Clear the connectionPromise upon close or error (parse-community#2314)

back4app · Mar 15, 2017 · 4cb08d9 · 4cb08d9
1 parent a872093
commit 4cb08d9
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/src/Adapters/Storage/Mongo/MongoStorageAdapter.js b/src/Adapters/Storage/Mongo/MongoStorageAdapter.js
@@ -105,7 +105,20 @@ export class MongoStorageAdapter {
  const encodedUri = formatUrl(parseUrl(this._uri));
 
  this.connectionPromise = MongoClient.connect(encodedUri, this._mongoOptions).then(database => {
+ if (!database) {
+ delete this.connectionPromise;
+ return;
+ }
+ database.on('error', (error) => {
+ delete this.connectionPromise;
+ });
+ database.on('close', (error) => {
+ delete this.connectionPromise;
+ });
  this.database = database;
+ }).catch((err) => {
+ delete this.connectionPromise;
+ return Promise.reject(err);
  });
 
  return this.connectionPromise;