Added replset Status Command

example/get_replica_status.dart

@@ -0,0 +1,46 @@
+import 'package:mongo_dart/mongo_dart.dart';
+
+/// At the moment you can only run getStatus() command on primary
+/// On secondary we get a "MongoDart Error: No master connection" because we have no read permission on it
+/// To test with secondary you can comment our the lines 29 and 31 in connection_manager.dart
+main() async {
+  var db = new Db("mongodb://127.0.0.1:27017/admin");
+  await db.open();
+
+  Map<String, dynamic> rep_status = await db.getStatus();
+  //print(rep_status);
+  if (rep_status.containsKey("members")) {
+    List<dynamic> members = rep_status['members'];
+    int members_count = members.length;
+    print("Members Count: " + members_count.toString());
+    members.forEach((dynamic value) {
+      print("-----------------------------------");
+      //print(value);
+      int _id = value['_id'];
+      String name = value['name'];
+      double health = value['health'];
+      String stateStr = value['stateStr'];
+      int uptime = value['uptime'];
+
+      print("Member id: " + _id.toString());
+      print("Member name: " + name);
+      print("Member health: " + health.toString());
+      print("Member State: " + stateStr.toString());
+      print("Member State: " + secToTime(uptime));
+    });
+  }
+
+  await db.close();
+}
+
+String secToTime(int seconds) {
+  double hours = seconds / 3600;
+  double mins = seconds / 60 % 60;
+  int secs = seconds % 60;
+  return hours.floor().toString() +
+      "h " +
+      mins.floor().toString() +
+      "m " +
+      secs.floor().toString() +
+      "s";
+}

lib/src/database/db.dart

@@ -334,6 +334,11 @@ class Db {
         connection: connection);
   }
 
+  Future<Map<String, dynamic>> getStatus({_Connection connection}) {
+    return executeDbCommand(DbCommand.createStatusCommand(this),
+        connection: connection);
+  }
+
   Future<Map<String, dynamic>> isMaster({_Connection connection}) {
     return executeDbCommand(DbCommand.createIsMasterCommand(this),
         connection: connection);

lib/src/database/dbcommand.dart

@@ -112,6 +112,10 @@ class DbCommand extends MongoQueryMessage {
     return createQueryDbCommand(db, {'buildInfo': 1});
   }
 
+  static DbCommand createStatusCommand(Db db) {
+    return createQueryDbCommand(db, {'replSetGetStatus': 1 });
+  }
+
   static DbCommand createGetLastErrorCommand(Db db, WriteConcern concern) {
     return createQueryDbCommand(db, concern.command);
   }

lib/src/network/connection_manager.dart

@@ -26,9 +26,9 @@ class _ConnectionManager {
     _log.fine(() => replyMessage.documents[0].toString());
     var master = replyMessage.documents[0]["ismaster"] == true;
     connection.isMaster = master;
-    if (master) {
+    //if (master) {
       _masterConnection = connection;
-    }
+    //}
     connection.serverCapabilities
         .getParamsFromIstMaster(replyMessage.documents[0]);
     if (db._authenticationScheme == null) {

test/database_test.dart

@@ -9,6 +9,7 @@ import 'package:uuid/uuid.dart';
 const dbName = "test-mongo-dart";
 
 const DefaultUri = 'mongodb://localhost:27017/$dbName';
+const DefaultAdminUri = 'mongodb://localhost:27017/admin';
 
 Db db;
 Uuid uuid = new Uuid();
@@ -65,6 +66,11 @@ Future getBuildInfo() async {
   expect(result["ok"], 1);
 }
 
+Future getStatus() async {
+  var result = await db.getStatus();
+  expect(result["ok"], 1);
+}
+
 Future testIsMaster() async {
   var result = await db.isMaster();
   expect(result["ok"], 1);
@@ -1142,6 +1148,11 @@ Future testFindOneWhileStateIsOpening() {
 }
 
 main() {
+  Future initializeAdminDatabase() async {
+    db = new Db(DefaultAdminUri);
+    await db.open();
+  }
+
   Future initializeDatabase() async {
     db = new Db(DefaultUri);
     await db.open();
@@ -1151,6 +1162,20 @@ main() {
     await db.close();
   }
 
+  group("Admin", () {
+    setUp(() async {
+      await initializeAdminDatabase();
+    });
+
+    tearDown(() async {
+      await cleanupDatabase();
+    });
+
+    group('DBCommand:', () {
+      test('getStatus', getStatus);
+    });
+  });
+
   group("A", () {
     setUp(() async {
       await initializeDatabase();