const MongoClient = require('mongodb').MongoClient

async function connect(ops) {
  if (!ops) throw new Error("Invalid DB connection params, will not attempt to connect !");

  let _uri = ops.url;
  if (!_uri) {
    _uri = `mongodb://${ops.user}:${ops.pass}@${ops.hosts}/${ops.db}?authSource=${ops.authSource || ops.db}`;
    ops.replicaSet && (_uri += '&replicaSet=' + ops.replicaSet);
  }

  return await MongoClient.connect(_uri, {
    family: 4,
    keepAlive: true
  });
}

module.exports = {
  connect
}