Add missing stream key prefixes (#1230)

jessarcher · web-flow · commit 98d4f802636e · 2023-03-29T07:03:45.000-07:00
* Added missing stream key prefixes

* Tested stream command key prefixing
diff --git a/src/Command/Processor/KeyPrefixProcessor.php b/src/Command/Processor/KeyPrefixProcessor.php
@@ -181,9 +181,11 @@ public function __construct($prefix)
             /* ---------------- Redis 5.0 ---------------- */
             'XADD' => $prefixFirst,
             'XRANGE' => $prefixFirst,
+            'XREVRANGE' => $prefixFirst,
             'XDEL' => $prefixFirst,
             'XLEN' => $prefixFirst,
             'XACK' => $prefixFirst,
+            'XTRIM' => $prefixFirst,
         ];
     }
 
diff --git a/tests/Predis/Command/Processor/KeyPrefixProcessorTest.php b/tests/Predis/Command/Processor/KeyPrefixProcessorTest.php
@@ -944,6 +944,35 @@ public function commandArgumentsDataProvider(): array
                 ['key', 'member', '100', 'km', 'WITHDIST', 'STORE', 'key:store', 'STOREDIST', 'key:storedist'],
                 ['prefix:key', 'member', '100', 'km', 'WITHDIST', 'STORE', 'prefix:key:store', 'STOREDIST', 'prefix:key:storedist'],
             ],
+            /* ---------------- Redis 5.0 ---------------- */
+            ['XADD',
+                ['key', '*', ['field' => 'value']],
+                ['prefix:key', '*', ['field' => 'value']],
+            ],
+            ['XRANGE',
+                ['key', '-', '+'],
+                ['prefix:key', '-', '+'],
+            ],
+            ['XREVRANGE',
+                ['key', '+', '-'],
+                ['prefix:key', '+', '-'],
+            ],
+            ['XDEL',
+                ['key', 'id'],
+                ['prefix:key', 'id'],
+            ],
+            ['XLEN',
+                ['key'],
+                ['prefix:key'],
+            ],
+            ['XACK',
+                ['key', 'group', 'id'],
+                ['prefix:key', 'group', 'id'],
+            ],
+            ['XTRIM',
+                ['key', 'MAXLEN', 100],
+                ['prefix:key', 'MAXLEN', 100],
+            ],
         ];
     }
 }
