Prepare v3.3.0 release (#1612 )

Added testing with 8.4-GA (#1611 )
Added new experimental CAS/CAD functionallity (#1609 )
2026-08-20 09:32:11 +00:00 · 2025-11-24 09:48:50 -08:00 · 2025-11-19 08:30:39 -08:00 · 2025-11-12 10:14:06 +02:00 · 2025-11-12 09:14:57 +02:00 · 2025-11-11 15:31:10 +02:00
345 changed files with 11865 additions and 249 deletions
@@ -1,14 +1,2 @@
-# Default
-*                                     @tillkruss
-
-# Redis commands
-src/Command/Redis/*                   @predis/team @tillkruss
-
-# Redis Stack
-src/Command/Redis/Json/*              @predis/team
-src/Command/Redis/Search/*            @predis/team
-src/Command/Redis/TopK/*              @predis/team
-src/Command/Redis/TDigest/*           @predis/team
-src/Command/Redis/BloomFilter/*       @predis/team
-src/Command/Redis/CuckooFilter/*      @predis/team
-src/Command/Redis/CountMinSketch/*    @predis/team
+*                         @predis/maintainers
+src/Relay*                @tillkruss
@@ -3,7 +3,7 @@
 services:

  redis-official:
-    image: ${REDIS_IMAGE_NAME:-redis:7.4}
+    image: ${REDIS_IMAGE_NAME:-redis:8.0}
    container_name: redis-official
    healthcheck:
      test: [ "CMD", "redis-cli", "PING" ]
@@ -20,7 +20,7 @@ services:
      - standalone

  redis-clients:
-    image: ${REDIS_IMAGE_NAME:-redislabs/client-libs-test:7.4.2}
+    image: ${REDIS_IMAGE_NAME:-redislabs/client-libs-test:8.0.2}
    container_name: redis-standalone
    environment:
      - TLS_ENABLED=yes
@@ -40,7 +40,7 @@ services:
      - standalone

  redis-unprotected:
-    image: ${REDIS_IMAGE_NAME:-redislabs/client-libs-test:7.4.2}
+    image: ${REDIS_IMAGE_NAME:-redislabs/client-libs-test:8.0.2}
    container_name: redis-unprotected
    environment:
      - TLS_ENABLED=no
@@ -58,7 +58,7 @@ services:
      - unprotected

  redis-cluster:
-    image: ${REDIS_IMAGE_NAME:-redislabs/client-libs-test:7.4.2}
+    image: ${REDIS_IMAGE_NAME:-redislabs/client-libs-test:8.0.2}
    container_name: redis-cluster
    environment:
      - REDIS_CLUSTER=yes
@@ -1,7 +1,7 @@
 name-template: 'v$NEXT_MINOR_VERSION'
 tag-template: 'v$NEXT_MINOR_VERSION'
 change-template: '- $TITLE (#$NUMBER)'
-filter-by-comitish: true
+filter-by-commitish: true
 commitish: v3.x

 autolabeler:
@@ -4,6 +4,7 @@ CAS
 Customizable
 ElastiCache
 FPM
+GC
 IANA
 Lua
 PSR
@@ -31,6 +31,8 @@ jobs:
          - '7.2'
          - '7.4'
          - '8.0'
+          - '8.2'
+          - '8.4'

    steps:

@@ -38,7 +40,9 @@ jobs:
        run: |
          # Mapping of original redis versions to client test containers
          declare -A redis_clients_version_mapping=(
-            ["8.0"]="8.0.1-pre"
+            ["8.4"]="8.4.0"
+            ["8.2"]="8.2.2-pre"
+            ["8.0"]="8.0.2"
            ["7.4"]="7.4.2"
            ["7.2"]="7.2.7"
          )
@@ -106,7 +110,7 @@ jobs:
        with:
          php-version: ${{ matrix.php }}
          extensions: relay
-          coverage: ${{ (matrix.php == '8.4' && matrix.redis == '7.4') && 'xdebug' || 'none' }}
+          coverage: ${{ (matrix.php == '8.4' && matrix.redis == '8.0') && 'xdebug' || 'none' }}

      - name: Install Composer dependencies
        uses: ramsey/composer-install@v2
@@ -115,78 +119,74 @@ jobs:
          composer-options: ${{ matrix.php == '8.0' && '--ignore-platform-reqs' || '' }}

      - name: Run tests
-        if: ${{ matrix.php != '8.4' || matrix.redis != '7.4' }}
+        if: ${{ matrix.php != '8.4' || matrix.redis != '8.0' }}
        run: vendor/bin/phpunit

      - name: Run tests with coverage
-        if: ${{ matrix.php == '8.4' && matrix.redis == '7.4' }}
+        if: ${{ matrix.php == '8.4' && matrix.redis == '8.0' }}
        run: vendor/bin/phpunit --coverage-php build/cov/coverage-predis.cov --coverage-filter ./src

      - name: Run tests using Relay
-        if: ${{ matrix.php != '8.4' && matrix.redis >= '7.2' }}
+        if: ${{ matrix.php != '8.4' && matrix.redis >= '8.0' }}
        run: vendor/bin/phpunit -c phpunit.relay.xml

      - name: Run tests using Relay with coverage
-        if: ${{ matrix.php == '8.4' && matrix.redis == '7.4' }}
+        if: ${{ matrix.php == '8.4' && matrix.redis == '8.0' }}
        run: vendor/bin/phpunit -c phpunit.relay.xml --coverage-php build/cov/coverage-relay.cov --coverage-filter ./src

      - name: Run tests against unprotected Redis
-        if: ${{ (matrix.php != '8.4' || matrix.redis != '7.4') &&  matrix.redis > '4.0'}}
+        if: ${{ (matrix.php != '8.4' || matrix.redis != '8.0') &&  matrix.redis > '4.0'}}
        run: vendor/bin/phpunit --group unprotected

      - name: Run tests against unprotected Redis with coverage
-        if: ${{ matrix.php == '8.4' && matrix.redis == '7.4' }}
+        if: ${{ matrix.php == '8.4' && matrix.redis == '8.0' }}
        run: vendor/bin/phpunit --group unprotected --coverage-php build/cov/coverage-unprotected.cov --coverage-filter ./src

      - name: Run stack tests
-        if: ${{ (matrix.php != '8.4' || matrix.redis != '7.4') && matrix.redis >= '7.2' }}
+        if: ${{ (matrix.php != '8.4' || matrix.redis != '8.0') && matrix.redis >= '7.2' }}
        run: vendor/bin/phpunit --group realm-stack

      - name: Run stack tests with coverage
-        if: ${{ matrix.php == '8.4' && matrix.redis == '7.4' && steps.stack_infra.conclusion == 'success' }}
+        if: ${{ matrix.php == '8.4' && matrix.redis == '8.0' }}
        run: vendor/bin/phpunit --group realm-stack --coverage-php build/cov/coverage-stack.cov --coverage-filter ./src
-        env:
-          REDIS_STACK_SERVER_PORT: 6479

      - name: Run stack tests using Relay
-        if: ${{ matrix.php != '8.4' && matrix.redis == '7.4' }}
+        if: ${{ (matrix.php != '8.4' || matrix.redis != '8.0') && matrix.redis >= '7.2' }}
        run: vendor/bin/phpunit --group realm-stack -c phpunit.relay.xml

      - name: Run stack tests using Relay with coverage
-        if: ${{ matrix.php == '8.4' && matrix.redis == '7.4' }}
+        if: ${{ matrix.php == '8.4' && matrix.redis == '8.0' }}
        run: vendor/bin/phpunit --group realm-stack -c phpunit.relay.xml --coverage-php build/cov/coverage-stack-relay.cov --coverage-filter ./src
-        env:
-          REDIS_STACK_SERVER_PORT: 6479

      - name: Run tests against cluster
-        if: ${{ (matrix.php != '8.4' || matrix.redis != '7.4') && steps.cluster_infra.conclusion == 'success' }}
+        if: ${{ (matrix.php != '8.4' || matrix.redis != '8.0') && steps.cluster_infra.conclusion == 'success' }}
        run: |
          vendor/bin/phpunit --group cluster

      - name: Run tests against cluster with coverage
-        if: ${{ matrix.php == '8.4' && matrix.redis == '7.4' && steps.cluster_infra.conclusion == 'success' }}
+        if: ${{ matrix.php == '8.4' && matrix.redis == '8.0' && steps.cluster_infra.conclusion == 'success' }}
        run: |
          vendor/bin/phpunit --group cluster --coverage-php build/cov/coverage-cluster.cov --coverage-filter ./src

      - name: Run tests against cluster using Relay
-        if: ${{ matrix.php != '8.4' && matrix.redis == '7.4' }}
+        if: ${{ matrix.php != '8.4' && matrix.redis == '8.0' }}
        run: |
          sleep 5
          vendor/bin/phpunit -c phpunit.relay.xml --group cluster

      - name: Run tests against cluster using Relay with coverage
-        if: ${{ matrix.php == '8.4' && matrix.redis == '7.4' }}
+        if: ${{ matrix.php == '8.4' && matrix.redis == '8.0' }}
        run: |
          sleep 5
          vendor/bin/phpunit -c phpunit.relay.xml --group cluster --coverage-php build/cov/coverage-cluster-relay.cov --coverage-filter ./src

      - name: Merge coverage reports
-        if: ${{ matrix.php == '8.4' && matrix.redis == '7.4' }}
+        if: ${{ matrix.php == '8.4' && matrix.redis == '8.0' }}
        run: php vendor/bin/phpcov merge --clover build/logs/clover.xml build/cov

      - name: Send coverage to Coveralls
        uses: coverallsapp/github-action@v2
-        if: ${{ matrix.php == '8.4' && matrix.redis == '7.4' }}
+        if: ${{ matrix.php == '8.4' && matrix.redis == '8.0' }}
        with:
          github-token: ${{ secrets.GITHUB_TOKEN }}
          parallel: true
@@ -1,7 +1,54 @@
 ## Changelog

-## v3.0.1 (2025-05-16)
+## v3.3.0 (2025-11-24)
+### Added
+- Added cluster support for `XADD`, `XDEL` and `XRANGE` (#1587)
+- Added prefixable interface for `HEXPIRE` and `HEXPIRETIME` (#1592)
+- Added new experimental CAS/CAD functionality (#1609)
+- Added temporary `XREADGROUP_CLAIM` command (#1608)
+- Added support for `MSET` command (#1610)
+- Added experimental support for `FT.HYBRID` (#1607)

+### Changed
+- Improved compatiblity with Relay (#1597)
+- Refactor pipeline data writing depends on connection type (#1586)
+
+## v3.2.0 (2025-08-05)
+### Added
+- Added support for `XDELEX` and `XACKDEL` (#1580)
+- Added missing VSIM argument (#1582)
+
+### Changed
+- Extended `XTRIM` and `XADD` commands with new parameters (#1580)
+
+### Maintenance
+- Updated Redis 8.2 test image (#1583)
+- Added test coverage for updated Vamana (#1584)
+
+## v3.1.0 (2025-07-22)
+### Added
+- Add experimental support for vector sets commands (#1550)
+- Added support for `XACK` command (#1555)
+- Added support for `XCLAIM` command (#1557)
+- Added support for `XPENDING` command (#1558)
+- Added support for `XSETID` command (#1559)
+- Added validation and support for the new `BITOP` command operations (#1566)
+
+### Changed
+- Handle and retry `LOADING` errors from Sentinel replicas (#1536)
+- Retry all exceptions from Sentinel replicas (#1577)
+
+### Fixed
+- Fixed PHP 8.4 deprecated call to `stream_context_set_option()` (#1545)
+- Fixed return type for `ZCOUNT` to be `int` (#1547)
+- Fixed throwing `CommunicationException` when stream is EOF (#1548)
+- Removed automatic `conn_uid` parameter assignment (#1552)
+- Fixed wrong command API call on prefix processing (#1554)
+- Fixed `XREAD` response parsing while read null (#1563)
+- Fixed `XINFO` command responses parsing (#1560)
+- Marked missing commands as Prefixable (#1576)
+
+## v3.0.1 (2025-05-16)
 ### Fixed
 - Send `default` user if only password is used for authentication (#1535)

@@ -138,6 +138,50 @@ it is still desired to have control of when the connection is opened or closed:
 achieved by invoking `$client->connect()` and `$client->disconnect()`. Please note that the effect
 of these methods on aggregate connections may differ depending on each specific implementation.

+#### Persistent connections ####
+
+To increase a performance of your application you may set up a client to use persistent TCP connection, this way
+client saves a time on socket creation and connection handshake. By default, connection is created on first-command
+execution and will be automatically closed by GC before the process is being killed.
+However, if your application is backed by PHP-FPM the processes are idle, and you may set up it to be persistent and
+reusable across multiple script execution within the same process.
+
+To enable the persistent connection mode you should provide following configuration:
+
+```php
+// Standalone
+$client = new Predis\Client(['persistent' => true]);
+
+// Cluster
+$client = new Predis\Client(
+    ['tcp://host:port', 'tcp://host:port', 'tcp://host:port'],
+    ['cluster' => 'redis', 'parameters' => ['persistent' => true]]
+);
+```
+
+**Important**
+
+If you operate on multiple clients within the same application, and they communicate with the same resource, by default
+they will share the same socket (that's the default behaviour of persistent sockets). So in this case you would need
+to additionally provide a `conn_uid` identifier for each client, this way each client will create its own socket so
+the connection context won't be shared across clients. This socket behaviour explained
+[here](https://www.php.net/manual/en/function.stream-socket-client.php#105393)
+
+```php
+// Standalone
+$client1 = new Predis\Client(['persistent' => true, 'conn_uid' => 'id_1']);
+$client2 = new Predis\Client(['persistent' => true, 'conn_uid' => 'id_2']);
+
+// Cluster
+$client1 = new Predis\Client(
+    ['tcp://host:port', 'tcp://host:port', 'tcp://host:port'],
+    ['cluster' => 'redis', 'parameters' => ['persistent' => true, 'conn_uid' => 'id_1']]
+);
+$client2 = new Predis\Client(
+    ['tcp://host:port', 'tcp://host:port', 'tcp://host:port'],
+    ['cluster' => 'redis', 'parameters' => ['persistent' => true, 'conn_uid' => 'id_2']]
+);
+```

 ### Client configuration ###

@@ -1 +1 @@
-3.0.1
+3.3.0
@@ -15,7 +15,7 @@
 // For example, to generate a test case for SET (which is represented by the
 // Predis\Command\Redis\StringSet class):
 //
-//   $ ./bin/generate-command-test --class=StringSet
+//   $ ./bin/create-command-test --class=StringSet
 //
 // Here is a list of optional arguments:
 //
@@ -34,11 +34,11 @@ class SimpleDebuggableConnection extends StreamConnection

    private function storeDebug(CommandInterface $command, $direction)
    {
-        $firtsArg = $command->getArgument(0);
+        $firstArg = $command->getArgument(0);
        $timestamp = round(microtime(true) - $this->tstart, 4);

        $debug = $command->getId();
-        $debug .= isset($firtsArg) ? " $firtsArg " : ' ';
+        $debug .= isset($firstArg) ? " $firstArg " : ' ';
        $debug .= "$direction $this";
        $debug .= " [{$timestamp}s]";

@@ -10,6 +10,9 @@
    stopOnFailure="false"
    beStrictAboutTestsThatDoNotTestAnything="true"
 >
+    <php>
+        <ini name="error_reporting" value="E_ALL &amp; ~E_DEPRECATED"/>
+    </php>

    <testsuites>
        <testsuite name="Predis Test Suite">
@@ -54,7 +54,7 @@ use Traversable;
 */
 class Client implements ClientInterface, IteratorAggregate
 {
-    public const VERSION = '3.0.1';
+    public const VERSION = '3.3.0';

    /** @var OptionsInterface */
    private $options;
@@ -19,6 +19,7 @@ use Predis\Command\Argument\Search\AlterArguments;
 use Predis\Command\Argument\Search\CreateArguments;
 use Predis\Command\Argument\Search\DropArguments;
 use Predis\Command\Argument\Search\ExplainArguments;
+use Predis\Command\Argument\Search\HybridSearch\HybridSearchQuery;
 use Predis\Command\Argument\Search\ProfileArguments;
 use Predis\Command\Argument\Search\SchemaFields\FieldInterface;
 use Predis\Command\Argument\Search\SearchArguments;
@@ -45,12 +46,15 @@ use Predis\Command\Container\Json\JSONDEBUG;
 use Predis\Command\Container\Search\FTCONFIG;
 use Predis\Command\Container\Search\FTCURSOR;
 use Predis\Command\Container\XGROUP;
+use Predis\Command\Redis\VADD;

 /**
 * Interface defining a client-side context such as a pipeline or transaction.
 *
 * @method $this copy(string $source, string $destination, int $db = -1, bool $replace = false)
 * @method $this del(array|string $keys)
+ * @method $this delex(string $key, string $flag, $flagValue)
+ * @method $this digest(string $key)
 * @method $this dump($key)
 * @method $this exists($key)
 * @method $this expire($key, $seconds, string $expireOption = '')
@@ -125,6 +129,7 @@ use Predis\Command\Container\XGROUP;
 * @method $this ftdictdump(string $dict)
 * @method $this ftdropindex(string $index, ?DropArguments $arguments = null)
 * @method $this ftexplain(string $index, string $query, ?ExplainArguments $arguments = null)
+ * @method $this fthybrid(string $index, HybridSearchQuery $query)
 * @method $this ftinfo(string $index)
 * @method $this ftprofile(string $index, ProfileArguments $arguments)
 * @method $this ftsearch(string $index, string $query, ?SearchArguments $arguments = null)
@@ -147,9 +152,10 @@ use Predis\Command\Container\XGROUP;
 * @method $this incrbyfloat($key, $increment)
 * @method $this mget(array $keys)
 * @method $this mset(array $dictionary)
+ * @method $this msetex(array $dictionary, ?string $existModifier = null, ?string $expireResolution = null, ?int $expireTTL = null)
 * @method $this msetnx(array $dictionary)
 * @method $this psetex($key, $milliseconds, $value)
- * @method $this set($key, $value, $expireResolution = null, $expireTTL = null, $flag = null)
+ * @method $this set($key, $value, $expireResolution = null, $expireTTL = null, $flag = null, $flagValue = null)
 * @method $this setbit($key, $offset, $value)
 * @method $this setex($key, $seconds, $value)
 * @method $this setnx($key, $value)
@@ -283,6 +289,22 @@ use Predis\Command\Container\XGROUP;
 * @method $this tsqueryindex(string ...$filterExpression)
 * @method $this tsrange(string $key, $fromTimestamp, $toTimestamp, ?RangeArguments $arguments = null)
 * @method $this tsrevrange(string $key, $fromTimestamp, $toTimestamp, ?RangeArguments $arguments = null)
+ * @method $this xack(string $key, string $group, string ...$id)
+ * @method $this xackdel(string $key, string $group, string $mode, array $ids)
+ * @method $this xadd(string $key, array $dictionary, string $id = '*', array $options = null)
+ * @method $this xautoclaim(string $key, string $group, string $consumer, int $minIdleTime, string $start, ?int $count = null, bool $justId = false)
+ * @method $this xclaim(string $key, string $group, string $consumer, int $minIdleTime, string|array $ids, ?int $idle = null, ?int $time = null, ?int $retryCount = null, bool $force = false, bool $justId = false, ?string $lastId = null)
+ * @method $this xdel(string $key, string ...$id)
+ * @method $this xdelex(string $key, string $mode, array $ids)
+ * @method $this xlen(string $key)
+ * @method $this xpending(string $key, string $group, ?int $minIdleTime = null, ?string $start = null, ?string $end = null, ?int $count = null, ?string $consumer = null)
+ * @method $this xrevrange(string $key, string $end, string $start, ?int $count = null)
+ * @method $this xrange(string $key, string $start, string $end, ?int $count = null)
+ * @method $this xread(int $count = null, int $block = null, array $streams = null, string ...$id)
+ * @method $this xreadgroup(string $group, string $consumer, ?int $count = null, ?int $blockMs = null, bool $noAck = false, string ...$keyOrId)
+ * @method $this xreadgroup_claim(string $group, string $consumer, array $keyIdDict, ?int $count = null, ?int $blockMs = null, bool $noAck = false, ?int $claim = null)
+ * @method $this xsetid(string $key, string $lastId, ?int $entriesAdded = null, ?string $maxDeleteId = null)
+ * @method $this xtrim(string $key, array|string $strategy, string $threshold, array $options = null)
 * @method $this zadd($key, array $membersAndScoresDictionary)
 * @method $this zcard($key)
 * @method $this zcount($key, $min, $max)
@@ -325,6 +347,17 @@ use Predis\Command\Container\XGROUP;
 * @method $this unwatch()
 * @method $this waitaof(int $numLocal, int $numReplicas, int $timeout)
 * @method $this unsubscribe(string ...$channels)
+ * @method $this vadd(string $key, string|array $vector, string $elem, int $dim = null, bool $cas = false, string $quant = VADD::QUANT_DEFAULT, ?int $BEF = null, string|array $attributes = null, int $numlinks = null)
+ * @method $this vcard(string $key)
+ * @method $this vdim(int $key)
+ * @method $this vemb(string $key, string $elem, bool $raw = false)
+ * @method $this vgetattr(string $key, string $elem, bool $asJson = false)
+ * @method $this vinfo(string $key)
+ * @method $this vlinks(string $key, string $elem, bool $withScores = false)
+ * @method $this vrandmember(string $key, int $count = null)
+ * @method $this vrem(string $key, string $elem)
+ * @method $this vsetattr(string $key, string $elem, string|array $attributes)
+ * @method $this vsim(string $key, string|array $vectorOrElem, bool $isElem = false, bool $withScores = false, int $count = null, float $epsilon = null, int $ef = null, string $filter = null, int $filterEf = null, bool $truth = false, bool $noThread = false)
 * @method $this watch($key)
 * @method $this eval($script, $numkeys, $keyOrArg1 = null, $keyOrArgN = null)
 * @method $this eval_ro(string $script, array $keys, ...$argument)
@@ -19,6 +19,7 @@ use Predis\Command\Argument\Search\AlterArguments;
 use Predis\Command\Argument\Search\CreateArguments;
 use Predis\Command\Argument\Search\DropArguments;
 use Predis\Command\Argument\Search\ExplainArguments;
+use Predis\Command\Argument\Search\HybridSearch\HybridSearchQuery;
 use Predis\Command\Argument\Search\ProfileArguments;
 use Predis\Command\Argument\Search\SchemaFields\FieldInterface;
 use Predis\Command\Argument\Search\SearchArguments;
@@ -47,6 +48,7 @@ use Predis\Command\Container\Search\FTCURSOR;
 use Predis\Command\Container\XGROUP;
 use Predis\Command\Container\XINFO;
 use Predis\Command\FactoryInterface;
+use Predis\Command\Redis\VADD;
 use Predis\Configuration\OptionsInterface;
 use Predis\Connection\ConnectionInterface;
 use Predis\Response\Status;
@@ -61,6 +63,8 @@ use Predis\Response\Status;
 *
 * @method int               copy(string $source, string $destination, int $db = -1, bool $replace = false)
 * @method int               del(string[]|string $keyOrKeys, string ...$keys = null)
+ * @method int               delex(string $key, string $flag, $flagValue)
+ * @method string            digest(string $key)
 * @method string|null       dump(string $key)
 * @method int               exists(string $key)
 * @method int               expire(string $key, int $seconds, string $expireOption = '')
@@ -135,6 +139,7 @@ use Predis\Response\Status;
 * @method array             ftdictdump(string $dict)
 * @method Status            ftdropindex(string $index, ?DropArguments $arguments = null)
 * @method string            ftexplain(string $index, string $query, ?ExplainArguments $arguments = null)
+ * @method array             fthybrid(string $index, HybridSearchQuery $query)
 * @method array             ftinfo(string $index)
 * @method array             ftprofile(string $index, ProfileArguments $arguments)
 * @method array             ftsearch(string $index, string $query, ?SearchArguments $arguments = null)
@@ -157,9 +162,10 @@ use Predis\Response\Status;
 * @method string            incrbyfloat(string $key, int|float $increment)
 * @method array             mget(string[]|string $keyOrKeys, string ...$keys = null)
 * @method mixed             mset(array $dictionary)
+ * @method array             msetex(array $dictionary, ?string $existModifier = null, ?string $expireResolution = null, ?int $expireTTL = null)
 * @method int               msetnx(array $dictionary)
 * @method Status            psetex(string $key, $milliseconds, $value)
- * @method Status|null       set(string $key, $value, $expireResolution = null, $expireTTL = null, $flag = null)
+ * @method Status|null       set(string $key, $value, $expireResolution = null, $expireTTL = null, $flag = null, $flagValue = null)
 * @method int               setbit(string $key, $offset, $value)
 * @method Status            setex(string $key, $seconds, $value)
 * @method int               setnx(string $key, $value)
@@ -294,18 +300,25 @@ use Predis\Response\Status;
 * @method array             tsqueryindex(string ...$filterExpression)
 * @method array             tsrange(string $key, $fromTimestamp, $toTimestamp, ?RangeArguments $arguments = null)
 * @method array             tsrevrange(string $key, $fromTimestamp, $toTimestamp, ?RangeArguments $arguments = null)
+ * @method int               xack(string $key, string $group, string ...$id)
+ * @method array             xackdel(string $key, string $group, string $mode, array $ids)
 * @method string            xadd(string $key, array $dictionary, string $id = '*', array $options = null)
 * @method array             xautoclaim(string $key, string $group, string $consumer, int $minIdleTime, string $start, ?int $count = null, bool $justId = false)
+ * @method array             xclaim(string $key, string $group, string $consumer, int $minIdleTime, string|array $ids, ?int $idle = null, ?int $time = null, ?int $retryCount = null, bool $force = false, bool $justId = false, ?string $lastId = null)
 * @method int               xdel(string $key, string ...$id)
+ * @method array             xdelex(string $key, string $mode, array $ids)
 * @method int               xlen(string $key)
+ * @method array             xpending(string $key, string $group, ?int $minIdleTime = null, ?string $start = null, ?string $end = null, ?int $count = null, ?string $consumer = null)
 * @method array             xrevrange(string $key, string $end, string $start, ?int $count = null)
 * @method array             xrange(string $key, string $start, string $end, ?int $count = null)
 * @method array|null        xread(int $count = null, int $block = null, array $streams = null, string ...$id)
 * @method array             xreadgroup(string $group, string $consumer, ?int $count = null, ?int $blockMs = null, bool $noAck = false, string ...$keyOrId)
+ * @method array             xreadgroup_claim(string $group, string $consumer, array $keyIdDict, ?int $count = null, ?int $blockMs = null, bool $noAck = false, ?int $claim = null)
+ * @method Status            xsetid(string $key, string $lastId, ?int $entriesAdded = null, ?string $maxDeleteId = null)
 * @method string            xtrim(string $key, array|string $strategy, string $threshold, array $options = null)
 * @method int               zadd(string $key, array $membersAndScoresDictionary)
 * @method int               zcard(string $key)
- * @method string            zcount(string $key, int|string $min, int|string $max)
+ * @method int               zcount(string $key, int|string $min, int|string $max)
 * @method array             zdiff(array $keys, bool $withScores = false)
 * @method int               zdiffstore(string $destination, array $keys)
 * @method string            zincrby(string $key, int $increment, string $member)
@@ -346,6 +359,17 @@ use Predis\Response\Status;
 * @method mixed             multi()
 * @method mixed             unwatch()
 * @method array             unsubscribe(string ...$channels)
+ * @method bool              vadd(string $key, string|array $vector, string $elem, int $dim = null, bool $cas = false, string $quant = VADD::QUANT_DEFAULT, int $bef = null, string|array $attributes = null, int $numlinks = null)
+ * @method int               vcard(string $key)
+ * @method int               vdim(string $key)
+ * @method array             vemb(string $key, string $elem, bool $raw = false)
+ * @method string|array|null vgetattr(string $key, string $elem, bool $asJson = false)
+ * @method array|null        vinfo(string $key)
+ * @method array|null        vlinks(string $key, string $elem, bool $withScores = false)
+ * @method string|array|null vrandmember(string $key, int $count = null)
+ * @method bool              vrem(string $key, string $elem)
+ * @method array             vsim(string $key, string|array $vectorOrElem, bool $isElem = false, bool $withScores = false, int $count = null, float $epsilon = null, int $ef = null, string $filter = null, int $filterEf = null, bool $truth = false, bool $noThread = false)
+ * @method bool              vsetattr(string $key, string $elem, string|array $attributes)
 * @method array             waitaof(int $numLocal, int $numReplicas, int $timeout)
 * @method mixed             watch(string[]|string $keyOrKeys)
 * @method mixed             eval(string $script, int $numkeys, string ...$keyOrArg = null)
@@ -155,6 +155,11 @@ abstract class ClusterStrategy implements StrategyInterface
            'HSCAN' => $getKeyFromFirstArgument,
            'HSTRLEN' => $getKeyFromFirstArgument,

+            /* commands operating on streams */
+            'XADD' => $getKeyFromFirstArgument,
+            'XDEL' => $getKeyFromFirstArgument,
+            'XRANGE' => $getKeyFromFirstArgument,
+
            /* commands operating on HyperLogLog */
            'PFADD' => $getKeyFromFirstArgument,
            'PFCOUNT' => $getKeyFromAllArguments,
@@ -0,0 +1,44 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Argument\Search\HybridSearch\Combine;
+
+use Predis\Command\Argument\ArrayableArgument;
+
+abstract class BaseCombine implements ArrayableArgument
+{
+    /**
+     * @var array
+     */
+    protected $arguments = ['COMBINE'];
+
+    /**
+     * @var array
+     */
+    protected $as = [];
+
+    /**
+     * @param  string $alias
+     * @return $this
+     */
+    public function as(string $alias): self
+    {
+        array_push($this->as, 'YIELD_SCORE_AS', $alias);
+
+        return $this;
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    abstract public function toArray(): array;
+}
@@ -0,0 +1,79 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Argument\Search\HybridSearch\Combine;
+
+class LinearCombineConfig extends BaseCombine
+{
+    /**
+     * @var float
+     */
+    protected $alpha;
+
+    /**
+     * @var float
+     */
+    protected $beta;
+
+    /**
+     * The weight for the text score (a value between 0 and 1).
+     *
+     * @param  float $alpha
+     * @return $this
+     */
+    public function alpha(float $alpha): self
+    {
+        $this->alpha = $alpha;
+
+        return $this;
+    }
+
+    /**
+     * The weight for the vector score (a value between 0 and 1).
+     *
+     * @param  float $beta
+     * @return $this
+     */
+    public function beta(float $beta): self
+    {
+        $this->beta = $beta;
+
+        return $this;
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public function toArray(): array
+    {
+        $this->arguments[] = 'LINEAR';
+        $tokens = [];
+
+        if ($this->alpha !== null) {
+            array_push($tokens, 'ALPHA', $this->alpha);
+        }
+
+        if ($this->beta !== null) {
+            array_push($tokens, 'BETA', $this->beta);
+        }
+
+        if ($this->as) {
+            array_push($tokens, ...$this->as);
+        }
+
+        if (!empty($tokens)) {
+            array_push($this->arguments, count($tokens), ...$tokens);
+        }
+
+        return $this->arguments;
+    }
+}
@@ -0,0 +1,79 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Argument\Search\HybridSearch\Combine;
+
+class RRFCombineConfig extends BaseCombine
+{
+    /**
+     * @var int
+     */
+    protected $window;
+
+    /**
+     * @var int
+     */
+    protected $rrfConstant;
+
+    /**
+     * The number of top results from each search type to consider for fusion. Defaults to 50.
+     *
+     * @param  int   $window
+     * @return $this
+     */
+    public function window(int $window): self
+    {
+        $this->window = $window;
+
+        return $this;
+    }
+
+    /**
+     * The RRF ranking constant. A smaller value gives more weight to top-ranked items. Defaults to 60.
+     *
+     * @param  int   $constant
+     * @return $this
+     */
+    public function rrfConstant(int $constant): self
+    {
+        $this->rrfConstant = $constant;
+
+        return $this;
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public function toArray(): array
+    {
+        $this->arguments[] = 'RRF';
+        $tokens = [];
+
+        if ($this->window !== null) {
+            array_push($tokens, 'WINDOW', $this->window);
+        }
+
+        if ($this->rrfConstant !== null) {
+            array_push($tokens, 'CONSTANT', $this->rrfConstant);
+        }
+
+        if ($this->as) {
+            array_push($tokens, ...$this->as);
+        }
+
+        if (!empty($tokens)) {
+            array_push($this->arguments, count($tokens), ...$tokens);
+        }
+
+        return $this->arguments;
+    }
+}
@@ -0,0 +1,352 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Argument\Search\HybridSearch;
+
+use Predis\Command\Argument\ArrayableArgument;
+use Predis\Command\Argument\Search\HybridSearch\Combine\LinearCombineConfig;
+use Predis\Command\Argument\Search\HybridSearch\Combine\RRFCombineConfig;
+use Predis\Command\Argument\Search\HybridSearch\VectorSearch\KNNVectorSearchConfig;
+use Predis\Command\Argument\Search\HybridSearch\VectorSearch\RangeVectorSearchConfig;
+use Predis\Command\Redis\Utils\CommandUtility;
+use ValueError;
+
+class HybridSearchQuery implements ArrayableArgument
+{
+    public const SORT_ASC = 'ASC';
+    public const SORT_DESC = 'DESC';
+
+    /**
+     * @var SearchConfig
+     */
+    protected $searchConfig;
+
+    /**
+     * The vector search portion of the query.
+     *
+     * @var KNNVectorSearchConfig|RangeVectorSearchConfig
+     */
+    protected $vectorSearchConfig;
+
+    /**
+     * Configuration for the score fusion method (optional).
+     * If not provided, Reciprocal Rank Fusion (RRF) is used with server-side default parameters.
+     *
+     * @var RRFCombineConfig|LinearCombineConfig
+     */
+    protected $combineConfig;
+
+    /**
+     * @var array
+     */
+    protected $load = [];
+
+    /**
+     * @var array
+     */
+    protected $groupBy = [];
+
+    /**
+     * @var array
+     */
+    protected $apply = [];
+
+    /**
+     * @var array
+     */
+    protected $sortBy = [];
+
+    /**
+     * @var string
+     */
+    protected $filter;
+
+    /**
+     * @var array
+     */
+    protected $limit = [];
+
+    /**
+     * @var array
+     */
+    protected $params = [];
+
+    /**
+     * @var bool
+     */
+    protected $explainScore = false;
+
+    /**
+     * @var bool
+     */
+    protected $timeout = false;
+
+    /**
+     * @var array
+     */
+    protected $withCursor = [];
+
+    /**
+     * @var array
+     */
+    protected $arguments = [];
+
+    /**
+     * @param string $vectorSearchMethod Class type of desired vector search method
+     * @param string $combineMethod      Class type of desired combine method
+     */
+    public function __construct(
+        string $vectorSearchMethod = KNNVectorSearchConfig::class,
+        string $combineMethod = RRFCombineConfig::class
+    ) {
+        $this->searchConfig = new SearchConfig();
+        $this->vectorSearchConfig = new $vectorSearchMethod();
+        $this->combineConfig = new $combineMethod();
+    }
+
+    /**
+     * @param  callable(SearchConfig): void $callable
+     * @return $this
+     */
+    public function buildSearchConfig(callable $callable): self
+    {
+        $callable($this->searchConfig);
+
+        return $this;
+    }
+
+    /**
+     * @param  callable(KNNVectorSearchConfig|RangeVectorSearchConfig): void $callable
+     * @return $this
+     */
+    public function buildVectorSearchConfig(callable $callable): self
+    {
+        $callable($this->vectorSearchConfig);
+
+        return $this;
+    }
+
+    /**
+     * @param  callable(RRFCombineConfig|LinearCombineConfig): void $callable
+     * @return $this
+     */
+    public function buildCombineConfig(callable $callable): self
+    {
+        $callable($this->combineConfig);
+
+        return $this;
+    }
+
+    /**
+     * The list of fields to return in the results.
+     *
+     * @param  array $fields
+     * @return $this
+     */
+    public function load(array $fields): self
+    {
+        array_push($this->load, 'LOAD', count($fields), ...$fields);
+
+        return $this;
+    }
+
+    /**
+     * @param  array     $fields
+     * @param  Reducer[] $reducers
+     * @return $this
+     */
+    public function groupBy(array $fields, array $reducers): self
+    {
+        array_push($this->groupBy, 'GROUPBY', count($fields), ...$fields);
+
+        foreach ($reducers as $reducer) {
+            array_push($this->groupBy, 'REDUCE', ...$reducer->toArray());
+        }
+
+        return $this;
+    }
+
+    /**
+     * @param  array $expressionFieldDict field => function dictionary
+     * @return $this
+     */
+    public function apply(array $expressionFieldDict): self
+    {
+        foreach ($expressionFieldDict as $field => $function) {
+            array_push($this->apply, 'APPLY', $function, 'AS', $field);
+        }
+
+        return $this;
+    }
+
+    /**
+     * Sorts the final results by a specific field.
+     *
+     * @param  array<string, string> $fields Dictionary with fields and sort direction. Check class constants.
+     * @return $this
+     */
+    public function sortBy(array $fields): self
+    {
+        $fieldsArray = [];
+        foreach ($fields as $field => $direction) {
+            if (!in_array(strtoupper($direction), [self::SORT_ASC, self::SORT_DESC])) {
+                throw new ValueError('Sort direction must be one of "ASC" or "DESC".');
+            }
+
+            array_push($fieldsArray, $field, $direction);
+        }
+
+        array_push($this->sortBy, 'SORTBY', count($fieldsArray), ...$fieldsArray);
+
+        return $this;
+    }
+
+    /**
+     * Final result filtering.
+     *
+     * @param  string $expression
+     * @return $this
+     */
+    public function filter(string $expression): self
+    {
+        $this->filter = $expression;
+
+        return $this;
+    }
+
+    /**
+     * @param  int   $offset
+     * @param  int   $num
+     * @return $this
+     */
+    public function limit(int $offset, int $num): self
+    {
+        array_push($this->limit, 'LIMIT', $offset, $num);
+
+        return $this;
+    }
+
+    /**
+     * Binds values to named parameters in the query string.
+     *
+     * @param  array $params
+     * @return $this
+     */
+    public function params(array $params): self
+    {
+        $arrayParams = CommandUtility::dictionaryToArray($params);
+        array_push($this->params, 'PARAMS', count($arrayParams), ...$arrayParams);
+
+        return $this;
+    }
+
+    /**
+     * @return $this
+     */
+    public function explainScore(): self
+    {
+        $this->explainScore = true;
+
+        return $this;
+    }
+
+    /**
+     * @return $this
+     */
+    public function timeout(): self
+    {
+        $this->timeout = true;
+
+        return $this;
+    }
+
+    /**
+     * @param  int|null $readSize
+     * @param  int|null $idleTime
+     * @return $this
+     */
+    public function withCursor(?int $readSize = null, ?int $idleTime = null): self
+    {
+        $this->withCursor[] = 'WITHCURSOR';
+
+        if ($readSize) {
+            array_push($this->withCursor, 'COUNT', $readSize);
+        }
+
+        if ($idleTime) {
+            array_push($this->withCursor, 'MAXIDLE', $idleTime);
+        }
+
+        return $this;
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public function toArray(): array
+    {
+        $this->arguments = array_merge(
+            $this->arguments,
+            $this->searchConfig->toArray(),
+            $this->vectorSearchConfig->toArray()
+        );
+
+        $combineConfig = $this->combineConfig->toArray();
+
+        // Only add if any configuration was applied
+        if (count($combineConfig) > 2) {
+            $this->arguments = array_merge($this->arguments, $combineConfig);
+        }
+
+        if ($this->load) {
+            $this->arguments = array_merge($this->arguments, $this->load);
+        }
+
+        if ($this->groupBy) {
+            $this->arguments = array_merge($this->arguments, $this->groupBy);
+        }
+
+        if ($this->apply) {
+            $this->arguments = array_merge($this->arguments, $this->apply);
+        }
+
+        if ($this->sortBy) {
+            $this->arguments = array_merge($this->arguments, $this->sortBy);
+        }
+
+        if ($this->filter) {
+            array_push($this->arguments, 'FILTER', $this->filter);
+        }
+
+        if ($this->limit) {
+            $this->arguments = array_merge($this->arguments, $this->limit);
+        }
+
+        if ($this->params) {
+            $this->arguments = array_merge($this->arguments, $this->params);
+        }
+
+        if ($this->explainScore) {
+            $this->arguments[] = 'EXPLAINSCORE';
+        }
+
+        if ($this->timeout) {
+            $this->arguments[] = 'TIMEOUT';
+        }
+
+        if ($this->withCursor) {
+            $this->arguments = array_merge($this->arguments, $this->withCursor);
+        }
+
+        return $this->arguments;
+    }
+}
@@ -0,0 +1,51 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Argument\Search\HybridSearch;
+
+use Predis\Command\Argument\ArrayableArgument;
+
+class Reducer implements ArrayableArgument
+{
+    public const REDUCE_COUNT = 'COUNT';
+    public const REDUCE_COUNT_DISTINCT = 'COUNT_DISTINCT';
+    public const REDUCE_COUNT_DISTINCTISH = 'COUNT_DISTINCTISH';
+    public const REDUCE_SUM = 'SUM';
+    public const REDUCE_MIN = 'MIN';
+    public const REDUCE_MAX = 'MAX';
+    public const REDUCE_AVG = 'AVG';
+    public const REDUCE_STDDEV = 'STDDEV';
+    public const REDUCE_QUANTILE = 'QUANTILE';
+
+    /**
+     * @var array
+     */
+    protected $arguments = [];
+
+    /**
+     * @param string $function  One of the available functions. Check class constants.
+     * @param array  $arguments List of properties
+     */
+    public function __construct(string $function = self::REDUCE_COUNT, array $arguments = [], ?string $alias = null)
+    {
+        array_push($this->arguments, $function, count($arguments), ...$arguments);
+
+        if ($alias) {
+            array_push($this->arguments, 'AS', $alias);
+        }
+    }
+
+    public function toArray(): array
+    {
+        return $this->arguments;
+    }
+}
@@ -0,0 +1,60 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Argument\Search\HybridSearch;
+
+use Predis\Command\Argument\ArrayableArgument;
+
+class ScorerConfig implements ArrayableArgument
+{
+    public const TYPE_BM25 = 'BM25';
+    public const TYPE_TFIDF = 'TFIDF';
+    public const TYPE_DISMAX = 'DISMAX';
+    public const TYPE_DOCSCORE = 'DOCSCORE';
+
+    /**
+     * @var array
+     */
+    protected $arguments = [];
+
+    /**
+     * The text scoring algorithm. Defaults to BM25.
+     *
+     * @param  string $type
+     * @return $this
+     */
+    public function type(string $type = self::TYPE_BM25): self
+    {
+        $this->arguments[] = $type;
+
+        return $this;
+    }
+
+    /**
+     * An alias for the text score field in the results.
+     * The aliased field will be included in the `value` object of each returned document.
+     *
+     * @param  string $alias
+     * @return $this
+     */
+    public function as(string $alias): self
+    {
+        array_push($this->arguments, 'YIELD_SCORE_AS', $alias);
+
+        return $this;
+    }
+
+    public function toArray(): array
+    {
+        return $this->arguments;
+    }
+}
@@ -0,0 +1,80 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Argument\Search\HybridSearch;
+
+use Predis\Command\Argument\ArrayableArgument;
+
+class SearchConfig implements ArrayableArgument
+{
+    /**
+     * @var array
+     */
+    protected $arguments = ['SEARCH'];
+
+    /**
+     * @var ScorerConfig
+     */
+    protected $scorerConfig;
+
+    public function __construct()
+    {
+        $this->scorerConfig = new ScorerConfig();
+    }
+
+    /**
+     * Search query.
+     *
+     * @param  string $query
+     * @return $this
+     */
+    public function query(string $query): self
+    {
+        $this->arguments[] = $query;
+
+        return $this;
+    }
+
+    /**
+     * @param  string $alias
+     * @return $this
+     */
+    public function as(string $alias): self
+    {
+        array_push($this->arguments, 'YIELD_SCORE_AS', $alias);
+
+        return $this;
+    }
+
+    /**
+     * @param  callable(ScorerConfig): void $callable
+     * @return $this
+     */
+    public function buildScorerConfig(callable $callable): self
+    {
+        $callable($this->scorerConfig);
+
+        return $this;
+    }
+
+    public function toArray(): array
+    {
+        $scorerConfig = $this->scorerConfig->toArray();
+
+        if (!empty($scorerConfig)) {
+            $this->arguments[] = 'SCORER';
+            $this->arguments = array_merge($this->arguments, $scorerConfig);
+        }
+
+        return $this->arguments;
+    }
+}
@@ -0,0 +1,85 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Argument\Search\HybridSearch\VectorSearch;
+
+use Predis\Command\Argument\ArrayableArgument;
+use Predis\Command\Redis\Utils\VectorUtility;
+
+abstract class BaseVectorSearchConfig implements ArrayableArgument
+{
+    public const POLICY_ADHOC = 'ADHOC';
+    public const POLICY_BATCHES = 'BATCHES';
+    public const POLICY_ACORN = 'ACORN';
+
+    /**
+     * @var array
+     */
+    protected $vector = [];
+
+    /**
+     * @var array
+     */
+    protected $filter = [];
+
+    /**
+     * @var array
+     */
+    protected $as = [];
+
+    /**
+     * @var array
+     */
+    protected $arguments = ['VSIM'];
+
+    /**
+     * Vector to perform search against.
+     *
+     * @param  string         $field The vector field name to search against. Must start with "@".
+     * @param  string|float[] $value Binary vector representation or array of floats as vector.
+     * @return self
+     */
+    public function vector(string $field, $value): self
+    {
+        if (is_array($value)) {
+            array_push($this->vector, $field, VectorUtility::toBlob($value));
+        } else {
+            array_push($this->vector, $field, $value);
+        }
+
+        return $this;
+    }
+
+    /**
+     * @param  string $expression
+     * @return $this
+     */
+    public function filter(string $expression): self
+    {
+        array_push($this->filter, 'FILTER', $expression);
+
+        return $this;
+    }
+
+    /**
+     * @param  string $alias
+     * @return $this
+     */
+    public function as(string $alias): self
+    {
+        array_push($this->as, 'YIELD_SCORE_AS', $alias);
+
+        return $this;
+    }
+
+    abstract public function toArray(): array;
+}
@@ -0,0 +1,91 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Argument\Search\HybridSearch\VectorSearch;
+
+use ValueError;
+
+class KNNVectorSearchConfig extends BaseVectorSearchConfig
+{
+    /**
+     * @var int
+     */
+    protected $k;
+
+    /**
+     * @var int
+     */
+    protected $ef;
+
+    /**
+     * The number of nearest neighbors to find. Defaults to 10 on server side.
+     *
+     * @param  int  $k
+     * @return self
+     */
+    public function k(int $k): self
+    {
+        $this->k = $k;
+
+        return $this;
+    }
+
+    /**
+     * The HNSW `ef_runtime` parameter for tuning the accuracy/speed trade-off.
+     *
+     * @param  int   $ef
+     * @return $this
+     */
+    public function ef(int $ef): self
+    {
+        $this->ef = $ef;
+
+        return $this;
+    }
+
+    public function toArray(): array
+    {
+        if (!$this->vector) {
+            throw new ValueError('Vector configuration not specified.');
+        }
+
+        $this->arguments = array_merge($this->arguments, $this->vector);
+
+        if ($this->k || $this->ef) {
+            $this->arguments[] = 'KNN';
+        }
+
+        $tokens = [];
+
+        if ($this->k !== null) {
+            array_push($tokens, 'K', $this->k);
+        }
+
+        if ($this->ef !== null) {
+            array_push($tokens, 'EF_RUNTIME', $this->ef);
+        }
+
+        if (!empty($tokens)) {
+            array_push($this->arguments, count($tokens), ...$tokens);
+        }
+
+        if ($this->filter) {
+            $this->arguments = array_merge($this->arguments, $this->filter);
+        }
+
+        if ($this->as) {
+            array_push($this->arguments, ...$this->as);
+        }
+
+        return $this->arguments;
+    }
+}
@@ -0,0 +1,89 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Argument\Search\HybridSearch\VectorSearch;
+
+use ValueError;
+
+class RangeVectorSearchConfig extends BaseVectorSearchConfig
+{
+    /**
+     * @var int
+     */
+    protected $radius;
+
+    /**
+     * @var float
+     */
+    protected $epsilon;
+
+    /**
+     * The search radius/threshold. Finds all vectors within this distance.
+     *
+     * @param  int   $radius
+     * @return $this
+     */
+    public function radius(int $radius): self
+    {
+        $this->radius = $radius;
+
+        return $this;
+    }
+
+    /**
+     * @param  float $epsilon
+     * @return $this
+     */
+    public function epsilon(float $epsilon): self
+    {
+        $this->epsilon = $epsilon;
+
+        return $this;
+    }
+
+    public function toArray(): array
+    {
+        if (!$this->vector) {
+            throw new ValueError('Vector configuration not specified.');
+        }
+
+        $this->arguments = array_merge($this->arguments, $this->vector);
+
+        if ($this->radius || $this->epsilon) {
+            $this->arguments[] = 'RANGE';
+        }
+
+        $tokens = [];
+
+        if ($this->radius !== null) {
+            array_push($tokens, 'RADIUS', $this->radius);
+        }
+
+        if ($this->epsilon !== null) {
+            array_push($tokens, 'EPSILON', $this->epsilon);
+        }
+
+        if (!empty($tokens)) {
+            array_push($this->arguments, count($tokens), ...$tokens);
+        }
+
+        if ($this->filter) {
+            $this->arguments = array_merge($this->arguments, $this->filter);
+        }
+
+        if ($this->as) {
+            array_push($this->arguments, ...$this->as);
+        }
+
+        return $this->arguments;
+    }
+}
@@ -32,7 +32,7 @@ abstract class PrefixableCommand extends Command implements PrefixableCommandInt
     */
    public function applyPrefixForAllArguments(string $prefix): void
    {
-        $this->setArguments(
+        $this->setRawArguments(
            array_map(static function ($key) use ($prefix) {
                return $prefix . $key;
            }, $this->getArguments())
@@ -49,7 +49,7 @@ abstract class PrefixableCommand extends Command implements PrefixableCommandInt
    {
        $arguments = $this->getArguments();
        $arguments[0] = $prefix . $arguments[0];
-        $this->setArguments($arguments);
+        $this->setRawArguments($arguments);
    }

    /**
@@ -12,6 +12,7 @@

 namespace Predis\Command\Redis;

+use InvalidArgumentException;
 use Predis\Command\PrefixableCommand as RedisCommand;

 /**
@@ -19,6 +20,8 @@ use Predis\Command\PrefixableCommand as RedisCommand;
 */
 class BITOP extends RedisCommand
 {
+    private const VALID_OPERATIONS = ['AND', 'OR', 'XOR', 'NOT', 'DIFF', 'DIFF1', 'ANDOR', 'ONE'];
+
    /**
     * {@inheritdoc}
     */
@@ -38,6 +41,13 @@ class BITOP extends RedisCommand
            array_unshift($arguments, $operation, $destination);
        }

+        if (!empty($arguments)) {
+            $operation = strtoupper($arguments[0]);
+            if (!in_array($operation, self::VALID_OPERATIONS, false)) {
+                throw new InvalidArgumentException('BITOP operation must be one of: AND, OR, XOR, NOT, DIFF, DIFF1, ANDOR, ONE');
+            }
+        }
+
        parent::setArguments($arguments);
    }

@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\BloomFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/bf.add/
@@ -26,4 +26,9 @@ class BFADD extends RedisCommand
    {
        return 'BF.ADD';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\BloomFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/bf.exists/
@@ -25,4 +25,9 @@ class BFEXISTS extends RedisCommand
    {
        return 'BF.EXISTS';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\BloomFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;
 use UnexpectedValueException;

 /**
@@ -76,4 +76,9 @@ class BFINFO extends RedisCommand

        return $data;
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\BloomFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;
 use Predis\Command\Traits\BloomFilters\Capacity;
 use Predis\Command\Traits\BloomFilters\Error;
 use Predis\Command\Traits\BloomFilters\Expansion;
@@ -48,6 +48,11 @@ class BFINSERT extends RedisCommand
        return 'BF.INSERT';
    }

+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
+
    public function setArguments(array $arguments)
    {
        $this->setNoCreate($arguments);
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\BloomFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/bf.loadchunk/
@@ -25,4 +25,9 @@ class BFLOADCHUNK extends RedisCommand
    {
        return 'BF.LOADCHUNK';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\BloomFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/bf.madd/
@@ -26,4 +26,9 @@ class BFMADD extends RedisCommand
    {
        return 'BF.MADD';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\BloomFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/bf.mexists/
@@ -25,4 +25,9 @@ class BFMEXISTS extends RedisCommand
    {
        return 'BF.MEXISTS';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\BloomFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;
 use Predis\Command\Traits\BloomFilters\Expansion;

 /**
@@ -46,4 +46,9 @@ class BFRESERVE extends RedisCommand
        $this->setExpansion($arguments);
        $this->filterArguments();
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\BloomFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/bf.scandump/
@@ -26,4 +26,9 @@ class BFSCANDUMP extends RedisCommand
    {
        return 'BF.SCANDUMP';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -32,9 +32,23 @@ class COMMAND extends BaseCommand
     */
    public function parseResponse($data)
    {
-        // Relay (RESP3) uses maps and it might be good
-        // to make the return value a breaking change
+        if (!is_array($data)) {
+            return $data;
+        }

-        return $data;
+        if ($data === array_values($data)) {
+            return array_map(function ($item) {
+                return $this->parseResponse($item);
+            }, $data);
+        }
+
+        // Relay
+        $result = [];
+        foreach ($data as $key => $value) {
+            $result[] = $key;
+            $result[] = $this->parseResponse($value);
+        }
+
+        return $result;
    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CountMinSketch;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cms.incrby/
@@ -26,4 +26,9 @@ class CMSINCRBY extends RedisCommand
    {
        return 'CMS.INCRBY';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CountMinSketch;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cms.info/
@@ -42,4 +42,9 @@ class CMSINFO extends RedisCommand

        return $data;
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CountMinSketch;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cms.initbydim/
@@ -25,4 +25,9 @@ class CMSINITBYDIM extends RedisCommand
    {
        return 'CMS.INITBYDIM';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CountMinSketch;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cms.initbyprob/
@@ -25,4 +25,9 @@ class CMSINITBYPROB extends RedisCommand
    {
        return 'CMS.INITBYPROB';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CountMinSketch;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cms.merge/
@@ -39,4 +39,17 @@ class CMSMERGE extends RedisCommand

        parent::setArguments($processedArguments);
    }
+
+    public function prefixKeys($prefix)
+    {
+        if ($arguments = $this->getArguments()) {
+            $arguments[0] = $prefix . $arguments[0];
+
+            for ($i = 2, $iMax = (int) $arguments[1] + 2; $i < $iMax; $i++) {
+                $arguments[$i] = $prefix . $arguments[$i];
+            }
+
+            $this->setRawArguments($arguments);
+        }
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CountMinSketch;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cms.query/
@@ -25,4 +25,9 @@ class CMSQUERY extends RedisCommand
    {
        return 'CMS.QUERY';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CuckooFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cf.add/
@@ -25,4 +25,9 @@ class CFADD extends RedisCommand
    {
        return 'CF.ADD';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CuckooFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cf.addnx/
@@ -25,4 +25,9 @@ class CFADDNX extends RedisCommand
    {
        return 'CF.ADDNX';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CuckooFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cf.count/
@@ -26,4 +26,9 @@ class CFCOUNT extends RedisCommand
    {
        return 'CF.COUNT';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CuckooFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cf.del/
@@ -27,4 +27,9 @@ class CFDEL extends RedisCommand
    {
        return 'CF.DEL';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CuckooFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cf.exists/
@@ -25,4 +25,9 @@ class CFEXISTS extends RedisCommand
    {
        return 'CF.EXISTS';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CuckooFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cf.info/
@@ -42,4 +42,9 @@ class CFINFO extends RedisCommand

        return $data;
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CuckooFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;
 use Predis\Command\Traits\BloomFilters\Capacity;
 use Predis\Command\Traits\BloomFilters\Items;
 use Predis\Command\Traits\BloomFilters\NoCreate;
@@ -49,4 +49,9 @@ class CFINSERT extends RedisCommand
        $this->setCapacity($arguments);
        $this->filterArguments();
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CuckooFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cf.loadchunk/
@@ -26,4 +26,9 @@ class CFLOADCHUNK extends RedisCommand
    {
        return 'CF.LOADCHUNK';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CuckooFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cf.mexists/
@@ -25,4 +25,9 @@ class CFMEXISTS extends RedisCommand
    {
        return 'CF.MEXISTS';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CuckooFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;
 use Predis\Command\Traits\BloomFilters\BucketSize;
 use Predis\Command\Traits\BloomFilters\Expansion;
 use Predis\Command\Traits\BloomFilters\MaxIterations;
@@ -49,4 +49,9 @@ class CFRESERVE extends RedisCommand
        $this->setBucketSize($arguments);
        $this->filterArguments();
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\CuckooFilter;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/cf.scandump/
@@ -26,4 +26,9 @@ class CFSCANDUMP extends RedisCommand
    {
        return 'CF.SCANDUMP';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -0,0 +1,34 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Redis;
+
+use Predis\Command\PrefixableCommand;
+
+class DELEX extends PrefixableCommand
+{
+    /**
+     * {@inheritDoc}
+     */
+    public function getId()
+    {
+        return 'DELEX';
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
+}
@@ -0,0 +1,34 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Redis;
+
+use Predis\Command\PrefixableCommand;
+
+class DIGEST extends PrefixableCommand
+{
+    /**
+     * {@inheritDoc}
+     */
+    public function getId()
+    {
+        return 'DIGEST';
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
+}
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/expiretime/
@@ -26,4 +26,9 @@ class EXPIRETIME extends RedisCommand
    {
        return 'EXPIRETIME';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -127,4 +127,26 @@ class FUNCTIONS extends RedisCommand

        parent::setArguments($processedArguments);
    }
+
+    public function parseResponse($data)
+    {
+        if (!is_array($data)) {
+            return $data;
+        }
+
+        if ($data === array_values($data)) {
+            return array_map(function ($item) {
+                return $this->parseResponse($item);
+            }, $data);
+        }
+
+        // Relay
+        $result = [];
+        foreach ($data as $key => $value) {
+            $result[] = $key;
+            $result[] = $this->parseResponse($value);
+        }
+
+        return $result;
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;
 use Predis\Command\Traits\By\GeoBy;
 use Predis\Command\Traits\Count;
 use Predis\Command\Traits\From\GeoFrom;
@@ -119,4 +119,9 @@ class GEOSEARCH extends RedisCommand

        return $parsedData;
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 class GETDEL extends RedisCommand
 {
@@ -20,4 +20,9 @@ class GETDEL extends RedisCommand
    {
        return 'GETDEL';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;
 use UnexpectedValueException;

 class HEXPIRE extends RedisCommand
@@ -48,4 +48,9 @@ class HEXPIRE extends RedisCommand

        parent::setArguments($processedArguments);
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 class HEXPIRETIME extends RedisCommand
 {
@@ -28,4 +28,9 @@ class HEXPIRETIME extends RedisCommand

        parent::setArguments($processedArguments);
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.arrappend/
@@ -25,4 +25,9 @@ class JSONARRAPPEND extends RedisCommand
    {
        return 'JSON.ARRAPPEND';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.arrindex/
@@ -25,4 +25,9 @@ class JSONARRINDEX extends RedisCommand
    {
        return 'JSON.ARRINDEX';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.arrinsert/
@@ -25,4 +25,9 @@ class JSONARRINSERT extends RedisCommand
    {
        return 'JSON.ARRINSERT';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.arrlen/
@@ -25,4 +25,9 @@ class JSONARRLEN extends RedisCommand
    {
        return 'JSON.ARRLEN';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.arrpop/
@@ -25,4 +25,9 @@ class JSONARRPOP extends RedisCommand
    {
        return 'JSON.ARRPOP';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.arrtrim/
@@ -25,4 +25,9 @@ class JSONARRTRIM extends RedisCommand
    {
        return 'JSON.ARRTRIM';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.clear/
@@ -25,4 +25,9 @@ class JSONCLEAR extends RedisCommand
    {
        return 'JSON.CLEAR';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.del/
@@ -25,4 +25,9 @@ class JSONDEL extends RedisCommand
    {
        return 'JSON.DEL';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.forget/
@@ -25,4 +25,9 @@ class JSONFORGET extends RedisCommand
    {
        return 'JSON.FORGET';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;
 use Predis\Command\Traits\Json\Indent;
 use Predis\Command\Traits\Json\Newline;
 use Predis\Command\Traits\Json\Space;
@@ -54,4 +54,9 @@ class JSONGET extends RedisCommand
        $this->setIndent($arguments);
        $this->filterArguments();
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.merge/
@@ -26,4 +26,9 @@ class JSONMERGE extends RedisCommand
    {
        return 'JSON.MERGE';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 class JSONMGET extends RedisCommand
 {
@@ -33,4 +33,9 @@ class JSONMGET extends RedisCommand

        parent::setArguments($unpackedArguments);
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixSkippingLastArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.mset/
@@ -25,4 +25,15 @@ class JSONMSET extends RedisCommand
    {
        return 'JSON.MSET';
    }
+
+    public function prefixKeys($prefix)
+    {
+        if ($arguments = $this->getArguments()) {
+            for ($i = 0, $l = count($arguments); $i < $l; $i += 3) {
+                $arguments[$i] = $prefix . $arguments[$i];
+            }
+
+            $this->setArguments($arguments);
+        }
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.numincrby/
@@ -25,4 +25,9 @@ class JSONNUMINCRBY extends RedisCommand
    {
        return 'JSON.NUMINCRBY';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.objkeys/
@@ -25,4 +25,9 @@ class JSONOBJKEYS extends RedisCommand
    {
        return 'JSON.OBJKEYS';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.objlen/
@@ -25,4 +25,9 @@ class JSONOBJLEN extends RedisCommand
    {
        return 'JSON.OBJLEN';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.resp/
@@ -25,4 +25,9 @@ class JSONRESP extends RedisCommand
    {
        return 'JSON.RESP';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;
 use Predis\Command\Traits\Json\NxXxArgument;

 /**
@@ -38,4 +38,9 @@ class JSONSET extends RedisCommand
        $this->setSubcommand($arguments);
        $this->filterArguments();
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.strappend/
@@ -25,4 +25,9 @@ class JSONSTRAPPEND extends RedisCommand
    {
        return 'JSON.STRAPPEND';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.strlen/
@@ -25,4 +25,9 @@ class JSONSTRLEN extends RedisCommand
    {
        return 'JSON.STRLEN';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.toggle/
@@ -25,4 +25,9 @@ class JSONTOGGLE extends RedisCommand
    {
        return 'JSON.TOGGLE';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Json;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/json.type/
@@ -25,4 +25,9 @@ class JSONTYPE extends RedisCommand
    {
        return 'JSON.TYPE';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 class LMOVE extends RedisCommand
 {
@@ -20,4 +20,14 @@ class LMOVE extends RedisCommand
    {
        return 'LMOVE';
    }
+
+    public function prefixKeys($prefix)
+    {
+        if ($arguments = $this->getArguments()) {
+            $arguments[0] = $prefix . $arguments[0];
+            $arguments[1] = $prefix . $arguments[1];
+
+            $this->setRawArguments($arguments);
+        }
+    }
 }
@@ -0,0 +1,80 @@
+<?php
+
+/*
+ * This file is part of the Predis package.
+ *
+ * (c) 2009-2020 Daniele Alessandri
+ * (c) 2021-2025 Till Krüss
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Predis\Command\Redis;
+
+use Predis\Command\PrefixableCommand;
+use ValueError;
+
+class MSETEX extends PrefixableCommand
+{
+    /**
+     * {@inheritDoc}
+     */
+    public function getId()
+    {
+        return 'MSETEX';
+    }
+
+    public function setArguments(array $arguments)
+    {
+        $processedArguments = [count(array_keys($arguments[0]))];
+
+        array_walk($arguments[0], function ($value, $key) use (&$processedArguments) {
+            array_push($processedArguments, $key, $value);
+        });
+
+        if (isset($arguments[1])) {
+            if (!in_array(strtoupper($arguments[1]), ['NX', 'XX'])) {
+                throw new ValueError('Incorrect exist modifier. Should be one of: NX, XX.');
+            }
+
+            $processedArguments[] = strtoupper($arguments[1]);
+        }
+
+        if (isset($arguments[2])) {
+            if (!isset($arguments[3]) && strtoupper($arguments[2]) !== 'KEEPTTL') {
+                throw new ValueError('TTL should be specified along with expire resolution parameter');
+            }
+
+            if (!in_array(strtoupper($arguments[2]), ['EX', 'PX', 'EXAT', 'PXAT', 'KEEPTTL'])) {
+                throw new ValueError('Incorrect expire modifier. Should be one of: EX, PX, EXAT, PXAT, KEEPTTL');
+            }
+
+            if (strtoupper($arguments[2]) !== 'KEEPTTL') {
+                array_push($processedArguments, strtoupper($arguments[2]), $arguments[3]);
+            } else {
+                $processedArguments[] = strtoupper($arguments[2]);
+            }
+        }
+
+        parent::setArguments($processedArguments);
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public function prefixKeys($prefix)
+    {
+        $arguments = $this->getArguments();
+        $keysCount = $arguments[0];
+        $currentKeyIndex = 1;
+
+        while ($keysCount > 0) {
+            $arguments[$currentKeyIndex] = $prefix . $arguments[$currentKeyIndex];
+            $keysCount--;
+            $currentKeyIndex += 2;
+        }
+
+        parent::setRawArguments($arguments);
+    }
+}
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/smismember/
@@ -25,4 +25,9 @@ class SMISMEMBER extends RedisCommand
    {
        return 'SMISMEMBER';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Search;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/ft.aggregate/
@@ -50,4 +50,9 @@ class FTAGGREGATE extends RedisCommand
            $commandArguments
        ));
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Search;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/ft.aliasadd/
@@ -25,4 +25,9 @@ class FTALIASADD extends RedisCommand
    {
        return 'FT.ALIASADD';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForAllArguments($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Search;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/ft.aliasdel/
@@ -25,4 +25,9 @@ class FTALIASDEL extends RedisCommand
    {
        return 'FT.ALIASDEL';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Search;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/ft.aliasupdate/
@@ -26,4 +26,9 @@ class FTALIASUPDATE extends RedisCommand
    {
        return 'FT.ALIASUPDATE';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForAllArguments($prefix);
+    }
 }
@@ -13,7 +13,7 @@
 namespace Predis\Command\Redis\Search;

 use Predis\Command\Argument\Search\SchemaFields\FieldInterface;
-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 class FTALTER extends RedisCommand
 {
@@ -39,4 +39,9 @@ class FTALTER extends RedisCommand
            $schema
        ));
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -31,4 +31,20 @@ class FTCONFIG extends RedisCommand
    {
        return 'FT.CONFIG';
    }
+
+    public function parseResponse($data)
+    {
+        if (!is_array($data) || $data === array_values($data)) {
+            return $data;
+        }
+
+        // Relay
+        $result = [];
+        foreach ($data as $key => $value) {
+            $group = [$key, $value];
+            $result[] = $group;
+        }
+
+        return $result;
+    }
 }
@@ -13,7 +13,7 @@
 namespace Predis\Command\Redis\Search;

 use Predis\Command\Argument\Search\SchemaFields\FieldInterface;
-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/ft.create/
@@ -44,4 +44,9 @@ class FTCREATE extends RedisCommand
            $schema
        ));
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Search;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 class FTCURSOR extends RedisCommand
 {
@@ -31,4 +31,9 @@ class FTCURSOR extends RedisCommand
            $commandArguments
        ));
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Search;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/ft.dictadd/
@@ -25,4 +25,9 @@ class FTDICTADD extends RedisCommand
    {
        return 'FT.DICTADD';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Search;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/ft.dictdel/
@@ -25,4 +25,9 @@ class FTDICTDEL extends RedisCommand
    {
        return 'FT.DICTDEL';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Search;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/ft.dictdump/
@@ -25,4 +25,9 @@ class FTDICTDUMP extends RedisCommand
    {
        return 'FT.DICTDUMP';
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Search;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 class FTDROPINDEX extends RedisCommand
 {
@@ -35,4 +35,9 @@ class FTDROPINDEX extends RedisCommand
            $commandArguments
        ));
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
@@ -12,7 +12,7 @@

 namespace Predis\Command\Redis\Search;

-use Predis\Command\Command as RedisCommand;
+use Predis\Command\PrefixableCommand as RedisCommand;

 /**
 * @see https://redis.io/commands/ft.explain/
@@ -49,4 +49,9 @@ class FTEXPLAIN extends RedisCommand
            $commandArguments
        ));
    }
+
+    public function prefixKeys($prefix)
+    {
+        $this->applyPrefixForFirstArgument($prefix);
+    }
 }
--- a/Show More
+++ b/Show More
Author	SHA1	Message	Date
Till Krüss	153097374b	Prepare v3.3.0 release (#1612 )	2025-11-24 09:48:50 -08:00
Vladyslav Vildanov	6ef87493ca	Added testing with 8.4-GA (#1611 )	2025-11-19 08:30:39 -08:00
Vladyslav Vildanov	80430b4cde	Added new experimental CAS/CAD functionallity (#1609 ) * Added new CAS/CAD functionallity * Updated CHANGELOG.md * Codestyle fixes * Fixed version constraint * Marked feature as experimental * Updated version constraints, added missing annotations	2025-11-12 10:14:06 +02:00
Vladyslav Vildanov	d0f37f0bac	Added temporary XREADGROUP_CLAIM command (#1608 ) * Added temporary XREADGROUP_CLAIM command * Updated CHANGELOG.md * Added deprecation annotation	2025-11-12 09:14:57 +02:00
Vladyslav Vildanov	f11e855047	Added experimental support for FT.HYBRID (#1607 ) * Added basic structures and test coverage * Added most of the test coverage * Added more test coverage * Codestyle fixes * Fixed static analysis * ANother static analysis fix * Codestyle fixes * Fixed version constraints * Added missing annotations * Use class context * Added more test coverage * Codestyle fixes * Added experimental mentioning	2025-11-11 15:31:10 +02:00
Vladyslav Vildanov	ce853ecec2	Added support for MSET command (#1610 ) * Added support for MSET command * Codestyle fixes	2025-11-11 14:49:07 +02:00
Vladyslav Vildanov	f4dcf6ce57	Added testing with 8.4-RC1-pre.2 (#1605 ) * Added testing with 8.4-RC1-pre.2 * Updated CHANGELOG.md	2025-11-03 16:49:12 +02:00
Vladyslav Vildanov	72a95b3d75	Added testing with 8.4-RC1-pre image (#1602 ) * Added testing with 8.4-RC1-pre image * Updated CHANGELOG.md	2025-10-27 09:47:24 -07:00
Pavlo Yatsukhnenko	62f4ebcc37	Add AUTH command to Relay connection tests (#1601 )	2025-10-20 10:34:31 -07:00
Pavlo Yatsukhnenko	f26a13c8f4	Improve Relay compatibility (#1599 )	2025-10-20 07:52:40 -07:00
Till Krüss	44e4546ccd	add remaining `@group relay-fixme`	2025-10-17 13:09:13 -07:00
Pavlo Yatsukhnenko	da7b1cedb7	Improve Relay compatibility (#1597 )	2025-10-17 13:03:29 -07:00
Vladyslav Vildanov	fd1a0fc278	Added testing with 8.4-M01 (#1593 )	2025-10-17 10:42:36 -07:00
Vladyslav Vildanov	7a15da293b	Added prefixable interface for HEXPIRE, HEXPIRETIME (#1592 )	2025-10-17 10:27:44 -07:00
Viktor Szépe	d9dfefd247	Fix typos (#1579 )	2025-10-03 16:22:43 -07:00
Vladyslav Vildanov	8a0c70baa5	Added testing with 8.2.1-pre (#1588 )	2025-08-15 09:13:51 -07:00
Vladyslav Vildanov	053cb4b6ac	Refactor pipeline data writing depends on connection type (#1586 ) * Refactor pipeline data writing depends on connection type * Updated CHANGELOG.md	2025-08-13 09:59:39 +03:00
Róbert Kelčák	0f4bc7653c	Fix stream commands cluster support (#1587 ) * Fix stream commands cluster support * Update CHANGELOG.md	2025-08-12 13:33:48 +03:00
Vladyslav Vildanov	9e9deec4df	Tag v3.2.0 (#1585 ) * Tag v3.2.0 * Updated 8.2 test image	2025-08-06 09:41:24 +03:00
Vladyslav Vildanov	c1845d96cc	Added test coverage for updated Vamana (#1584 ) * Added test coverage for updated Vamana * Updated CHANGELOG.md * Increased timeouts * Removed assertion cause Relay removes total field * Added realy-resp3 group * Revert assertions	2025-08-03 22:20:07 +03:00
Elena Kolevska	8f18de1c12	Updates 8.2 test image to rc2 (#1583 )	2025-08-01 12:42:25 -07:00
Hristo Temelski	6d37dc45b0	Added new stream commands, extended existing ones (#1580 ) * Added new stream commands, extended existing ones * updated the changelog * fixed linter errors * fixed regressions * more linter fixes * XADD fix * lint fix * Update CHANGELOG.md * update interfaces, address PR comments * fixed linter errors * fixed xdelex return type * updated new command signatures --------- Co-authored-by: Till Krüss <tillkruss@users.noreply.github.com>	2025-07-29 12:59:06 +03:00
Vladyslav Vildanov	1c96f704fc	Added missing VSIM argument (#1582 ) * Added missing VSIM argument * Updated CHANGELOG.md	2025-07-28 15:57:35 +03:00
Till Krüss	b10cf7c96a	back to dev version	2025-07-22 08:38:59 -07:00
Till Krüss	202e0c5322	bump version	2025-07-22 08:37:44 -07:00
Till Krüss	6387da61d4	bump dev version	2025-07-22 08:33:40 -07:00
Till Krüss	97bce0062d	cleanup changelog	2025-07-22 08:31:37 -07:00
Till Krüss	fe1ea1b8f9	tag v3.0.2	2025-07-22 08:30:03 -07:00
Hristo Temelski	302b63b742	Added test to ensure ftcreate vamana compatibility (#1578 ) * Added test to ensure ftcreate vamana compatibility * updated changelog	2025-07-21 09:48:12 -07:00
ridgey-dev	8e7afbe679	Retry all exceptions from Sentinel replicas (#1577 ) * Retry SentinelReplication::retryCommandOnFailure on all classes with Throwable interface * Retry SentinelReplication::retryCommandOnFailure on all classes with Throwable interface * Fix coding style	2025-07-18 09:21:40 +03:00
Vladyslav Vildanov	c60003a717	Marked missing commands as Prefixable (#1576 ) * Marked missing commands as Prefixable * Codestyle fixes * Updated CHANGELOG.md	2025-07-09 19:03:22 +03:00
Vladyslav Vildanov	4dcc66f47e	Updated Redis 8.2 test image (#1573 ) * Updated Redis 8.2 test image * Updated CHANGELOG.md	2025-07-03 16:53:00 +03:00
Hristo Temelski	e0a03c6590	BITOP added operation validation (#1566 ) * BITOP added operation validation * Ensure that the arguments are not an empty list before doing operation check * Updated changelog, fixed linter errors * added test for the new bitop operations * fixed liniting * update requiresRedisVersion --------- Co-authored-by: Vladyslav Vildanov <117659936+vladvildanov@users.noreply.github.com>	2025-06-21 11:03:17 +03:00
Vladyslav Vildanov	5e59123f0a	Added testing with 8.2 (#1567 ) * Added testing with 8.2 * Updated CHANGELOG.md * Updated conditions for Relay stack tests * Removed redundat condition * Removed stack port overriding	2025-06-20 18:39:26 +03:00
alschastny	7509e5f42d	XINFO command parse response changes + more tests (#1560 ) Co-authored-by: alschastny <>	2025-06-19 10:32:39 +03:00
Till Krüss	efc2c3798c	Update CODEOWNERS (#1564 )	2025-06-17 07:00:17 -07:00
alschastny	ec375afa4a	fix XREAD parse null response (#1563 ) Co-authored-by: aleksanders <alexander.s@seranking.com>	2025-06-17 10:39:31 +03:00
Vladyslav Vildanov	9992595711	Updated Redis 8.0 test image (#1562 ) * Updated Redis 8.0 test image * Updated CHANGELOG.md * Updated version restriction * Marked test as relay-incompatible	2025-06-16 09:42:56 -07:00
alschastny	33e1174a4f	implement XSETID command (#1559 ) * implement XSETID command * modify CHANGELOG.md * split test to basic and extended version --------- Co-authored-by: aleksanders <alexander.s@seranking.com>	2025-06-16 10:11:51 +03:00
alschastny	1e390b1814	implement XPENDING command (#1558 ) * implement XPENDING command * modify CHANGELOG.md --------- Co-authored-by: aleksanders <alexander.s@seranking.com> Co-authored-by: Vladyslav Vildanov <117659936+vladvildanov@users.noreply.github.com>	2025-06-13 10:34:52 +03:00
alschastny	0a8fe54b44	implement XCLAIM command (#1557 ) * implement XCLAIM command * modify CHANGELOG.md * add empty line before return * test xclaim with all available options * review refactoring * remove fast-track check for empty answer --------- Co-authored-by: aleksanders <alexander.s@seranking.com>	2025-06-13 10:07:44 +03:00
alschastny	b5b486a254	add XACK command (#1555 ) * add XACK command * add XACK to ClientContextInterface * modify CHANGELOG.md --------- Co-authored-by: aleksanders <alexander.s@seranking.com> Co-authored-by: Vladyslav Vildanov <117659936+vladvildanov@users.noreply.github.com>	2025-06-11 09:28:13 -07:00
Vladyslav Vildanov	5e18e91ffc	fix(commands): Fixed wrong command API call on prefix processing (#1554 ) * fix(commands): Fixed wrong command API call on prefix processing * Updated CHANGELOG.md * Updated test case	2025-06-11 10:46:25 +03:00
Vladyslav Vildanov	c2b95dfd2a	Backport #1551 (#1552 ) * fix(conn): Removed automatic conn_uid assignment (#1551) * fix(conn): Removed automatic conn_uid assignment * Restrict redis version * Updated CHANGELOG.md * Added test case * Update CHANGELOG.md --------- Co-authored-by: Till Krüss <tillkruss@users.noreply.github.com> * Removed duplicated disconnect * Updated CHANGELOg.md --------- Co-authored-by: Till Krüss <tillkruss@users.noreply.github.com>	2025-06-05 18:34:21 +03:00
Vladyslav Vildanov	30e48f566e	feat(commands): Add support for VectorSet commands (#1550 ) * feat(commands): Add support for VectorSet commands * Codestyle fixes * Fixed test * Added logging for test purposes * Marked tests as relay incompatible * Missing incompatible tests * Updated CHANGELOG to reflect experimental nature of feature * Marked properties as nullable * Changed static variables to constants * Codestyle fixe * Revert changes * Update CHANGELOG.md --------- Co-authored-by: Till Krüss <tillkruss@users.noreply.github.com>	2025-06-05 09:28:31 +03:00
Vladyslav Vildanov	d7f60099a6	fix(stream): Fixed throwing `CommunicationException` when stream is EOF (#1548 ) * fix(stream): Fixed return type to match function signature * Updated CHANGELOG.md * Fix syntax error * Updated CHANGELOG.md entry	2025-05-30 10:26:17 +03:00
Mustafa AKBEL	6021daf9cd	Treat LOADING Errors as Connection Failures to Retry with Next Replica (#1536 ) * fix(sentinel-replication): Treat LOADING error responses as ConnectionException to allow retry mechanism to discard the current replica and switch to the next available one. * fix(sentinel-replication): add changelog entries for LOADING response handling * Update CHANGELOG.md * Update CHANGELOG.md --------- Co-authored-by: Mustafa AKBEL <mustafa.akbel@pusula.net.tr> Co-authored-by: Till Krüss <tillkruss@users.noreply.github.com>	2025-05-28 15:11:13 +03:00
Till Krüss	2372b5c767	Update CHANGELOG.md	2025-05-27 09:55:23 -07:00
Vladyslav Vildanov	87e08a3709	Backport #1546 (#1547 ) * Fix return type for ZCOUNT (#1546) * Fix return type for ZCOUNT ZCOUNT returns an `int`: > Integer reply: the number of members in the specified score range. * Update CHANGELOG.md --------- Co-authored-by: Till Krüss <tillkruss@users.noreply.github.com> * Added changelog entry --------- Co-authored-by: Tim Düsterhus <timwolla@googlemail.com> Co-authored-by: Till Krüss <tillkruss@users.noreply.github.com>	2025-05-27 09:54:46 -07:00
Vladyslav Vildanov	421827625e	Backport #1503 (#1545 ) * Backport #1503 * Update CHANGELOG.md --------- Co-authored-by: Till Krüss <tillkruss@users.noreply.github.com>	2025-05-27 10:17:35 +03:00
Till Krüss	afa8b55aa3	bump dev version	2025-05-16 11:33:03 -07:00
@@ -1 +1 @@
 .0.1
 .3.0