Add client for ReactPHP Redis

Author: MacFJA

CHANGELOG.md

@@ -8,6 +8,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Added
 
+- Add client for ReactPHP Redis
 - Path validation for JSON fields
 - Helper function get current RedisJSON version + (abstraction)
 - (dev) More unit tests

README.md

@@ -24,6 +24,7 @@ This lib can use several connector for Redis:
  - [Rediska](https://github.com/Shumkov/Rediska) - Pure PHP implementation
  - [Redisent](https://github.com/jdp/redisent) - Pure PHP implementation
  - [TinyRedis](https://github.com/ptrofimov/tinyredisclient) - Pure PHP implementation
+ - [RecatPHP Redis](https://github.com/clue/reactphp-redis) - Pure PHP Async implementation
 
 You can pick the connector depending on your need.
 
@@ -56,6 +57,9 @@ $client = $clientFacade->getClient(new \TinyRedisClient(/* ... */));
 
 // With Credis
 $client = $clientFacade->getClient(new \Credis_Client(/* ... */));
+
+// With ReactPHP Redis
+$client = $clientFacade->getClient(new (new \Clue\React\Redis\Factory())->createClient(/* ... */));
 ```
 
 You can add your own implementation, all you need is to implement the interface `\MacFJA\RediSearch\Redis\Client` and add it to the client facace with:

composer.json

@@ -30,6 +30,7 @@
         "ext-mbstring": "*",
         "amphp/redis": "^1.0",
         "cheprasov/php-redis-client": "^1.10",
+        "clue/redis-react": "^2.6",
         "colinmollenhour/credis": "^1.12",
         "enlightn/security-checker": "^1.9",
         "ergebnis/composer-normalize": "^2.13",
@@ -42,6 +43,7 @@
         "phpunit/phpunit": "^8.5 || ^9.3",
         "predis/predis": "^1.1 || ^2.0",
         "ptrofimov/tinyredisclient": "^1.1",
+        "react/async": "^3.0",
         "redisent/redisent": "dev-master",
         "roave/security-advisories": "dev-latest",
         "rskuipers/php-assumptions": "^0.8.0",

src/Redis/Client/AbstractClient.php

@@ -41,6 +41,18 @@ public function pipeline(Command ...$commands): array
         }, $results, array_keys($results));
     }
 
+    public function execute(Command $command)
+    {
+        $args = [$command->getId()];
+        $commandArgs = $command->getArguments();
+        if (count($commandArgs) > 0) {
+            array_push($args, ...$commandArgs);
+        }
+        $result = $this->executeRaw(...$args);
+
+        return $command->parseResponse($result);
+    }
+
     /**
      * @return array<mixed>
      */

src/Redis/Client/AmpRedisClient.php

@@ -53,15 +53,6 @@ public static function make($redis): Client
         return new self($redis);
     }
 
-    public function execute(Command $command)
-    {
-        /** @var Promise<mixed> $query */
-        $query = $this->redis->query($command->getId(), ...array_map('strval', $command->getArguments()));
-        $result = wait($query);
-
-        return $command->parseResponse($result);
-    }
-
     public function executeRaw(...$args)
     {
         /** @var Promise<mixed> $query */
@@ -77,6 +68,9 @@ public static function supports($redis): bool
             && function_exists('\\Amp\\Promise\\wait');
     }
 
+    /**
+     * @codeCoverageIgnore
+     */
     public function pipeline(Command ...$commands): array
     {
         false === static::$disableNotice

src/Redis/Client/CheprasovRedisClient.php

@@ -52,13 +52,6 @@ public static function make($redis): Client
         return new self($redis);
     }
 
-    public function execute(Command $command)
-    {
-        $response = $this->redis->executeRaw(array_merge([$command->getId()], $command->getArguments()));
-
-        return $command->parseResponse($response);
-    }
-
     public function executeRaw(...$args)
     {
         return $this->redis->executeRaw(array_map('strval', $args));

src/Redis/Client/ClientFacade.php

@@ -22,9 +22,11 @@
 namespace MacFJA\RediSearch\Redis\Client;
 
 use Amp\Redis\Redis as AmpRedis;
+use Clue\React\Redis\Client as ReactClient;
 use Credis_Client as CredisRedis;
 use MacFJA\RediSearch\Redis\Client;
 use Predis\ClientInterface as PredisRedis;
+use React\Promise\Promise as ReactPromise;
 use Redis as PhpredisRedis;
 use RedisClient\Client\AbstractRedisClient as CheprasovRedis;
 use redisent\Redis as RedisentRedis;
@@ -44,10 +46,11 @@ class ClientFacade
         RediskaClient::class,
         AmpRedisClient::class,
         TinyRedisClient::class,
+        ReactRedisClient::class,
     ];
 
     /**
-     * @param AmpRedis|CheprasovRedis|CredisRedis|mixed|PhpredisRedis|PredisRedis|RedisentRedis|RediskaRedis|resource $redis
+     * @param AmpRedis|CheprasovRedis|CredisRedis|mixed|PhpredisRedis|PredisRedis|ReactClient|ReactPromise|RedisentRedis|RediskaRedis|resource $redis
      */
     public function getClient($redis): Client
     {

src/Redis/Client/CredisClient.php

@@ -51,13 +51,6 @@ public static function make($redis): Client
         return new self($redis);
     }
 
-    public function execute(Command $command)
-    {
-        $result = $this->redis->__call($command->getId(), $command->getArguments());
-
-        return $command->parseResponse($this->fixFalseToNull($result));
-    }
-
     public function executeRaw(...$args)
     {
         $command = array_shift($args);

src/Redis/Client/PhpiredisClient.php

@@ -51,13 +51,6 @@ private function __construct($redis)
         $this->redis = $redis;
     }
 
-    public function execute(Command $command)
-    {
-        $rawResponse = phpiredis_command_bs($this->redis, array_merge([$command->getId()], $command->getArguments()));
-
-        return $command->parseResponse($rawResponse);
-    }
-
     public static function supports($redis): bool
     {
         if (!is_resource($redis)

src/Redis/Client/PredisClient.php

@@ -55,13 +55,6 @@ private function __construct(ClientInterface $redis)
         $this->redis = $redis;
     }
 
-    public function execute(Command $command)
-    {
-        $rawResponse = $this->redis->executeCommand(self::createRawCommand(array_merge([$command->getId()], $command->getArguments())));
-
-        return $command->parseResponse($rawResponse);
-    }
-
     public static function supports($redis): bool
     {
         if (