NODE-266 support listIndexes on 2.7 and higher

Author: christkv

lib/db.js

@@ -438,12 +438,8 @@ var Db = function(databaseName, topology, options) {
       if(err) return fallbackListCollections();
       // List of result documents that have been filtered
       var filtered_documents = result.collections.filter(function(document) {
-        if(name && document.name != name) {
-          return false;
-        } else if(document.name.indexOf('$') != -1) {
-          return false;
-        }
-
+        if(name && document.name != name) return false;
+        if(document.name.indexOf('$') != -1) return false;
         return true;
       });
 
@@ -1127,23 +1123,11 @@ var Db = function(databaseName, topology, options) {
 
     // If we specified full information
     var full = options['full'] == null ? false : options['full'];
-    // Build selector for the indexes
-    var selector = name != null ? {ns: (databaseName + "." + name)} : {};
 
-    // Get read preference if we set one
-    readPreference = ReadPreference.PRIMARY;
-
-    // Iterate through all the fields of the index
-    var collection = this.collection(Db.SYSTEM_INDEX_COLLECTION);
-    // Perform the find for the collection
-    collection.find(selector).setReadPreference(readPreference).toArray(function(err, indexes) {
-      if(err != null) return handleCallback(callback, err, null);
+    // Process all the results from the index command and collection
+    var processResults = function(indexes) {
       // Contains all the information
       var info = {};
-
-      // if full defined just return all the indexes directly
-      if(full) return handleCallback(callback, null, indexes);
-
       // Process all the indexes
       for(var i = 0; i < indexes.length; i++) {
         var index = indexes[i];
@@ -1154,8 +1138,36 @@ var Db = function(databaseName, topology, options) {
         }
       }
 
+      return info;
+    }
+
+    // Fallback to pre 2.8 getting the index information
+    var fallbackListIndexes = function() {
+      // Build selector for the indexes
+      var selector = name != null ? {ns: (databaseName + "." + name)} : {};
+
+      // Get read preference if we set one
+      readPreference = ReadPreference.PRIMARY;
+
+      // Iterate through all the fields of the index
+      var collection = self.collection(Db.SYSTEM_INDEX_COLLECTION);
+      // Perform the find for the collection
+      collection.find(selector).setReadPreference(readPreference).toArray(function(err, indexes) {
+        if(err != null) return handleCallback(callback, err, null);
+        // if full defined just return all the indexes directly
+        if(full) return handleCallback(callback, null, indexes);
+        // Return all the indexes
+        handleCallback(callback, null, processResults(indexes));
+      });
+    }
+
+    // Attempt to execute the listIndexes command
+    self.command({listIndexes: name}, function(err, result) {
+      if(err) return fallbackListIndexes();
+      // if full defined just return all the indexes directly
+      if(full) return handleCallback(callback, null, result.indexes);
       // Return all the indexes
-      handleCallback(callback, null, info);
+      handleCallback(callback, null, processResults(result.indexes));
     });
   };
 

test/functional/scram_tests.js

@@ -1,4 +1,5 @@
 /**
+ * rm -rf data; mkdir data; mongod --dbpath=./data --setParameter authenticationMechanisms=SCRAM-SHA-1 --auth
  * @ignore
  */
 exports['should correctly create a new user and authenticate using scram'] = {