[redis] Add ability to pass instance of Redis instance.

Author: makasim

RedisConnectionFactory.php

@@ -25,6 +25,7 @@ class RedisConnectionFactory implements PsrConnectionFactory
      *  'reserved' => should be null if $retry_interval is specified
      *  'retry_interval' => retry interval in milliseconds.
      *  'vendor' => 'The library used internally to interact with Redis server
+     *  'redis' => 'Used only if vendor is custom, should contain an instance of \Enqueue\Redis\Redis interface.
      *  'persisted' => bool, Whether it use single persisted connection or open a new one for every context
      *  'lazy' => the connection will be performed as later as possible, if the option set to true
      *  'database' => Database index to select when connected (default value: 0)
@@ -50,7 +51,7 @@ public function __construct($config = 'redis:')
 
         $this->config = array_replace($this->defaultConfig(), $config);
 
-        $supportedVendors = ['predis', 'phpredis'];
+        $supportedVendors = ['predis', 'phpredis', 'custom'];
         if (false == in_array($this->config['vendor'], $supportedVendors, true)) {
             throw new \LogicException(sprintf(
                 'Unsupported redis vendor given. It must be either "%s". Got "%s"',
@@ -90,6 +91,18 @@ private function createRedis()
                 $this->redis = new PRedis(new Client($this->config, ['exceptions' => true]));
             }
 
+            if ('custom' == $this->config['vendor'] && false == $this->redis) {
+                if (empty($this->config['redis'])) {
+                    throw new \LogicException('The redis option should be set if vendor is custom.');
+                }
+
+                if (false == $this->config['redis'] instanceof Redis) {
+                    throw new \LogicException(sprintf('The redis option should be instance of "%s".', Redis::class));
+                }
+
+                $this->redis = $this->config['redis'];
+            }
+
             $this->redis->connect();
         }
 
@@ -138,6 +151,7 @@ private function defaultConfig()
             'reserved' => null,
             'retry_interval' => null,
             'vendor' => 'phpredis',
+            'redis' => null,
             'persisted' => false,
             'lazy' => true,
             'database' => 0,

Tests/RedisConnectionFactoryConfigTest.php

@@ -40,7 +40,7 @@ public function testThrowIfDsnCouldNotBeParsed()
     public function testThrowIfVendorIsInvalid()
     {
         $this->expectException(\LogicException::class);
-        $this->expectExceptionMessage('Unsupported redis vendor given. It must be either "predis", "phpredis". Got "invalidVendor"');
+        $this->expectExceptionMessage('Unsupported redis vendor given. It must be either "predis", "phpredis", "custom". Got "invalidVendor"');
 
         new RedisConnectionFactory(['vendor' => 'invalidVendor']);
     }
@@ -72,6 +72,7 @@ public static function provideConfigs()
                 'persisted' => false,
                 'lazy' => true,
                 'database' => 0,
+                'redis' => null,
             ],
         ];
 
@@ -87,6 +88,7 @@ public static function provideConfigs()
                 'persisted' => false,
                 'lazy' => true,
                 'database' => 0,
+                'redis' => null,
             ],
         ];
 
@@ -102,6 +104,7 @@ public static function provideConfigs()
                 'persisted' => false,
                 'lazy' => true,
                 'database' => 0,
+                'redis' => null,
             ],
         ];
 
@@ -118,6 +121,7 @@ public static function provideConfigs()
                 'lazy' => false,
                 'foo' => 'bar',
                 'database' => 5,
+                'redis' => null,
             ],
         ];
 
@@ -134,6 +138,7 @@ public static function provideConfigs()
                 'lazy' => true,
                 'foo' => 'bar',
                 'database' => 0,
+                'redis' => null,
             ],
         ];
     }

Tests/RedisConnectionFactoryTest.php

@@ -2,6 +2,7 @@
 
 namespace Enqueue\Redis\Tests;
 
+use Enqueue\Redis\Redis;
 use Enqueue\Redis\RedisConnectionFactory;
 use Enqueue\Redis\RedisContext;
 use Enqueue\Test\ClassExtensionTrait;
@@ -28,4 +29,45 @@ public function testShouldCreateLazyContext()
         $this->assertAttributeEquals(null, 'redis', $context);
         $this->assertInternalType('callable', $this->readAttribute($context, 'redisFactory'));
     }
+
+    public function testShouldThrowIfVendorIsCustomButRedisInstanceNotSet()
+    {
+        $factory = new RedisConnectionFactory([
+            'vendor' => 'custom',
+            'redis' => null,
+            'lazy' => false,
+        ]);
+
+        $this->expectException(\LogicException::class);
+        $this->expectExceptionMessage('The redis option should be set if vendor is custom.');
+        $factory->createContext();
+    }
+
+    public function testShouldThrowIfVendorIsCustomButRedisIsNotInstanceOfRedis()
+    {
+        $factory = new RedisConnectionFactory([
+            'vendor' => 'custom',
+            'redis' => new \stdClass(),
+            'lazy' => false,
+        ]);
+
+        $this->expectException(\LogicException::class);
+        $this->expectExceptionMessage('The redis option should be instance of "Enqueue\Redis\Redis".');
+        $factory->createContext();
+    }
+
+    public function testShouldUseCustomRedisInstance()
+    {
+        $redisMock = $this->createMock(Redis::class);
+
+        $factory = new RedisConnectionFactory([
+            'vendor' => 'custom',
+            'redis' => $redisMock,
+            'lazy' => false,
+        ]);
+
+        $context = $factory->createContext();
+
+        $this->assertAttributeSame($redisMock, 'redis', $context);
+    }
 }