Update predis & remove temp predis cluster fixes

Author: RobiNN1

predis.phar

@@ -16,7 +16,6 @@
 use RobiNN\Pca\Dashboards\Redis\Compatibility\RedisCompatibilityInterface;
 use RobiNN\Pca\Dashboards\Redis\Compatibility\RedisJson;
 use RobiNN\Pca\Dashboards\Redis\Compatibility\RedisModules;
-use Throwable;
 
 /**
  * @method bool restore(string $key, int $ttl, string $value)
@@ -202,119 +201,11 @@ public function listRem(string $key, string $value, int $count): int {
         return $this->lrem($key, $count, $value);
     }
 
-    private function getKeyNode(string $key): ?PredisClient {
-        $cluster = $this->getConnection();
-
-        if (!method_exists($cluster, 'getClusterStrategy') || !method_exists($cluster, 'getConnectionBySlot')) {
-            return null;
-        }
-
-        $slot = $cluster->getClusterStrategy()->getSlotByKey($key);
-
-        if ($slot === null) {
-            return null;
-        }
-
-        try {
-            $connection = $cluster->getConnectionBySlot((string) $slot);
-        } catch (Throwable) {
-            return null;
-        }
-
-        foreach ($this->nodes as $node) {
-            $nodeConn = $node->getConnection();
-            if (
-                method_exists($nodeConn, 'getParameters') &&
-                $nodeConn->getParameters()->host === $connection->getParameters()->host &&
-                $nodeConn->getParameters()->port === $connection->getParameters()->port
-            ) {
-                return $node;
-            }
-        }
-
-        return null;
-    }
-
     /**
      * @param array<string, string> $messages
      */
     public function streamAdd(string $key, string $id, array $messages): string {
-        $args = [$key, $id];
-        foreach ($messages as $field => $value) {
-            $args[] = $field;
-            $args[] = $value;
-        }
-
-        $node = $this->getKeyNode($key);
-        if (!$node instanceof PredisClient) {
-            return '';
-        }
-
-        $raw = $node->executeRaw(array_merge(['XADD'], $args));
-
-        return $raw !== false && $raw !== null ? (string) $raw : '';
-    }
-
-    /**
-     * @return array<string, array<string, string>>
-     */
-    public function xrange(string $key, string $start, string $end, ?int $count = null): array {
-        $args = [$key, $start, $end];
-        if ($count !== null) {
-            $args[] = 'COUNT';
-            $args[] = (string) $count;
-        }
-
-        $node = $this->getKeyNode($key);
-        if (!$node instanceof PredisClient) {
-            return [];
-        }
-
-        $raw = $node->executeRaw(array_merge(['XRANGE'], $args));
-
-        if (!is_array($raw)) {
-            return [];
-        }
-
-        return $this->parseStreamEntries($raw);
-    }
-
-    /**
-     * @param list<array{string, list<string>}> $entries
-     *
-     * @return array<string, array<string, string>>
-     */
-    private function parseStreamEntries(array $entries): array {
-        $result = [];
-        foreach ($entries as [$id, $fields]) {
-            $assoc = [];
-            for ($i = 0, $j = count($fields); $i < $j; $i += 2) {
-                $assoc[$fields[$i]] = $fields[$i + 1];
-            }
-
-            $result[$id] = $assoc;
-        }
-
-        return $result;
-    }
-
-    /**
-     * @param string|array<int, string> ...$id
-     */
-    public function xdel(string $key, string|array ...$id): int {
-        if (count($id) === 1 && is_array($id[0])) {
-            $id = $id[0];
-        }
-
-        $node = $this->getKeyNode($key);
-        if (!$node instanceof PredisClient) {
-            return 0;
-        }
-
-        $args = array_merge([$key], $id);
-        $raw = $node->executeRaw(array_merge(['XDEL'], $args));
-
-        return is_int($raw) ? $raw : 0;
+        return $this->xadd($key, $messages, $id);
     }
 
     public function rawcommand(string $command, mixed ...$arguments): mixed {