Function getConnection

lib/db.js:129–154

(db)

module.exports.Store = Store;

function getConnection(db) {
  if (db.Db) return Promise.resolve(db.Db); // reuse connection
  if (typeof db.connectionString !== "string" || db.connectionString.length === 0) {
    error(new Error("Cannot initialize store. A proper connection string was not specified."));
    process.exit(1);
  }
  return new Promise(function(resolve, reject) {
    try {
      mongodb.MongoClient.connect(db.connectionString, db.connectionOptions, function (err, database) {
        if (!err) {
          db.Db = database;
          resolve(database);
        }
        else {
          // log error
          error(new Error("Cannot open store: " + err));
          // hide sensitive database connection error details
          reject("Database connection error");
        }
      });
    } catch(e){
      error(e);
      reject("Database connection error");
    }
  });
}

function collection(store, fn) {
  var db = store._db;