update mongodb to 3.x

lib/collection.js

@@ -228,9 +228,9 @@ Collection.prototype.findOne = function (query, opts, fn) {
 
   return this._dispatch(function findOne (args) {
     return args.col.find(args.query, args.options).limit(1).toArray()
-    .then(function (docs) {
-      return (docs && docs[0]) || null
-    })
+      .then(function (docs) {
+        return (docs && docs[0]) || null
+      })
   })({options: opts, query: query, callback: fn}, 'findOne')
 }
 

lib/manager.js

@@ -126,13 +126,15 @@ inherits(Manager, EventEmitter)
  * @private
  */
 Manager.prototype.open = function (uri, opts, fn) {
-  MongoClient.connect(uri, opts, function (err, db) {
-    if (err || !db) {
+  MongoClient.connect(uri, opts, function (err, client) {
+    if (err) {
       this._state = STATE.CLOSED
       this.emit('error-opening', err)
     } else {
       this._state = STATE.OPEN
-      this._db = db
+
+      this._client = client
+      this._db = client.db()
 
       // set up events
       var self = this
@@ -142,7 +144,7 @@ Manager.prototype.open = function (uri, opts, fn) {
         })
       })
 
-      this.emit('open', db)
+      this.emit('open', this._db)
     }
     if (fn) {
       fn(err, this)
@@ -212,8 +214,8 @@ Manager.prototype.close = function (force, fn) {
   }
 
   var self = this
-  function close (resolve, db) {
-    db.close(force, function () {
+  function close (resolve) {
+    self._client.close(force, function () {
       self._state = STATE.CLOSED
       if (fn) {
         fn()
@@ -230,14 +232,14 @@ Manager.prototype.close = function (force, fn) {
       return Promise.resolve()
     case STATE.OPENING:
       return new Promise(function (resolve) {
-        self._queue.push(function (db) {
-          close(resolve, db)
+        self._queue.push(function () {
+          close(resolve)
         })
       })
     case STATE.OPEN:
     default:
       return new Promise(function (resolve) {
-        close(resolve, self._db)
+        close(resolve)
       })
   }
 }