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

Author: makasim

bin/dev

@@ -6,13 +6,13 @@ set -e
 while getopts "bustefcdp" OPTION; do
   case $OPTION in
     b)
-      COMPOSE_PROJECT_NAME=mqdev docker-compose pull && COMPOSE_PROJECT_NAME=mqdev docker-compose build
+      docker-compose pull && docker-compose build
       ;;
     u)
-      COMPOSE_PROJECT_NAME=mqdev docker-compose up
+      docker-compose up
       ;;
     s)
-      COMPOSE_PROJECT_NAME=mqdev docker-compose stop
+      docker-compose stop
       ;;
     e)
       docker exec -it mqdev_dev_1 /bin/bash
@@ -24,10 +24,10 @@ while getopts "bustefcdp" OPTION; do
       ./bin/run-fun-test.sh "$2"
       ;;
     c)
-      COMPOSE_PROJECT_NAME=mqdev docker-compose run -e CHANGELOG_GITHUB_TOKEN=${CHANGELOG_GITHUB_TOKEN:-""} --workdir="/mqdev" --rm generate-changelog github_changelog_generator --future-release "$2" --simple-list
+      docker-compose run -e CHANGELOG_GITHUB_TOKEN=${CHANGELOG_GITHUB_TOKEN:-""} --workdir="/mqdev" --rm generate-changelog github_changelog_generator --future-release "$2" --simple-list
       ;;
 
-    d) COMPOSE_PROJECT_NAME=mqdev docker-compose run --workdir="/mqdev" --rm dev php pkg/enqueue-bundle/Tests/Functional/app/console.php config:dump-reference enqueue -vvv
+    d) docker-compose run --workdir="/mqdev" --rm dev php pkg/enqueue-bundle/Tests/Functional/app/console.php config:dump-reference enqueue -vvv
       ;;
     \?)
       echo "Invalid option: -$OPTARG" >&2

docs/transport/redis.md

@@ -78,6 +78,23 @@ $connectionFactory = new RedisConnectionFactory([
 $psrContext = $connectionFactory->createContext();
 ```
 
+* With custom redis instance:
+
+It gives you more control over vendor specific features.
+
+```php
+<?php
+use Enqueue\Redis\RedisConnectionFactory;
+use Enqueue\Redis\PRedis;
+ 
+$config = []; 
+$options = [];
+
+$redis = new PRedis(new \PRedis\Client($config, $options));
+
+$factory = new RedisConnectionFactory(['vendor' => 'custom', 'redis' => $redis]);
+```
+
 ## Send message to topic
 
 ```php

pkg/redis/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,

pkg/redis/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,
             ],
         ];
     }

pkg/redis/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);
+    }
 }