feat: add support for predis scan

Author: shakaran

src/Factory/PhpredisClientFactory.php

@@ -301,6 +301,7 @@ private function createClient(RedisDsn $dsn, string $class, string $alias, array
             $client->setOption($class::OPT_PREFIX, $options['prefix']);
         }
 
+        // Support for scan option since https://github.com/phpredis/phpredis/issues/548
         if (isset($options['scan']) && $options['scan'] === 'prefix') {
             $client->setOption($class::OPT_SCAN, $class::SCAN_PREFIX);
         }

src/Factory/PredisParametersFactory.php

@@ -6,6 +6,7 @@
 
 use InvalidArgumentException;
 use Predis\Connection\ParametersInterface;
+use Redis;
 use Snc\RedisBundle\DependencyInjection\Configuration\RedisDsn;
 
 use function array_filter;
@@ -24,8 +25,13 @@ public static function create(array $options, string $class, string $dsn): Param
         }
 
         $defaultOptions = ['timeout' => null]; // Allow to be consistent with old version of Predis where default timeout was 5
-        $dsnOptions     = static::parseDsn(new RedisDsn($dsn));
-        $dsnOptions     = array_merge($defaultOptions, $options, $dsnOptions);
+
+        if (isset($options['scan']) && $options['scan'] === 'prefix') {
+            $dsnOptions[Redis::OPT_SCAN] = Redis::SCAN_PREFIX;
+        }
+
+        $dsnOptions = static::parseDsn(new RedisDsn($dsn));
+        $dsnOptions = array_merge($defaultOptions, $options, $dsnOptions);
 
         if (!empty($dsnOptions['persistent']) && !empty($dsnOptions['database'])) {
             $dsnOptions['persistent'] = (int) $dsnOptions['database'];

tests/Factory/PredisParametersFactoryTest.php

@@ -159,4 +159,16 @@ public function testCreateException(): void
 
         PredisParametersFactory::create([], stdClass::class, 'redis://localhost');
     }
+
+    public function testScanOption(): void
+    {
+        $dsn     = 'redis://localhost:6379';
+        $options = ['scan' => 'prefix'];
+
+        $parameters = PredisParametersFactory::create($options, Parameters::class, $dsn);
+
+        $this->assertInstanceOf(Parameters::class, $parameters);
+        $this->assertArrayHasKey('scan', $parameters->toArray());
+        $this->assertSame('prefix', $parameters->toArray()['scan']);
+    }
 }