Better compatibility with yii2-redis

Author: Pavle Lee

.gitignore

@@ -0,0 +1 @@
+.idea

src/ActiveQuery.php

@@ -0,0 +1,33 @@
+<?php
+/**
+ * User: Pavle Lee <523260513@qq.com>
+ * Date: 2017/8/26
+ * Time: 16:29
+ */
+
+namespace pavle\yii\redis\Command;
+
+
+class ClientList extends \Predis\Command\ServerClient
+{
+    /**
+     * @inheritDoc
+     */
+    public function getArguments()
+    {
+        return ['LIST'];
+    }
+
+
+    /**
+     * Parses the response to CLIENT LIST and returns a structured list.
+     *
+     * @param string $data Response buffer.
+     *
+     * @return string
+     */
+    protected function parseClientList($data)
+    {
+        return $data;
+    }
+}

src/ActiveRecord.php

@@ -0,0 +1,33 @@
+<?php
+/**
+ * User: Pavle Lee <523260513@qq.com>
+ * Date: 2017/8/26
+ * Time: 16:29
+ */
+
+namespace pavle\yii\redis\Command;
+
+
+class ClientSetName extends \Predis\Command\ServerClient
+{
+    /**
+     * @inheritDoc
+     */
+    public function getArguments()
+    {
+        return array_merge(['SETNAME'], parent::getArguments());
+    }
+
+
+    /**
+     * Parses the response to CLIENT LIST and returns a structured list.
+     *
+     * @param string $data Response buffer.
+     *
+     * @return string
+     */
+    protected function parseClientList($data)
+    {
+        return $data;
+    }
+}

src/Command/ClientList.php

@@ -0,0 +1,30 @@
+<?php
+/**
+ * User: Pavle Lee <523260513@qq.com>
+ * Date: 2017/8/26
+ * Time: 16:11
+ */
+
+namespace pavle\yii\redis\Command;
+
+
+use Predis\Command\Command;
+
+class HashGetAll extends Command
+{
+    /**
+     * {@inheritdoc}
+     */
+    public function getId()
+    {
+        return 'HGETALL';
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function parseResponse($data)
+    {
+        return $data;
+    }
+}

src/Command/ClientSetName.php

@@ -7,7 +7,15 @@
 
 namespace pavle\yii\redis;
 
+use pavle\yii\redis\Profile\RedisVersion200;
+use pavle\yii\redis\Profile\RedisVersion220;
+use pavle\yii\redis\Profile\RedisVersion240;
+use pavle\yii\redis\Profile\RedisVersion260;
+use pavle\yii\redis\Profile\RedisVersion280;
+use pavle\yii\redis\Profile\RedisVersion300;
+use pavle\yii\redis\Profile\RedisVersion320;
 use Predis\Client;
+use Predis\Profile\Factory;
 use yii\db\Exception;
 use yii\helpers\VarDumper;
 
@@ -28,6 +36,24 @@ class Connection extends \yii\redis\Connection
      */
     private $_socket = false;
 
+    /**
+     * @inheritDoc
+     */
+    public function init()
+    {
+        parent::init();
+
+        Factory::define('2.0', RedisVersion200::class);
+        Factory::define('2.2', RedisVersion220::class);
+        Factory::define('2.4', RedisVersion240::class);
+        Factory::define('2.6', RedisVersion260::class);
+        Factory::define('2.8', RedisVersion280::class);
+        Factory::define('3.0', RedisVersion300::class);
+        Factory::define('3.2', RedisVersion320::class);
+        Factory::define('dev', 'Predis\Profile\RedisUnstable');
+        Factory::define('default', RedisVersion320::class);
+    }
+
     /**
      * Returns a value indicating whether the DB connection is established.
      * @return bool whether the DB connection is established
@@ -113,7 +139,7 @@ public function executeCommand($name, $params = [])
     {
         $this->open();
 
-        \Yii::trace("Executing Redis Command: {$name}", __METHOD__);
+        \Yii::trace("Executing Redis Command: {$name} " . join(' ', $params), __METHOD__);
 
         return $this->_socket->executeCommand(
             $this->_socket->createCommand($name, $params)

src/Command/HashGetAll.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace pavle\yii\redis\Profile;
+
+
+class RedisVersion200 extends \Predis\Profile\RedisVersion200
+{
+    public function getSupportedCommands()
+    {
+        return array_merge(parent::getSupportedCommands(), [
+            'HGETALL' => 'pavle\yii\redis\Command\HashGetAll',
+            'CLIENT LIST' => 'pavle\yii\redis\Command\ClientList',
+            'CLIENT SETNAME' => 'pavle\yii\redis\Command\ClientSetName',
+        ]);
+    }
+}

src/Connection.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace pavle\yii\redis\Profile;
+
+
+class RedisVersion220 extends \Predis\Profile\RedisVersion220
+{
+    public function getSupportedCommands()
+    {
+        return array_merge(parent::getSupportedCommands(), [
+            'HGETALL' => 'pavle\yii\redis\Command\HashGetAll',
+            'CLIENT LIST' => 'pavle\yii\redis\Command\ClientList',
+            'CLIENT SETNAME' => 'pavle\yii\redis\Command\ClientSetName',
+        ]);
+    }
+}

src/Profile/RedisVersion200.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace pavle\yii\redis\Profile;
+
+
+class RedisVersion240 extends \Predis\Profile\RedisVersion240
+{
+    public function getSupportedCommands()
+    {
+        return array_merge(parent::getSupportedCommands(), [
+            'HGETALL' => 'pavle\yii\redis\Command\HashGetAll',
+            'CLIENT LIST' => 'pavle\yii\redis\Command\ClientList',
+            'CLIENT SETNAME' => 'pavle\yii\redis\Command\ClientSetName',
+        ]);
+    }
+}