diff options
author | Sam Wilkins <35748010+samwilkins333@users.noreply.github.com> | 2019-10-09 16:59:11 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-10-09 16:59:11 -0400 |
commit | 062a938dae7e78b59aaf9a706d2b656cc4474ac6 (patch) | |
tree | dbbbfe1238a4babd3638132ea48f7e2332e7c540 /src/server/database.ts | |
parent | 0890639c166df6558c3a5c0fd3d427157b3549de (diff) | |
parent | ae9584b6a0b588e0b854a7c5b56723e1a71d47d3 (diff) |
Merge pull request #293 from browngraphicslab/exif
Exif
Diffstat (limited to 'src/server/database.ts')
-rw-r--r-- | src/server/database.ts | 7 |
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(() => { |