NODE-892 Passthrough options.readPreference to mongodb-core ReplSet instance.

Author: christkv

HISTORY.md

@@ -1,3 +1,8 @@
+2.2.14 2016-12-
+-----------------
+* Updated mongodb-core to 2.1.1.
+* NODE-892 Passthrough options.readPreference to mongodb-core ReplSet instance.
+
 2.2.13 2016-12-05
 -----------------
 * Updated mongodb-core to 2.1.0.

lib/replset.js

@@ -418,8 +418,16 @@ ReplSet.prototype.isDestroyed = function() {
 }
 
 // IsConnected
-ReplSet.prototype.isConnected = function() {
-  return this.s.replset.isConnected();
+ReplSet.prototype.isConnected = function(options) {
+  options = options || {};
+
+  // If we passed in a readPreference, translate to
+  // a CoreReadPreference instance
+  if(options.readPreference) {
+    options.readPreference = translateReadPreference(options.readPreference);
+  }
+
+  return this.s.replset.isConnected(options);
 }
 
 define.classMethod('isConnected', {callback: false, promise:false, returns: [Boolean]});

package.json

@@ -1,6 +1,6 @@
 {
   "name": "mongodb",
-  "version": "2.2.13",
+  "version": "2.2.14",
   "description": "The official MongoDB driver for Node.js",
   "main": "index.js",
   "repository": {
@@ -15,6 +15,7 @@
   "dependencies": {
     "es6-promise": "3.2.1",
     "mongodb-core": "2.1.0",
+    "mongodb-core": "christkv/mongodb-core#2.0",
     "readable-stream": "2.1.5"
   },
   "devDependencies": {

test/functional/apm_tests.js

@@ -132,7 +132,6 @@ exports['Correctly receive the APM events for a listIndexes command'] = {
           test.equal(null, err);
 
           db.collection('apm_test_list_collections').listIndexes({readPreference: ReadPreference.SECONDARY}).toArray(function(err, cols) {
-            console.dir(err)
             // console.log(started[0].connectionId.port)
             // console.log(started[1].connectionId.port)
             test.equal(null, err);