CSHARP-1145: added support for cursors in list collections and list indexes.

Author: craiggwilson

MongoDB.Driver/Operations/ListCollectionsOperation.cs

@@ -108,7 +108,28 @@ private IEnumerable<BsonDocument> ExecuteUsingCommand(MongoConnection connection
             var operation = new CommandOperation<CommandResult>(_databaseName, _readerSettings, _writerSettings, command, flags, options, _readPreference, serializationOptions, serializer);
             var result = operation.Execute(connection);
             var response = result.Response;
-            return response["collections"].AsBsonArray.Select(value => (BsonDocument)value).ToList();
+            var cursorDocument = response["cursor"];
+            var cursorId = cursorDocument["id"].ToInt64();
+            var firstBatch = cursorDocument["firstBatch"].AsBsonArray.Select(v => v.AsBsonDocument);
+            var ns = cursorDocument["ns"].ToString();
+            using (var enumerator = new CursorEnumerator<BsonDocument>(
+                new ServerInstanceConnectionProvider(connection.ServerInstance),
+                ns,
+                firstBatch,
+                cursorId,
+                0,
+                0,
+                _readerSettings,
+                BsonDocumentSerializer.Instance,
+                null))
+            {
+                var collections = new List<BsonDocument>();
+                while (enumerator.MoveNext())
+                {
+                    collections.Add(enumerator.Current);
+                }
+                return collections;
+            }
         }
 
         private IEnumerable<BsonDocument> ExecuteUsingQuery(MongoConnection connection)

MongoDB.Driver/Operations/ListIndexesOperation.cs

@@ -46,7 +46,7 @@ public ListIndexesOperation(
             ReadPreference readPreference,
             BsonBinaryReaderSettings readerSettings,
             BsonBinaryWriterSettings writerSettings)
-       {
+        {
             if (string.IsNullOrEmpty(databaseName))
             {
                 throw new ArgumentException("Database name cannot be null or empty.", "databaseName");
@@ -95,7 +95,10 @@ public IEnumerable<BsonDocument> Execute(MongoConnection connection)
 
         private IEnumerable<BsonDocument> ExecuteUsingCommand(MongoConnection connection)
         {
-            var command = new CommandDocument("listIndexes", _collectionName);
+            var command = new CommandDocument
+            {
+                { "listIndexes", _collectionName }
+            };
             var flags = QueryFlags.None;
             var options = new BsonDocument();
             IBsonSerializationOptions serializationOptions = null;
@@ -118,7 +121,29 @@ private IEnumerable<BsonDocument> ExecuteUsingCommand(MongoConnection connection
                 throw;
             }
 
-            return result.Response["indexes"].AsBsonArray.Cast<BsonDocument>();
+
+            var cursorDocument = result.Response["cursor"];
+            var cursorId = cursorDocument["id"].ToInt64();
+            var firstBatch = cursorDocument["firstBatch"].AsBsonArray.Select(v => v.AsBsonDocument);
+            var ns = cursorDocument["ns"].ToString();
+            using (var enumerator = new CursorEnumerator<BsonDocument>(
+                new ServerInstanceConnectionProvider(connection.ServerInstance),
+                ns,
+                firstBatch,
+                cursorId,
+                0,
+                0,
+                _readerSettings,
+                BsonDocumentSerializer.Instance,
+                null))
+            {
+                var collections = new List<BsonDocument>();
+                while (enumerator.MoveNext())
+                {
+                    collections.Add(enumerator.Current);
+                }
+                return collections;
+            }
         }
 
         private IEnumerable<BsonDocument> ExecuteUsingQuery(MongoConnection connection)