[predis] Add support for prefix option

Author: ostrolucky

src/DependencyInjection/Configuration/RedisDsn.php

@@ -52,6 +52,8 @@ class RedisDsn
 
     protected ?string $role = null;
 
+    protected ?string $prefix = null;
+
     public function __construct(string $dsn)
     {
         $this->dsn = $dsn;
@@ -119,6 +121,11 @@ public function getPersistentId(): string
         return md5($this->dsn);
     }
 
+    public function getPrefix(): ?string
+    {
+        return $this->prefix;
+    }
+
     public function isValid(): bool
     {
         if (strpos($this->dsn, 'redis://') !== 0 && strpos($this->dsn, 'rediss://') !== 0) {
@@ -202,6 +209,10 @@ protected function parseParameters(array $matches): string
             $this->role = $params['role'];
         }
 
+        if (!empty($params['prefix'])) {
+            $this->prefix = $params['prefix'];
+        }
+
         return '';
     }
 

src/Factory/PredisParametersFactory.php

@@ -16,7 +16,14 @@
 /** @internal */
 class PredisParametersFactory
 {
-    /** @param array<string, mixed> $options */
+    /**
+     * @param class-string<T>      $class
+     * @param array<string, mixed> $options
+     *
+     * @return T
+     *
+     * @template T of  ParametersInterface
+     */
     public static function create(array $options, string $class, string $dsn): ParametersInterface
     {
         if (!is_a($class, ParametersInterface::class, true)) {
@@ -41,6 +48,7 @@ private static function parseDsn(RedisDsn $dsn): array
         $options = [
             'password' => $dsn->getPassword(),
             'weight' => $dsn->getWeight(),
+            'prefix' => $dsn->getPrefix(),
         ];
 
         if ($socket !== null) {

tests/Factory/PredisParametersFactoryTest.php

@@ -20,7 +20,6 @@ public static function createDp(): array
         return [
             [
                 'redis://z:df577d779b4f724c8c29b5eff5bcc534b732722b9df308a661f1b79014175063d5@ec2-34-321-123-45.us-east-1.compute.amazonaws.com:3210',
-                Parameters::class,
                 [
                     'test' => 123,
                     'some' => 'string',
@@ -48,7 +47,6 @@ public static function createDp(): array
             ],
             [
                 'redis://pw@/var/run/redis/redis-1.sock/10',
-                Parameters::class,
                 [
                     'test' => 124,
                     'password' => 'toto',
@@ -72,7 +70,6 @@ public static function createDp(): array
             ],
             [
                 'rediss://pw@localhost:6380',
-                Parameters::class,
                 [],
                 [
                     'scheme' => 'tls',
@@ -83,7 +80,6 @@ public static function createDp(): array
             ],
             [
                 'redis://localhost?alias=master',
-                Parameters::class,
                 ['replication' => 'predis'],
                 [
                     'scheme' => 'tcp',
@@ -98,7 +94,6 @@ public static function createDp(): array
             ],
             [
                 'redis://localhost?alias=connection_alias',
-                Parameters::class,
                 [
                     'replication' => 'predis',
                     'alias' => 'client_alias',
@@ -116,23 +111,34 @@ public static function createDp(): array
             ],
             [
                 'redis://localhost/0',
-                Parameters::class,
                 ['persistent' => true],
                 [
                     'persistent' => true,
                     'database' => 0,
                 ],
             ],
-
             [
                 'redis://localhost',
-                Parameters::class,
                 ['database' => 11, 'password' => 'pass'],
                 [
                     'database' => 11,
                     'password' => 'pass',
                 ],
             ],
+            'everything in DSN' => [
+                'rediss://pw@localhost:6380/0?prefix=foo&alias=connection_alias',
+                [],
+                $allOptions = [
+                    'scheme' => 'tls',
+                    'host' => 'localhost',
+                    'port' => 6380,
+                    'password' => 'pw',
+                    'database' => 0,
+                    'prefix' => 'foo',
+                    'alias' => 'connection_alias',
+                ],
+            ],
+            'everything in options' => ['rediss://localhost:6380', $allOptions, $allOptions]
         ];
     }
 
@@ -142,11 +148,9 @@ public static function createDp(): array
      *
      * @dataProvider createDp
      */
-    public function testCreate(string $dsn, string $class, array $options, array $expectedParameters): void
+    public function testCreate(string $dsn, array $options, array $expectedParameters): void
     {
-        $parameters = PredisParametersFactory::create($options, $class, $dsn);
-
-        $this->assertInstanceOf($class, $parameters);
+        $parameters = PredisParametersFactory::create($options, Parameters::class, $dsn);
 
         foreach ($expectedParameters as $name => $value) {
             $this->assertSame($value, $parameters->{$name}, sprintf("Wrong '%s' value", $name));