DX-2446: expose TData generic on xrange and xrevrange (#1414)

* feat: expose TData generic on xrange and xrevrange

* fix: lint

* fix: add sleep before xclaim to satisfy min-idle-time in CI

* fix: simplify xrange/xrevrange generic

Author: CahidArda

pkg/commands/xclaim.test.ts

@@ -30,6 +30,9 @@ describe("XCLAIM", () => {
 
     await new XReadGroupCommand([group, consumer3, [streamKey], [">"], { count: 1 }]).exec(client);
 
+    // XCLAIM requires the message to have been idle for at least min-idle-time (100ms)
+    await new Promise((r) => setTimeout(r, 150));
+
     const res = (await new XClaimCommand([streamKey, group, consumer3, 100, streamId2]).exec(
       client
     )) as string[];

pkg/pipeline.ts

@@ -1302,14 +1302,15 @@ export class Pipeline<TCommands extends Command<any, any>[] = []> {
   /**
    * @see https://redis.io/commands/xrange
    */
-  xrange = (...args: CommandArgs<typeof XRangeCommand>) =>
-    this.chain(new XRangeCommand(args, this.commandOptions));
+  xrange = <TData extends Record<string, unknown>>(...args: CommandArgs<typeof XRangeCommand>) =>
+    this.chain(new XRangeCommand<Record<string, TData>>(args, this.commandOptions));
 
   /**
    * @see https://redis.io/commands/xrevrange
    */
-  xrevrange = (...args: CommandArgs<typeof XRevRangeCommand>) =>
-    this.chain(new XRevRangeCommand(args, this.commandOptions));
+  xrevrange = <TData extends Record<string, unknown>>(
+    ...args: CommandArgs<typeof XRevRangeCommand>
+  ) => this.chain(new XRevRangeCommand<Record<string, TData>>(args, this.commandOptions));
 
   /**
    * @see https://redis.io/commands/zcard

pkg/redis.ts

@@ -1471,14 +1471,15 @@ export class Redis {
   /**
    * @see https://redis.io/commands/xrange
    */
-  xrange = (...args: CommandArgs<typeof XRangeCommand>) =>
-    new XRangeCommand(args, this.opts).exec(this.client);
+  xrange = <TData extends Record<string, unknown>>(...args: CommandArgs<typeof XRangeCommand>) =>
+    new XRangeCommand<Record<string, TData>>(args, this.opts).exec(this.client);
 
   /**
    * @see https://redis.io/commands/xrevrange
    */
-  xrevrange = (...args: CommandArgs<typeof XRevRangeCommand>) =>
-    new XRevRangeCommand(args, this.opts).exec(this.client);
+  xrevrange = <TData extends Record<string, unknown>>(
+    ...args: CommandArgs<typeof XRevRangeCommand>
+  ) => new XRevRangeCommand<Record<string, TData>>(args, this.opts).exec(this.client);
 
   /**
    * @see https://redis.io/commands/zadd