[5.4] Make PhpRedis connection more compatible with Predis (pipeline, ...)

.travis.yml

@@ -30,7 +30,7 @@ services:
 before_install:
   - if [[ $TRAVIS_PHP_VERSION != 7.1 ]] ; then phpenv config-rm xdebug.ini; fi
   - echo "extension = memcached.so" >> ~/.phpenv/versions/$(phpenv version-name)/etc/php.ini
-  - echo "extension = redis.so" >> ~/.phpenv/versions/$(phpenv version-name)/etc/php.ini
+  - pecl install -f redis
   - travis_retry composer self-update
 
 install:

src/Illuminate/Redis/Connections/PhpRedisConnection.php

@@ -110,6 +110,47 @@ public function zadd($key, ...$dictionary)
         return $this->client->zadd($key, ...$dictionary);
     }
 
+    /**
+     * Execute commands in a pipeline.
+     *
+     * @param  callable  $callback
+     * @return array|\Redis
+     */
+    public function pipeline(callable $callback = null)
+    {
+        $pipeline = $this->client()->pipeline();
+
+        return is_null($callback)
+            ? $pipeline
+            : tap($pipeline, $callback)->exec();
+    }
+
+    /**
+     * Execute commands in a transaction.
+     *
+     * @param  callable  $callback
+     * @return array|\Redis
+     */
+    public function transaction(callable $callback = null)
+    {
+        $transaction = $this->client()->multi();
+
+        return is_null($callback)
+            ? $transaction
+            : tap($transaction, $callback)->exec();
+    }
+
+    /**
+     * Execute a raw command.
+     *
+     * @param  array  $parameters
+     * @return mixed
+     */
+    public function executeRaw(array $parameters)
+    {
+        return $this->command('rawCommand', $parameters);
+    }
+
     /**
      * Evaluate a LUA script serverside, from the SHA1 hash of the script instead of the script itself.
      *

tests/Redis/Connections/PhpRedisConnectionTest.php

@@ -0,0 +1,64 @@
+<?php
+
+namespace Illuminate\Tests\Redis\Connections;
+
+use PHPUnit\Framework\TestCase;
+use Illuminate\Tests\Redis\InteractsWithRedis;
+
+class PhpRedisConnectionTest extends TestCase
+{
+    use InteractsWithRedis;
+
+    public function setUp()
+    {
+        parent::setUp();
+        $this->setUpRedis();
+
+        if (! isset($this->redis['phpredis'])) {
+            $this->markTestSkipped('PhpRedis should be enabled to run the tests');
+        }
+    }
+
+    public function tearDown()
+    {
+        parent::tearDown();
+        $this->tearDownRedis();
+    }
+
+    public function testPhpRedisPipeline()
+    {
+        $result = $this->redis['phpredis']->connection()->pipeline(function ($pipe) {
+            $pipe->set('test:pipeline:1', 1);
+            $pipe->get('test:pipeline:1');
+            $pipe->set('test:pipeline:2', 2);
+            $pipe->get('test:pipeline:2');
+        });
+
+        $this->assertCount(4, $result);
+        $this->assertEquals(1, $result[1]);
+        $this->assertEquals(2, $result[3]);
+    }
+
+    public function testPhpRedisTransaction()
+    {
+        $result = $this->redis['phpredis']->connection()->transaction(function ($pipe) {
+            $pipe->set('test:transaction:1', 1);
+            $pipe->get('test:transaction:1');
+            $pipe->set('test:transaction:2', 2);
+            $pipe->get('test:transaction:2');
+        });
+
+        $this->assertCount(4, $result);
+        $this->assertEquals(1, $result[1]);
+        $this->assertEquals(2, $result[3]);
+    }
+
+    public function testPhpRedisExecuteRaw()
+    {
+        $this->redis['phpredis']->connection()->set('test:raw:1', 1);
+
+        $this->assertEquals(
+            1, $this->redis['phpredis']->connection()->executeRaw(['GET', 'test:raw:1'])
+        );
+    }
+}