Added test case to exercise all non-crud methods on mongos topologies, fixed numberOfConnectedServers on mongos topology instance.

Author: christkv

HISTORY.md

@@ -1,3 +1,7 @@
+2.0.42 08-18-2015
+-----------------
+* Added test case to exercise all non-crud methods on mongos topologies, fixed numberOfConnectedServers on mongos topology instance.
+
 2.0.41 08-14-2015
 -----------------
 * Added missing Mongos.prototype.parserType function.

lib/command_cursor.js

@@ -142,7 +142,7 @@ inherits(CommandCursor, Readable);
 // Set the methods to inherit from prototype
 var methodsToInherit = ['_next', 'next', 'each', 'forEach', 'toArray'
   , 'rewind', 'bufferedCount', 'readBufferedDocuments', 'close', 'isClosed', 'kill'
-  , '_find', '_getmore', '_killcursor'];
+  , '_find', '_getmore', '_killcursor', 'isDead', 'isNotified', 'isKilled'];
 
 // Only inherit the types we need
 for(var i = 0; i < methodsToInherit.length; i++) {

lib/mongos.js

@@ -192,7 +192,9 @@ var Mongos = function(servers, options) {
 
   // Last ismaster
   Object.defineProperty(this, 'numberOfConnectedServers', {
-    enumerable:true, get: function() { return self.s.mongos.connectedServers().length; }
+    enumerable:true, get: function() { 
+      return self.s.mongos.s.mongosState.connectedServers().length; 
+    }
   });
 
   // BSON property

package.json

@@ -1,6 +1,6 @@
 {
   "name": "mongodb",
-  "version": "2.0.41",
+  "version": "2.0.42",
   "description": "MongoDB legacy driver emulation layer on top of mongodb-core",
   "main": "index.js",
   "repository": {

test/functional/crud_api_tests.js

@@ -871,3 +871,41 @@ exports['should correctly execute updateOne operations with w:0 and upsert'] = {
     });
   }
 }
+
+exports['should correctly execute crud operations using w:0'] = {
+  // Add a tag that our runner can trigger on
+  // in this case we are setting that node needs to be higher than 0.10.X to run
+  metadata: { requires: { topology: ['single', 'replicaset', 'sharded', 'ssl', 'heap', 'wiredtiger'] } },
+
+  // The actual test we wish to run
+  test: function(configuration, test) {
+    var db = configuration.newDbInstance(configuration.writeConcernMax(), {poolSize:1, auto_reconnect:false});
+    // Establish connection to db
+    db.open(function(err, db) {
+      test.equal(null, err);
+
+      var collection = db.collection('w0crudoperations');
+      collection.insertOne({}, function(err, r) {
+        console.log("-------------------------------------------")
+        console.dir(err)
+        console.dir(r)
+
+        db.close();
+        test.done();
+      });
+
+      // collection.insertOne({a:1});
+      // collection.insertMany([{b:1}]);
+      // collection.updateOne({c:1}, {$set:{a:1}}, {upsert:true});
+
+
+      // db.collection('try').updateOne({_id:1}, {$set:{x:1}}, {upsert:true, w:0}, function(err, r) {
+      //   test.equal(null, err);
+      //   test.ok(r != null);
+
+      //   db.close();
+      //   test.done();
+      // });
+    });
+  }
+}

test/functional/sharding_connection_tests.js

@@ -141,4 +141,40 @@ exports['Should correctly emit open and fullsetup to all db instances'] = {
       });                                                                           
     });
   }
-}
+}
+
+/**
+ * @ignore
+ */
+exports['Should exercise all options on mongos topology'] = {
+  metadata: { requires: { topology: 'sharded' } },
+  
+  // The actual test we wish to run
+  test: function(configuration, test) {
+    var MongoClient = configuration.require.MongoClient;
+
+    var url = f('mongodb://%s:%s,%s:%s/sharded_test_db?w=1&readPreference=secondaryPreferred&readPreferenceTags=sf%3A1&readPreferenceTags='
+      , configuration.host, configuration.port
+      , configuration.host, configuration.port + 1);
+    MongoClient.connect(url, {
+      mongos: {
+        haInterval: 500
+      }
+    }, function(err, db) {          
+      test.equal(null, err);
+      test.ok(db != null);
+      test.equal(500, db.serverConfig.haInterval);
+      test.ok(db.serverConfig.capabilities() != null);
+      test.ok(db.serverConfig.parserType() != null);
+      test.equal(true, db.serverConfig.isConnected());
+      test.ok(db.serverConfig.lastIsMaster() != null);
+      test.ok(db.serverConfig.connections() != null);
+      test.ok(db.serverConfig.isMasterDoc != null);
+      test.ok(db.serverConfig.numberOfConnectedServers != null);
+      test.ok(db.serverConfig.bson != null);
+
+      db.close();
+      test.done();
+    });
+  }
+}