XINFO CONSUMERS - add support for the inactive field (#2490)

* Support XINFO CONSUMERS: Added the inactive field * Update XINFO_CONSUMERS.ts --------- Co-authored-by: Leibale Eidelman <me@leibale.com>
redis · May 21, 2023 · d4f1943 · d4f1943
1 parent 8d37c11
commit d4f1943
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 5 deletions.
diff --git a/packages/client/lib/commands/XINFO_CONSUMERS.spec.ts b/packages/client/lib/commands/XINFO_CONSUMERS.spec.ts
@@ -13,17 +13,19 @@ describe('XINFO CONSUMERS', () => {
     it('transformReply', () => {
         assert.deepEqual(
             transformReply([
-                ['name', 'Alice', 'pending', 1, 'idle', 9104628],
-                ['name', 'Bob', 'pending', 1, 'idle', 83841983]
+                ['name', 'Alice', 'pending', 1, 'idle', 9104628, 'inactive', 9281221],
+                ['name', 'Bob', 'pending', 1, 'idle', 83841983, 'inactive', 7213871]
             ]),
             [{
                 name: 'Alice',
                 pending: 1,
-                idle: 9104628
+                idle: 9104628,
+                inactive: 9281221,
             }, {
                 name: 'Bob',
                 pending: 1,
-                idle: 83841983
+                idle: 83841983,
+                inactive: 7213871,
             }]
         );
     });

diff --git a/packages/client/lib/commands/XINFO_CONSUMERS.ts b/packages/client/lib/commands/XINFO_CONSUMERS.ts
@@ -15,12 +15,14 @@ type XInfoConsumersReply = Array<{
     name: RedisCommandArgument;
     pending: number;
     idle: number;
+    inactive: number;
 }>;
 
 export function transformReply(rawReply: Array<any>): XInfoConsumersReply {
     return rawReply.map(consumer => ({
         name: consumer[1],
         pending: consumer[3],
-        idle: consumer[5]
+        idle: consumer[5],
+        inactive: consumer[7]
     }));
 }