catch mongo errors. delete (some) sessions from mongo. more package updates. cleanup of express-validator.

1 files changed, 33 insertions, 14 deletions

diff --git a/src/server/database.ts b/src/server/database.ts
index 0893bfd35..3a087ce38 100644
--- a/src/server/database.ts
+++ b/src/server/database.ts
@@ -83,13 +83,18 @@ export namespace Database {
                 let newProm: Promise<void>;
                 const run = (): Promise<void> => {
                     return new Promise<void>(resolve => {
-                        collection.updateOne({ _id: id }, value, { upsert }).then(res => {
-                            if (this.currentWrites[id] === newProm) {
-                                delete this.currentWrites[id];
-                            }
-                            resolve();
-                            callback(undefined as any, res);
-                        });
+                        collection
+                            .updateOne({ _id: id }, value, { upsert })
+                            .then(res => {
+                                if (this.currentWrites[id] === newProm) {
+                                    delete this.currentWrites[id];
+                                }
+                                resolve();
+                                callback(undefined as any, res);
+                            })
+                            .catch(error => {
+                                console.log('MOngo UPDATE ONE ERROR:', error);
+                            });
                     });
                 };
                 newProm = prom ? prom.then(run) : run();
@@ -185,12 +190,17 @@ export namespace Database {
                 let newProm: Promise<void>;
                 const run = (): Promise<void> => {
                     return new Promise<void>(resolve => {
-                        collection.insertOne(value).then(res => {
-                            if (this.currentWrites[id] === newProm) {
-                                delete this.currentWrites[id];
-                            }
-                            resolve();
-                        });
+                        collection
+                            .insertOne(value)
+                            .then(res => {
+                                if (this.currentWrites[id] === newProm) {
+                                    delete this.currentWrites[id];
+                                }
+                                resolve();
+                            })
+                            .catch(err => {
+                                console.log('Mongo INSERT ERROR: ', err);
+                            });
                     });
                 };
                 newProm = prom ? prom.then(run) : run();
@@ -285,10 +295,19 @@ export namespace Database {
                         .collection(collectionName)
                         .updateMany(query, update)
                         .then(result => res(result))
+                        .catch(error => {
+                            console.log('Mongo INSERT MANY ERROR:', error);
+                        })
                 );
             } else {
                 return new Promise<mongodb.UpdateResult>(res => {
-                    this.onConnect.push(() => this.updateMany(query, update, collectionName).then(res));
+                    this.onConnect.push(() =>
+                        this.updateMany(query, update, collectionName)
+                            .then(res)
+                            .catch(error => {
+                                console.log('Mongo UPDATAE MANY ERROR: ', error);
+                            })
+                    );
                 });
             }
         }