MongoDB Connection Pool

gistfile1.js

'use strict';
var uri = require('../util/url');
var pool = require('generic-pool');
var driver = require('mongodb');
var flag = require('node-env-flag');

module.exports = function(url) {
  var connection_settings = uri(url || process.env.MONGODB_URL);

  return pool.Pool({
    name: 'mongodb',
    create: function(callback) {
      var server = new driver.Server(connection_settings.hostname, connection_settings.port, {});
      var client = new driver.Db(connection_settings.db, server, {safe: false});

      client.open(function(err, p_client) {
        if (err) {
          callback(err, null);
          return;
        }

        if (connection_settings.username && connection_settings.password) {
          client.authenticate(connection_settings.username, connection_settings.password, function(err, replies) {
            if (err) {
              callback(err, null);
              return;
            }

            callback(null, client);
          });
        } else {
          callback(null, client);
        }

      });
    },
    destroy: function(client) {
      client.close();
    },
    max: process.env.POOL_MAX_MONGODB || 10,
    min: process.env.POOL_MIN_MONGODB || 1,
    idleTimeoutMillis: process.env.POOL_TIMEOUT_MONGODB || 10000,
    log: flag(process.env.POOL_LOG_MONGODB, false)
  });
};