PHPC-189: Implement Manager->getServers()

Author: bjori

src/MongoDB/Manager.c

@@ -255,7 +255,10 @@ PHP_METHOD(Manager, executeDelete)
    Returns the Servers associated with this Manager */
 PHP_METHOD(Manager, getServers)
 {
-	php_phongo_manager_t     *intern;
+	php_phongo_manager_t         *intern;
+	mongoc_set_t                 *set;
+	size_t                        i;
+	(void)return_value_ptr; (void)return_value_used;
 
 
 	intern = (php_phongo_manager_t *)zend_object_store_get_object(getThis() TSRMLS_CC);
@@ -264,6 +267,16 @@ PHP_METHOD(Manager, getServers)
 		return;
 	}
 
+	array_init(return_value);
+	set = intern->client->topology->description.servers;
+	for(i=0; i<set->items_len; i++) {
+		zval *obj = NULL;
+
+		MAKE_STD_ZVAL(obj);
+
+		phongo_server_init(obj, intern->client, ((mongoc_server_description_t *)set->items[i].item)->id);
+		add_next_index_zval(return_value, obj);
+	}
 }
 /* }}} */
 

tests/replicaset/manager-getservers-001.phpt

@@ -0,0 +1,42 @@
+--TEST--
+MongoDB\Driver\Manager: getServers()
+--SKIPIF--
+<?php require "tests/utils/basic-skipif.inc"?>
+--FILE--
+<?php
+require_once "tests/utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(REPLICASET);
+
+
+$doc = array("example" => "document");
+$bulk = new \MongoDB\Driver\BulkWrite();
+$bulk->insert($doc);
+$wresult = $manager->executeBulkWrite(NS, $bulk);
+
+
+var_dump($manager->getServers());
+$servers = $manager->getServers();
+
+foreach($servers as $server) {
+    printf("%s:%d - primary: %d, secondary: %d, arbiter: %d\n", $server->getHost(), $server->getPort(), $server->isPrimary(), $server->isSecondary(), $server->isArbiter());
+}
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECTF--
+array(3) {
+  [0]=>
+  object(MongoDB\Driver\Server)#5 (0) {
+  }
+  [1]=>
+  object(MongoDB\Driver\Server)#6 (0) {
+  }
+  [2]=>
+  object(MongoDB\Driver\Server)#7 (0) {
+  }
+}
+192.168.112.10:3000 - primary: 1, secondary: 0, arbiter: 0
+192.168.112.10:3001 - primary: 0, secondary: 1, arbiter: 0
+192.168.112.10:3002 - primary: 0, secondary: 0, arbiter: 1
+===DONE===