[dsn] Cluster DSN

Author: makasim

GenericStatsStorageFactory.php

@@ -22,7 +22,7 @@ public function create($config): StatsStorage
             throw new \InvalidArgumentException('The config must have dsn key set.');
         }
 
-        $dsn = new Dsn($config['dsn']);
+        $dsn = Dsn::parseFirst($config['dsn']);
 
         if ($storageClass = $this->findStorageClass($dsn, Resources::getKnownStorages())) {
             return new $storageClass(1 === count($config) ? $config['dsn'] : $config);

InfluxDbStorage.php

@@ -182,7 +182,7 @@ private function getDb(): Database
 
     private function parseDsn(string $dsn): array
     {
-        $dsn = new Dsn($dsn);
+        $dsn = Dsn::parseFirst($dsn);
 
         if (false === in_array($dsn->getSchemeProtocol(), ['influxdb'], true)) {
             throw new \LogicException(sprintf(
@@ -196,10 +196,10 @@ private function parseDsn(string $dsn): array
             'port' => $dsn->getPort(),
             'user' => $dsn->getUser(),
             'password' => $dsn->getPassword(),
-            'db' => $dsn->getQueryParameter('db'),
-            'measurementSentMessages' => $dsn->getQueryParameter('measurementSentMessages'),
-            'measurementConsumedMessages' => $dsn->getQueryParameter('measurementConsumedMessages'),
-            'measurementConsumers' => $dsn->getQueryParameter('measurementConsumers'),
+            'db' => $dsn->getString('db'),
+            'measurementSentMessages' => $dsn->getString('measurementSentMessages'),
+            'measurementConsumedMessages' => $dsn->getString('measurementConsumedMessages'),
+            'measurementConsumers' => $dsn->getString('measurementConsumers'),
         ]), function ($value) { return null !== $value; });
     }
 }

WampStorage.php

@@ -192,7 +192,7 @@ private function createClient(): Client
 
     private function parseDsn(string $dsn): array
     {
-        $dsn = new Dsn($dsn);
+        $dsn = Dsn::parseFirst($dsn);
 
         if (false === in_array($dsn->getSchemeProtocol(), ['wamp', 'ws'], true)) {
             throw new \LogicException(sprintf(
@@ -204,10 +204,10 @@ private function parseDsn(string $dsn): array
         return array_filter(array_replace($dsn->getQuery(), [
             'host' => $dsn->getHost(),
             'port' => $dsn->getPort(),
-            'topic' => $dsn->getQueryParameter('topic'),
-            'max_retries' => $dsn->getInt('max_retries'),
+            'topic' => $dsn->getString('topic'),
+            'max_retries' => $dsn->getDecimal('max_retries'),
             'initial_retry_delay' => $dsn->getFloat('initial_retry_delay'),
-            'max_retry_delay' => $dsn->getInt('max_retry_delay'),
+            'max_retry_delay' => $dsn->getDecimal('max_retry_delay'),
             'retry_delay_growth' => $dsn->getFloat('retry_delay_growth'),
         ]), function ($value) { return null !== $value; });
     }