feat(predis): support json:/csv: env processors for DSN arrays

phpunit.xml.dist

@@ -7,6 +7,7 @@
   <php>
     <ini name="error_reporting" value="-1"/>
     <env name="SHELL_VERBOSITY" value="-1"/>
+    <env name="REDIS_DSNS" value='["redis://sncredis@127.0.0.1/3","redis://sncredis@127.0.0.1/4","redis://sncredis@127.0.0.1/5"]'/>
   </php>
   <testsuites>
     <testsuite name="RedisBundle Test Suite">

psalm.xml.dist

@@ -19,6 +19,11 @@
                 <referencedMethod name="Symfony\Component\Config\Definition\Builder\NodeBuilder::end"/>
             </errorLevel>
         </UnusedMethodCall>
+        <PossiblyUnusedMethod>
+            <errorLevel type="suppress">
+                <referencedMethod name="Snc\RedisBundle\Tests\Functional\App\Controller\Controller::__construct"/>
+            </errorLevel>
+        </PossiblyUnusedMethod>
     </issueHandlers>
     <plugins>
         <pluginClass class="Psalm\PhpUnitPlugin\Plugin"/>

src/DependencyInjection/SncRedisExtension.php

@@ -185,7 +185,8 @@ private function loadPredisClient(array $client, ContainerBuilder $container): v
         $container->setDefinition($optionId, $optionDef);
         $clientDef = new Definition($client['class'] ?? (string) $container->getParameter('snc_redis.client.class'));
         $clientDef->addTag('snc_redis.client', ['alias' => $client['alias']]);
-        if ($connectionCount === 1 && !isset($client['options']['cluster']) && !isset($client['options']['replication'])) {
+
+        if ($connectionCount === 1 && !isset($client['options']['replication'])) {
             $clientDef->addArgument(new Reference(sprintf('snc_redis.connection.%s_parameters.%s', $connectionAliases[0], $client['alias'])));
         } else {
             $connections = [];

src/Factory/PredisParametersFactory.php

@@ -9,21 +9,51 @@
 use Snc\RedisBundle\DependencyInjection\Configuration\RedisDsn;
 
 use function array_filter;
+use function array_map;
 use function array_merge;
 use function constant;
+use function count;
 use function defined;
 use function is_a;
+use function is_array;
+use function is_string;
 use function sprintf;
 use function str_replace;
 
 /** @internal */
 class PredisParametersFactory
 {
+    /**
+     * @param class-string<ParametersInterface>      $class
+     * @param array<string, mixed>                   $options
+     * @param string|list<string>|list<list<string>> $dsn
+     *
+     * @return ParametersInterface|list<ParametersInterface>
+     */
+    public static function create(array $options, string $class, string|array $dsn): ParametersInterface|array
+    {
+        if (is_string($dsn)) {
+            $dsn = [$dsn];
+        }
+
+        // json:/csv: env processors can produce a single-element array wrapping the actual list
+        if (count($dsn) === 1 && is_array($dsn[0])) {
+            $dsn = $dsn[0];
+        }
+
+        $parameters = array_map(
+            static fn (string $d) => static::createFromSingleDsn($options, $class, $d),
+            $dsn,
+        );
+
+        return count($parameters) === 1 ? $parameters[0] : $parameters;
+    }
+
     /**
      * @param class-string<ParametersInterface> $class
      * @param array<string, mixed>              $options
      */
-    public static function create(array $options, string $class, string $dsn): ParametersInterface
+    private static function createFromSingleDsn(array $options, string $class, string $dsn): ParametersInterface
     {
         if (!is_a($class, ParametersInterface::class, true)) {
             throw new InvalidArgumentException(sprintf('%s::%s requires $class argument to implement %s', self::class, __METHOD__, ParametersInterface::class));

tests/Factory/PredisParametersFactoryTest.php

@@ -185,4 +185,28 @@ public function testCreateMergesSslWithTlsVersion(): void
         $this->assertSame(STREAM_CRYPTO_METHOD_TLSv1_2_CLIENT, $ssl['crypto_type']);
         $this->assertFalse($ssl['verify_peer']);
     }
+
+    /**
+     * @testWith ["redis://localhost"]
+     *           [["redis://localhost"]]
+     *           [[["redis://localhost"]]]
+     */
+    public function testCreateReturnsSingleParameters(string|array $dsn): void
+    {
+        $result = PredisParametersFactory::create([], Parameters::class, $dsn);
+        $this->assertInstanceOf(Parameters::class, $result);
+    }
+
+    /**
+     * @param array<int, string|array<int, string>> $dsn
+     *
+     * @testWith [["redis://host1", "redis://host2"]]
+     *           [[["redis://host1", "redis://host2"]]]
+     */
+    public function testCreateReturnsMultipleParameters(array $dsn): void
+    {
+        $result = PredisParametersFactory::create([], Parameters::class, $dsn);
+        $this->assertIsArray($result);
+        $this->assertCount(2, $result);
+    }
 }

tests/Functional/App/Controller/Controller.php

@@ -13,18 +13,26 @@
 
 namespace Snc\RedisBundle\Tests\Functional\App\Controller;
 
+use Predis\ClientInterface;
 use Redis;
 use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
 use Symfony\Component\HttpFoundation\JsonResponse;
 
 class Controller extends AbstractController
 {
-    public function __invoke(Redis $redis): JsonResponse
+    /** @param iterable<Redis|ClientInterface> $clients */
+    public function __construct(private iterable $clients)
     {
-        $redis->set('foo', 'bar');
+    }
+
+    public function __invoke(): JsonResponse
+    {
+        $result = null;
+        foreach ($this->clients as $client) {
+            $client->set('foo', 'bar');
+            $result = $client->get('foo');
+        }
 
-        return new JsonResponse([
-            'result' => $redis->get('foo'),
-        ]);
+        return new JsonResponse(['result' => $result]);
     }
 }

tests/Functional/App/config.yaml

@@ -35,11 +35,9 @@ snc_redis:
         cluster:
             type: predis
             alias: cluster
-            dsn:
-              - redis://sncredis@127.0.0.1/3
-              - redis://sncredis@127.0.0.1/4
-              - redis://sncredis@127.0.0.1/5
+            dsn: "%env(json:REDIS_DSNS)%"
             options:
+                cluster: predis
                 prefix: foo
                 connection_timeout: 10
                 connection_persistent: true
@@ -59,20 +57,14 @@ snc_redis:
         with_acl:
             type: predis
             alias: with_acl
-            dsn: redis://localhost/1
+            dsn: redis://snc_redis:snc_password@localhost:7099/1
             logging: false
-            options:
-                parameters:
-                    username: my_user
-                    password: sncredis
 
 services:
     _defaults:
         autowire: true
         autoconfigure: true
         public: false
-        bind:
-            Predis\Client $predisReplication: '@snc_redis.predis_replication'
 
     Redis: '@snc_redis.default'
 
@@ -87,6 +79,14 @@ services:
         resource: './Controller'
         tags: ['controller.service_arguments']
 
+    Snc\RedisBundle\Tests\Functional\App\Controller\PredisReplication:
+        bind:
+            Predis\Client $predisReplication: '@snc_redis.predis_replication'
+
+    Snc\RedisBundle\Tests\Functional\App\Controller\Controller:
+        arguments:
+            $clients: !tagged_iterator snc_redis.client
+
     var_dumper.cli_dumper:
         class: Symfony\Component\VarDumper\Dumper\CliDumper
         arguments: ['/dev/null']

tests/Functional/IntegrationTest.php

@@ -69,8 +69,8 @@ public function testIntegration(): void
         $this->assertInstanceOf(RedisDataCollector::class, $collector);
         $this->assertInstanceOf(ResetInterface::class, $container = $this->client->getKernel()->getContainer());
         $this->assertInstanceOf(RedisLogger::class, $redisLogger = $container->get('test.snc_redis.logger'));
-        $this->assertSame(5, $redisLogger->getNbCommands());
-        $this->assertCount(5, $collector->getCommands());
+        $this->assertSame(13, $redisLogger->getNbCommands());
+        $this->assertCount(13, $collector->getCommands());
         $container->reset();
         $this->assertSame(0, $redisLogger->getNbCommands());
     }