allow multiple endpoints as dsn to avoid downtime if single node fail…

…s. (new config `hosts`)

src/DependencyInjection/Configuration.php

@@ -16,6 +16,13 @@ public function getConfigTreeBuilder()
             ->children()
             ->arrayNode('client')
             ->children()
+            ->arrayNode('connections')->info('An array of DSN to connect to the Elasticsearch cluster.')
+            ->arrayPrototype()
+            ->children()
+            ->scalarNode('url')->end()
+            ->end()
+            ->end()
+            ->end()
             ->scalarNode('dsn')->defaultValue('http://localhost:9200')->info('The DSN to connect to the Elasticsearch cluster.')->end()
             ->booleanNode('should_add_sentry_breadcrumbs')->defaultFalse()->info('If true, breadcrumbs are added to Sentry for every request made to Elasticsearch via Elastica.')->end()
             ->end()

src/Repository/ConfigurationRepository.php

@@ -4,6 +4,8 @@
 
 namespace Valantic\ElasticaBridgeBundle\Repository;
 
+use Psr\Container\ContainerExceptionInterface;
+use Psr\Container\NotFoundExceptionInterface;
 use Symfony\Component\DependencyInjection\ParameterBag\ContainerBagInterface;
 
 /**
@@ -15,8 +17,18 @@ public function __construct(
         private readonly ContainerBagInterface $containerBag,
     ) {}
 
-    public function getClientDsn(): string
+    /**
+     * @throws ContainerExceptionInterface
+     * @throws NotFoundExceptionInterface
+     *
+     * @return string|array<string>
+     */
+    public function getClientDsn(): string|array
     {
+        if ($this->containerBag->get('valantic_elastica_bridge')['client']['connections'] !== []) {
+            return ['connections' => $this->containerBag->get('valantic_elastica_bridge')['client']['connections']];
+        }
+
         return $this->containerBag->get('valantic_elastica_bridge')['client']['dsn'];
     }