aboutsummaryrefslogtreecommitdiff
path: root/src/server/database.ts
diff options
context:
space:
mode:
authorSam Wilkins <35748010+samwilkins333@users.noreply.github.com>2019-10-09 16:59:11 -0400
committerGitHub <noreply@github.com>2019-10-09 16:59:11 -0400
commit062a938dae7e78b59aaf9a706d2b656cc4474ac6 (patch)
treedbbbfe1238a4babd3638132ea48f7e2332e7c540 /src/server/database.ts
parent0890639c166df6558c3a5c0fd3d427157b3549de (diff)
parentae9584b6a0b588e0b854a7c5b56723e1a71d47d3 (diff)
Merge pull request #293 from browngraphicslab/exif
Exif
Diffstat (limited to 'src/server/database.ts')
-rw-r--r--src/server/database.ts7
1 files changed, 3 insertions, 4 deletions
diff --git a/src/server/database.ts b/src/server/database.ts
index d2375ebd9..990441d5a 100644
--- a/src/server/database.ts
+++ b/src/server/database.ts
@@ -131,7 +131,7 @@ export namespace Database {
}
}
- public getDocument(id: string, fn: (result?: Transferable) => void, collectionName = Database.DocumentsCollection) {
+ public getDocument(id: string, fn: (result?: Transferable) => void, collectionName = "newDocuments") {
if (this.db) {
this.db.collection(collectionName).findOne({ _id: id }, (err, result) => {
if (result) {
@@ -165,7 +165,7 @@ export namespace Database {
}
}
- public async visit(ids: string[], fn: (result: any) => string[], collectionName = "newDocuments"): Promise<void> {
+ public async visit(ids: string[], fn: (result: any) => string[] | Promise<string[]>, collectionName = "newDocuments"): Promise<void> {
if (this.db) {
const visited = new Set<string>();
while (ids.length) {
@@ -179,10 +179,9 @@ export namespace Database {
for (const doc of docs) {
const id = doc.id;
visited.add(id);
- ids.push(...fn(doc));
+ ids.push(...(await fn(doc)));
}
}
-
} else {
return new Promise(res => {
this.onConnect.push(() => {