COMPASS 171: Fix doc & index stats on secondary reported incorrectly (#52)

Better fixes incoming in COMPASS-368 and later tickets.

Author: pzrq

lib/fetch.js

@@ -8,9 +8,15 @@ var _ = require('lodash');
 var async = require('async');
 var mongodbNS = require('mongodb-ns');
 var isNotAuthorizedError = require('mongodb-js-errors').isNotAuthorized;
+var ReadPreference = require('mongodb').ReadPreference;
 
 var debug = require('debug')('mongodb-index-model:fetch');
 
+/**
+ * The default read preference.
+ */
+var READ = ReadPreference.PRIMARY_PREFERRED;
+
 /**
  * helper function to attach objects to the async.auto task structure.
  * @param  {any}   anything  pass in any variable to attach it to the name
@@ -28,7 +34,7 @@ function attach(anything, done) {
 function getIndexes(done, results) {
   var db = results.db;
   var ns = mongodbNS(results.namespace);
-  db.db(ns.database).collection(ns.collection).indexes(function(err, indexes) {
+  db.db(ns.database, {readPreference: {mode: READ}}).collection(ns.collection).indexes(function(err, indexes) {
     if (err) {
       done(err);
     }
@@ -52,7 +58,7 @@ function getIndexStats(done, results) {
     { $indexStats: { } },
     { $project: { name: 1, usageHost: '$host', usageCount: '$accesses.ops', usageSince: '$accesses.since' } }
   ];
-  var collection = db.db(ns.database).collection(ns.collection);
+  var collection = db.db(ns.database, {readPreference: {mode: READ}}).collection(ns.collection);
   collection.aggregate(pipeline, function(err, res) {
     if (err) {
       if (isNotAuthorizedError(err)) {
@@ -86,7 +92,7 @@ function getIndexStats(done, results) {
 function getIndexSizes(done, results) {
   var db = results.db;
   var ns = mongodbNS(results.namespace);
-  db.db(ns.database).collection(ns.collection).stats(function(err, res) {
+  db.db(ns.database, {readPreference: {mode: READ}}).collection(ns.collection).stats(function(err, res) {
     if (err) {
       if (isNotAuthorizedError(err)) {
         debug('Not authorized to get collection stats.  Returning default for indexSizes {}.');

package.json

@@ -28,6 +28,7 @@
     "ampersand-rest-collection": "^5.0.0",
     "async": "^1.5.2",
     "lodash": "^4.8.2",
+    "mongodb": "^2.2.11",
     "mongodb-js-errors": "^0.2.1",
     "mongodb-ns": "^1.0.3",
     "triejs": "github:rueckstiess/triejs"