fix time series

Author: sjpotter

packages/time-series/lib/commands/INFO.ts

@@ -1,6 +1,7 @@
-import { BlobStringReply, Command, NumberReply, SimpleStringReply } from "@redis/client/dist/lib/RESP/types";
+import { BlobStringReply, Command, DoubleReply, NumberReply, SimpleStringReply, TypeMapping } from "@redis/client/dist/lib/RESP/types";
 import { TimeSeriesDuplicatePolicies } from ".";
 import { TimeSeriesAggregationType } from "./CREATERULE";
+import { transformDoubleReply } from '@redis/client/dist/lib/commands/generic-transformers';
 
 export type InfoRawReply = [
   'totalSamples',
@@ -26,7 +27,11 @@ export type InfoRawReply = [
   'sourceKey',
   BlobStringReply | null,
   'rules',
-  Array<[key: BlobStringReply, timeBucket: NumberReply, aggregationType: TimeSeriesAggregationType]>
+  Array<[key: BlobStringReply, timeBucket: NumberReply, aggregationType: TimeSeriesAggregationType]>,
+  'ignoreMaxTimeDiff',
+  NumberReply,
+  'ignoreMaxValDiff',
+  DoubleReply,
 ];
 
 export interface InfoReply {
@@ -49,6 +54,8 @@ export interface InfoReply {
     timeBucket: NumberReply;
     aggregationType: TimeSeriesAggregationType
   }>;
+  ignoreMaxTimeDiff: NumberReply;
+  ignoreMaxValDiff: DoubleReply;
 }
 
 export default {
@@ -58,7 +65,7 @@ export default {
       return ['TS.INFO', key];
     },
     transformReply: {
-      2: (reply: InfoRawReply): InfoReply => {
+      2: (reply: InfoRawReply, _, typeMapping?: TypeMapping): InfoReply => {
         return {
           totalSamples: reply[1],
           memoryUsage: reply[3],
@@ -78,7 +85,9 @@ export default {
             key,
             timeBucket,
             aggregationType
-          }))
+          })),
+          ignoreMaxTimeDiff: reply[25],
+          ignoreMaxValDiff: transformDoubleReply[2](reply[27] as unknown as BlobStringReply, undefined, typeMapping)
         };
       },
       3: undefined as unknown as () => InfoReply

packages/time-series/lib/commands/INFO_DEBUG.spec.ts

@@ -25,7 +25,7 @@ describe('TS.INFO_DEBUG', () => {
         ]);
 
         const infoDebug = await client.ts.infoDebug('key');
-        assertInfo(infoDebug);
+        assertInfo(infoDebug as any);
         assert.equal(typeof infoDebug.keySelfName, 'string');
         assert.ok(Array.isArray(infoDebug.chunks));
         for (const chunk of infoDebug.chunks) {

packages/time-series/lib/commands/INFO_DEBUG.ts

@@ -1,4 +1,4 @@
-import { BlobStringReply, Command, NumberReply, SimpleStringReply } from "@redis/client/dist/lib/RESP/types";
+import { BlobStringReply, Command, NumberReply, SimpleStringReply, TypeMapping } from "@redis/client/dist/lib/RESP/types";
 import INFO, { InfoRawReply, InfoReply } from "./INFO";
 
 type InfoDebugRawReply = [
@@ -40,17 +40,17 @@ export default {
 		return args;
   },
   transformReply: {
-    2: (rawReply: InfoDebugRawReply): InfoDebugReply => {
-  		const reply = INFO.transformReply[2](rawReply as unknown as InfoRawReply);
-	  	(reply as InfoDebugReply).keySelfName = rawReply[25];
-		  (reply as InfoDebugReply).chunks = rawReply[27].map(chunk => ({
-			  startTimestamp: chunk[1],
-  			endTimestamp: chunk[3],
-	  		samples: chunk[5],
-		    size: chunk[7],
-		    bytesPerSample: chunk[9]
-		  }));
-		  return reply as InfoDebugReply;
+    2: (rawReply: InfoDebugRawReply, _, typeMapping?: TypeMapping): InfoDebugReply => {
+      const reply = INFO.transformReply[2](rawReply as unknown as InfoRawReply, _, typeMapping);
+      (reply as InfoDebugReply).keySelfName = rawReply[29];
+      (reply as InfoDebugReply).chunks = rawReply[31].map(chunk => ({
+        startTimestamp: chunk[1],
+        endTimestamp: chunk[3],
+        samples: chunk[5],
+        size: chunk[7],
+        bytesPerSample: chunk[9]
+      }));
+      return reply as InfoDebugReply;
 		},
     3: undefined as unknown as () => InfoDebugReply
   }

packages/time-series/lib/commands/index.ts

@@ -1,4 +1,4 @@
-import type { CommandArguments, DoubleReply, NumberReply, RedisArgument, RedisCommands, TuplesReply, UnwrapReply, Resp2Reply, ArrayReply, BlobStringReply, MapReply, NullReply, TypeMapping, ReplyUnion, RespType } from '@redis/client/dist/lib/RESP/types';
+import type { DoubleReply, NumberReply, RedisArgument, RedisCommands, TuplesReply, UnwrapReply, Resp2Reply, ArrayReply, BlobStringReply, MapReply, NullReply, TypeMapping, ReplyUnion, RespType } from '@redis/client/dist/lib/RESP/types';
 import ADD from './ADD';
 import ALTER from './ALTER';
 import CREATE from './CREATE';
@@ -29,8 +29,8 @@ import MREVRANGE from './MREVRANGE';
 import QUERYINDEX from './QUERYINDEX';
 import RANGE from './RANGE';
 import REVRANGE from './REVRANGE';
-import { RedisVariadicArgument, pushVariadicArguments } from '@redis/client/dist/lib/commands/generic-transformers';
-import { RESP_TYPES } from '@redis/client';
+import { RedisVariadicArgument, pushVariadicArguments } from '@redis/client/lib/commands/generic-transformers';
+import { RESP_TYPES } from '@redis/client/lib/RESP/decoder';
 
 export default {
   ADD,

packages/time-series/lib/index.ts

@@ -1,6 +1,3 @@
-import { RESP_TYPES } from '@redis/client';
-import { ArrayReply, BlobStringReply, MapReply, NullReply, TuplesReply, TypeMapping, UnwrapReply } from '@redis/client/dist/lib/RESP/types';
-
 export {
   default,
   TIME_SERIES_ENCODING, TimeSeriesEncoding,