From d4f194352f52f545e5e5747b9b7a14fa05db2688 Mon Sep 17 00:00:00 2001
From: Codrin-Mihai Chira <122961778+codrin-ch@users.noreply.github.com>
Date: Sun, 21 May 2023 15:06:46 +0300
Subject: [PATCH] `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>
---
 packages/client/lib/commands/XINFO_CONSUMERS.spec.ts | 10 ++++++----
 packages/client/lib/commands/XINFO_CONSUMERS.ts      |  4 +++-
 2 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/packages/client/lib/commands/XINFO_CONSUMERS.spec.ts b/packages/client/lib/commands/XINFO_CONSUMERS.spec.ts
index 87c82b34f2..a2c5899977 100644
--- 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
index 05e3a26b17..9b3893cc93 100644
--- 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]
     }));
 }