[5.8] Add support for custom redis driver

src/Illuminate/Contracts/Redis/Connector.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace Illuminate\Contracts\Redis;
+
+interface Connector
+{
+    /**
+     * Create a new clustered redis connection.
+     *
+     * @param  array  $config
+     * @param  array  $options
+     * @return \Illuminate\Redis\Connections\Connection
+     */
+    public function connect(array $config, array $options);
+
+    /**
+     * Create a new clustered redis connection.
+     *
+     * @param  array  $config
+     * @param  array  $clusterOptions
+     * @param  array  $options
+     * @return \Illuminate\Redis\Connections\Connection
+     */
+    public function connectToCluster(array $config, array $clusterOptions, array $options);
+}

src/Illuminate/Redis/Connectors/PhpRedisConnector.php

@@ -5,10 +5,11 @@
 use Redis;
 use RedisCluster;
 use Illuminate\Support\Arr;
+use Illuminate\Contracts\Redis\Connector;
 use Illuminate\Redis\Connections\PhpRedisConnection;
 use Illuminate\Redis\Connections\PhpRedisClusterConnection;
 
-class PhpRedisConnector
+class PhpRedisConnector implements Connector
 {
     /**
      * Create a new clustered PhpRedis connection.

src/Illuminate/Redis/Connectors/PredisConnector.php

@@ -4,10 +4,11 @@
 
 use Predis\Client;
 use Illuminate\Support\Arr;
+use Illuminate\Contracts\Redis\Connector;
 use Illuminate\Redis\Connections\PredisConnection;
 use Illuminate\Redis\Connections\PredisClusterConnection;
 
-class PredisConnector
+class PredisConnector implements Connector
 {
     /**
      * Create a new clustered Predis connection.

src/Illuminate/Redis/RedisManager.php

@@ -26,6 +26,13 @@ class RedisManager implements Factory
      */
     protected $driver;
 
+    /**
+     * The registered custom driver creators.
+     *
+     * @var array
+     */
+    protected $customCreators = [];
+
     /**
      * The Redis server configurations.
      *
@@ -147,10 +154,16 @@ protected function configure(Connection $connection, $name)
     /**
      * Get the connector instance for the current driver.
      *
-     * @return \Illuminate\Redis\Connectors\PhpRedisConnector|\Illuminate\Redis\Connectors\PredisConnector
+     * @return \Illuminate\Contracts\Redis\Connector
      */
     protected function connector()
     {
+        $customCreator = $this->customCreators[$this->driver] ?? null;
+
+        if ($customCreator) {
+            return call_user_func($customCreator);
+        }
+
         switch ($this->driver) {
             case 'predis':
                 return new Connectors\PredisConnector;
@@ -215,6 +228,20 @@ public function setDriver($driver)
         $this->driver = $driver;
     }
 
+    /**
+     * Register a custom driver creator Closure.
+     *
+     * @param  string  $driver
+     * @param  \Closure  $callback
+     * @return $this
+     */
+    public function extend($driver, \Closure $callback)
+    {
+        $this->customCreators[$driver] = $callback->bindTo($this, $this);
+
+        return $this;
+    }
+
     /**
      * Pass methods onto the default Redis connection.
      *

tests/Redis/RedisManagerExtensionTest.php

@@ -0,0 +1,88 @@
+<?php
+
+namespace Illuminate\Tests\Redis;
+
+use PHPUnit\Framework\TestCase;
+use Illuminate\Redis\RedisManager;
+use Illuminate\Foundation\Application;
+use Illuminate\Contracts\Redis\Connector;
+
+class RedisManagerExtensionTest extends TestCase
+{
+    /**
+     * Redis manager instance.
+     *
+     * @var RedisManager
+     */
+    protected $redis;
+
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        $this->redis = new RedisManager(new Application(), 'my_custom_driver', [
+            'default' => [
+                'host' => 'some-host',
+                'port' => 'some-port',
+                'database' => 5,
+                'timeout' => 0.5,
+            ],
+            'clusters' => [
+                'my-cluster' => [
+                    [
+                        'host' => 'some-host',
+                        'port' => 'some-port',
+                        'database' => 5,
+                        'timeout' => 0.5,
+                    ],
+                ],
+            ],
+        ]);
+
+        $this->redis->extend('my_custom_driver', function () {
+            return new FakeRedisConnnector();
+        });
+    }
+
+    public function test_using_custom_redis_connector_with_single_redis_instance()
+    {
+        $this->assertEquals(
+            'my-redis-connection', $this->redis->resolve()
+        );
+    }
+
+    public function test_using_custom_redis_connector_with_redis_cluster_instance()
+    {
+        $this->assertEquals(
+            'my-redis-cluster-connection', $this->redis->resolve('my-cluster')
+        );
+    }
+}
+
+class FakeRedisConnnector implements Connector
+{
+    /**
+     * Create a new clustered Predis connection.
+     *
+     * @param array $config
+     * @param array $options
+     * @return \Illuminate\Contracts\Redis\Connection
+     */
+    public function connect(array $config, array $options)
+    {
+        return 'my-redis-connection';
+    }
+
+    /**
+     * Create a new clustered Predis connection.
+     *
+     * @param array $config
+     * @param array $clusterOptions
+     * @param array $options
+     * @return \Illuminate\Contracts\Redis\Connection
+     */
+    public function connectToCluster(array $config, array $clusterOptions, array $options)
+    {
+        return 'my-redis-cluster-connection';
+    }
+}