Implement passing mongojs connections

mongo-js · Oct 9, 2015 · 3a89ec7 · 3a89ec7
1 parent 143c836
commit 3a89ec7
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/lib/database.js b/lib/database.js
@@ -19,13 +19,10 @@ var Database = function (connString, cols, options) {
     this._getConnection = thunky(function (cb) {
       mongodb.connect(connString, options, cb)
     })
-  } else {
-    var connection = connString
-
-    // TODO: Check if the connection we got is already connected and connect if not!
-    this._getConnection = thunky(function (cb) {
-      cb(null, connection)
-    })
+  } else if (connString instanceof Database) { // mongojs
+    this._getConnection = connString._getConnection
+  } else { // try mongodb-native
+    // TODO: Implement mongodb connections
   }
 
   this.ObjectId = mongodb.ObjectId