aboutsummaryrefslogtreecommitdiff
path: root/src/server/database.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/database.ts')
-rw-r--r--src/server/database.ts40
1 files changed, 17 insertions, 23 deletions
diff --git a/src/server/database.ts b/src/server/database.ts
index c51d4a3f6..7914febf8 100644
--- a/src/server/database.ts
+++ b/src/server/database.ts
@@ -20,31 +20,25 @@ export class Database {
let newProm: Promise<void>;
const run = (): Promise<void> => {
return new Promise<void>(resolve => {
- collection.updateOne({ _id: id }, { $set: value }, {
- upsert: true
- }, (err, res) => {
- if (err) {
- console.log(err.message);
- console.log(err.errmsg);
- }
- // if (res) {
- // console.log(JSON.stringify(res.result));
- // }
- if (this.currentWrites[id] === newProm) {
- delete this.currentWrites[id];
- }
- resolve();
- callback();
- });
+ collection.updateOne({ _id: id }, { $set: value }, { upsert: true }
+ , (err, res) => {
+ if (err) {
+ console.log(err.message);
+ console.log(err.errmsg);
+ }
+ // if (res) {
+ // console.log(JSON.stringify(res.result));
+ // }
+ if (this.currentWrites[id] === newProm) {
+ delete this.currentWrites[id];
+ }
+ resolve();
+ callback();
+ });
});
};
- if (prom) {
- newProm = prom.then(run);
- this.currentWrites[id] = newProm;
- } else {
- newProm = run();
- this.currentWrites[id] = newProm;
- }
+ newProm = prom ? prom.then(run) : run();
+ this.currentWrites[id] = newProm;
}
}