0.0.6 objectStartingRow looks for { now.

Author: mattqs

lib/index.js

@@ -78,31 +78,31 @@ var extractResult = function (result) {
     {
       re: /db.isMaster/,
       run: function (resultp) {
-        return objectStartingRow3(resultp);
+        return objectStartingRow(resultp);
       }
     },
     {
       re: /rs.conf/,
       run: function (resultp) {
-        return objectStartingRow3(resultp);
+        return objectStartingRow(resultp);
       }
     },
     {
       re: /rs.initiate/,
       run: function (resultp) {
-        return objectStartingRow3(resultp);
+        return objectStartingRow(resultp);
       }
     },
     {
       re: /rs.add/,
       run: function (resultp) {
-        return objectStartingRow3(resultp);
+        return objectStartingRow(resultp);
       }
     },
     {
       re: /rs.status/,
       run: function (resultp) {
-        return objectStartingRow3(resultp);
+        return objectStartingRow(resultp);
       }
     }
   ];
@@ -127,13 +127,26 @@ var extractResult = function (result) {
 };
 
 
-var objectStartingRow3 = function (resultp) {
+var objectStartingRow = function (resultp) {
   var obj = JSON.parse(resultp.raw);
   var lines = obj[0].split(os.EOL);
   resultp.lines = _.clone(lines);
 
+  var jsonStartIndex = 0;
+  for (var i = 0; i < lines.length; i++) {
+    var line = lines[i];
+    //console.log('line', line);
+    if (line === '{') {
+      jsonStartIndex = i;
+      break;
+    }
+  }
+
+  //console.log('jsonStartIndex', jsonStartIndex);
+
+
   try {
-    var tempArray = lines.splice(2);
+    var tempArray = lines.splice(jsonStartIndex);
     //console.log('tempArray', tempArray);
 
     var jsonString = tempArray.reduce(function (previousValue, currentValue) {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "mongo-cli-js",
-  "version": "0.0.5",
+  "version": "0.0.6",
   "description": "A node.js wrapper for the mongo CLI",
   "main": "lib/index.js",
   "scripts": {

test/index.js

@@ -138,5 +138,26 @@ describe('Mongo', function () {
     });
   });
 
+  it('command rs.status() with replica set should pass', function (done) {
+    var mongo = new Mongo({
+      host: 'mongodb/mongodb1:27017,mongodb2:27018,mongodb3:27019'
+    });
+
+
+    assert.isNotNull(mongo);
+    var failed = false;
+    var err = null;
+    mongo.command('rs.status()').then(function (data) {
+      console.log('data = ', util.inspect(data, {depth:10}));
+      assert.isNotNull(data);
+    }).finally(function () {
+      //console.log('finally ');
+      assert.isFalse(failed);
+      assert.isNull(err);
+      done();
+    });
+  });
+
+
 });