Handle CSV DSN in ZookeeperStore

Author: qkdreyer

Store/ZookeeperStore.php

@@ -45,11 +45,15 @@ public static function createConnection(string $dsn): \Zookeeper
         }
 
         $host = $params['host'] ?? '';
-        if (isset($params['port'])) {
-            $host .= ':'.$params['port'];
+        $hosts = explode(',', $host);
+
+        foreach ($hosts as $index => $host) {
+            if (isset($params['port'])) {
+                $hosts[$index] = $host.':'.$params['port'];
+            }
         }
 
-        return new \Zookeeper($host);
+        return new \Zookeeper(implode($hosts, ','));
     }
 
     /**

Tests/Store/StoreFactoryTest.php

@@ -62,6 +62,7 @@ public function validConnections()
         if (class_exists(\Zookeeper::class)) {
             yield [$this->createMock(\Zookeeper::class), ZookeeperStore::class];
             yield ['zookeeper://localhost:2181', ZookeeperStore::class];
+            yield ['zookeeper://localhost01,localhost02:2181', ZookeeperStore::class];
         }
         if (\extension_loaded('sysvsem')) {
             yield ['semaphore', SemaphoreStore::class];