fix GET

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

@@ -1,46 +1,46 @@
 import { strict as assert } from 'assert';
 import testUtils, { GLOBAL } from '../test-utils';
-import { transformArguments } from './GET';
+import GET from './GET';
 
 describe('GET', () => {
-    describe('transformArguments', () => {
+  describe('transformArguments', () => {
-        it('without options', () => {
+    it('without options', () => {
-            assert.deepEqual(
+      assert.deepEqual(
-                transformArguments('key'),
+        GET.transformArguments('key'),
-                ['TS.GET', 'key']
+        ['TS.GET', 'key']
-            );
+      );
-        });
-
-        it('with LATEST', () => {
-            assert.deepEqual(
-                transformArguments('key', {
-                    LATEST: true
-                }),
-                ['TS.GET', 'key', 'LATEST']
-            );
-        });
     });
 
-    describe('client.ts.get', () => {
+    it('with LATEST', () => {
-        testUtils.testWithClient('null', async client => {
+      assert.deepEqual(
-            await client.ts.create('key');
+        GET.transformArguments('key', {
-
+          LATEST: true
-            assert.equal(
+        }),
-                await client.ts.get('key'),
+        ['TS.GET', 'key', 'LATEST']
-                null
+      );
-            );
-        }, GLOBAL.SERVERS.OPEN);
-
-        testUtils.testWithClient('with samples', async client => {
-            await client.ts.add('key', 0, 1);
-
-            assert.deepEqual(
-                await client.ts.get('key'),
-                {
-                    timestamp: 0,
-                    value: 1
-                }
-            );
-        }, GLOBAL.SERVERS.OPEN);
     });
+  });
+
+  describe('client.ts.get', () => {
+    testUtils.testWithClient('null', async client => {
+      await client.ts.create('key');
+
+      assert.equal(
+        await client.ts.get('key'),
+        null
+      );
+    }, GLOBAL.SERVERS.OPEN);
+
+    testUtils.testWithClient('with samples', async client => {
+      await client.ts.add('key', 0, 1);
+
+      assert.deepEqual(
+        await client.ts.get('key'),
+        {
+          timestamp: 0,
+          value: 1
+        }
+      );
+    }, GLOBAL.SERVERS.OPEN);
+  });
 });

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

@@ -1,20 +1,30 @@
-import { RedisCommandArguments } from '@redis/client/dist/lib/commands';
+import { RedisArgument, TuplesReply, NumberReply, DoubleReply, Resp2Reply, Command } from '@redis/client/dist/lib/RESP/types';
-import { pushLatestArgument, SampleRawReply, SampleReply, transformSampleReply } from '.';
+import { pushLatestArgument } from '.';
 
-export const FIRST_KEY_INDEX = 1;
+export interface TsGetOptions {
-
+  LATEST?: boolean;
-export const IS_READ_ONLY = true;
-
-interface GetOptions {
-    LATEST?: boolean;
 }
 
-export function transformArguments(key: string, options?: GetOptions): RedisCommandArguments {
+export type TsGetReply = TuplesReply<[]> | TuplesReply<[NumberReply, DoubleReply]>;
+
+export default {
+  FIRST_KEY_INDEX: 1,
+  IS_READ_ONLY: true,
+  transformArguments(key: RedisArgument, options?: TsGetOptions) {
     return pushLatestArgument(['TS.GET', key], options?.LATEST);
-}
+  },
-
+  transformReply: {
-export function transformReply(reply: [] | SampleRawReply): null | SampleReply {
+    2(reply: Resp2Reply<TsGetReply>) {
-    if (reply.length === 0) return null;
+      return reply.length === 0 ? null : {
-
+        timestamp: reply[0],
-    return transformSampleReply(reply);
+        value: Number(reply[1])
-}
+      };
+    },
+    3(reply: TsGetReply) {
+      return reply.length === 0 ? null : {
+        timestamp: reply[0],
+        value: reply[1]
+      };
+    }
+  }
+} as const satisfies Command;