fix(client): XAUTOCLAIM after a TRIM returns nil

redis · Jul 10, 2023 · 0d8d05e · 0d8d05e
1 parent a7d5bc7
commit 0d8d05e
Show file tree

Hide file tree

Showing 2 changed files with 37 additions and 24 deletions.
diff --git a/packages/client/lib/commands/generic-transformers.spec.ts b/packages/client/lib/commands/generic-transformers.spec.ts
@@ -194,30 +194,39 @@ describe('Generic Transformers', () => {
         );
     });
 
-    it('transformStreamMessagesReply', () => {
-        assert.deepEqual(
-            transformStreamMessagesReply([['0-0', ['0key', '0value']], ['1-0', ['1key', '1value']]]),
-            [{
-                id: '0-0',
-                message: Object.create(null, {
-                    '0key': {
-                        value: '0value',
-                        configurable: true,
-                        enumerable: true
-                    }
-                })
-            }, {
-                id: '1-0',
-                message: Object.create(null, {
-                    '1key': {
-                        value: '1value',
-                        configurable: true,
-                        enumerable: true
-                    }
-                })
-            }]
-        );
-    });
+    describe('transformStreamMessagesReply', () => {
+        it('with null', () => {
+            assert.deepEqual(
+                transformStreamMessagesReply([null]),
+                []
+            );
+        })
+
+        it('with messages', () => {
+            assert.deepEqual(
+                transformStreamMessagesReply([['0-0', ['0key', '0value']], ['1-0', ['1key', '1value']]]),
+                [{
+                    id: '0-0',
+                    message: Object.create(null, {
+                        '0key': {
+                            value: '0value',
+                            configurable: true,
+                            enumerable: true
+                        }
+                    })
+                }, {
+                    id: '1-0',
+                    message: Object.create(null, {
+                        '1key': {
+                            value: '1value',
+                            configurable: true,
+                            enumerable: true
+                        }
+                    })
+                }]
+            );
+        })
+    })
 
     describe('transformStreamsMessagesReply', () => {
         it('null', () => {

diff --git a/packages/client/lib/commands/generic-transformers.ts b/packages/client/lib/commands/generic-transformers.ts
@@ -97,6 +97,10 @@ export type StreamMessagesReply = Array<StreamMessageReply>;
 export function transformStreamMessagesReply(reply: Array<any>): StreamMessagesReply {
     const messages = [];
 
+    if (reply[0] === null) {
+        return messages;
+    }
+
     for (const [id, message] of reply) {
         messages.push({
             id,