[Cache] Enforce usage of Predis with Sentinel

buffcode · buffcode · commit 86a7e1cac1ce · 2022-05-19T00:06:36.000+02:00
Enforce usage of \Predis\Client when the Sentinel option is enabled
diff --git a/src/Symfony/Component/Cache/Tests/Adapter/RedisAdapterSentinelTest.php b/src/Symfony/Component/Cache/Tests/Adapter/RedisAdapterSentinelTest.php
@@ -14,6 +14,7 @@
 use PHPUnit\Framework\SkippedTestSuiteError;
 use Symfony\Component\Cache\Adapter\AbstractAdapter;
 use Symfony\Component\Cache\Adapter\RedisAdapter;
+use Symfony\Component\Cache\Exception\CacheException;
 use Symfony\Component\Cache\Exception\InvalidArgumentException;
 
 /**
@@ -43,4 +44,12 @@ public function testInvalidDSNHasBothClusterAndSentinel()
         $dsn = 'redis:?host[redis1]&host[redis2]&host[redis3]&redis_cluster=1&redis_sentinel=mymaster';
         RedisAdapter::createConnection($dsn);
     }
+
+    public function testSentinelRequiresPredis()
+    {
+        $this->expectException(CacheException::class);
+        $this->expectExceptionMessage('Redis Sentinel requires the use of \Predis\Client as class:');
+        $dsn = 'redis:?host[redis1]&host[redis2]&host[redis3]&redis_cluster=1&redis_sentinel=mymaster';
+        RedisAdapter::createConnection($dsn, ['class' => \Redis::class]);
+    }
 }
diff --git a/src/Symfony/Component/Cache/Traits/RedisTrait.php b/src/Symfony/Component/Cache/Traits/RedisTrait.php
@@ -178,6 +178,10 @@ public static function createConnection($dsn, array $options = [])
             $class = $params['redis_cluster'] ? \RedisCluster::class : (1 < \count($hosts) ? \RedisArray::class : \Redis::class);
         } else {
             $class = $params['class'] ?? \Predis\Client::class;
+
+            if (isset($params['redis_sentinel']) && !is_a($class, \Predis\Client::class, true)) {
+                throw new CacheException(sprintf('Redis Sentinel requires the use of \Predis\Client as class: "%s".', $dsn));
+            }
         }
 
         if (is_a($class, \Redis::class, true)) {
