Throw exception when RediSearch module isn't loaded

Author: ethanhann

src/Exceptions/UnknownRediSearchCommandException.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace Ehann\RediSearch\Exceptions;
+
+use Exception;
+
+class UnknownRediSearchCommandException extends Exception
+{
+    public function __construct($message = '', $code = 0, Exception $previous = null)
+    {
+        parent::__construct(
+            trim("Unknown RediSearch command. Are you sure the RediSearch module is enabled in Redis? $message"),
+            $code,
+            $previous
+        );
+    }
+}

src/Redis/RedisClient.php

@@ -4,6 +4,7 @@
 
 use Ehann\RediSearch\Exceptions\InvalidRedisClientClassException;
 use Ehann\RediSearch\Exceptions\UnknownIndexNameException;
+use Ehann\RediSearch\Exceptions\UnknownRediSearchCommandException;
 use Ehann\RediSearch\Exceptions\UnsupportedLanguageException;
 use Psr\Log\LoggerInterface;
 
@@ -72,16 +73,24 @@ public function rawCommand(string $command, array $arguments)
         $rawResult = $this->isPredisClient() ?
             $this->redis->executeRaw($arguments) :
             call_user_func_array([$this->redis, 'rawCommand'], $arguments);
+        $this->throwExceptionIfRawResultIndicatesAnError($rawResult);
+        return $rawResult;
+    }
 
+    public function throwExceptionIfRawResultIndicatesAnError($rawResult)
+    {
+        if (!is_string($rawResult)) {
+            return;
+        }
         if ($rawResult === 'Unknown Index name') {
             throw new UnknownIndexNameException();
         }
-        $unsupportedLanguageMessages = ['Unsupported Language', 'Unsupported Stemmer Language'];
-        if (in_array($rawResult, $unsupportedLanguageMessages)) {
+        if (in_array($rawResult, ['Unsupported Language', 'Unsupported Stemmer Language'])) {
             throw new UnsupportedLanguageException();
         }
-
-        return $rawResult;
+        if (strpos($rawResult, 'ERR unknown command \'FT.') !== false) {
+            throw new UnknownRediSearchCommandException($rawResult);
+        }
     }
 
     public function setLogger(LoggerInterface $logger): RedisClient