feat(command): add zadd zrem zrangewithscores

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@litert/redis",
-  "version": "3.0.1",
+  "version": "3.0.2",
   "description": "A redis protocol implement for Node.js.",
   "main": "./lib/index.js",
   "scripts": {

src/lib/Commands.ts

@@ -2085,6 +2085,79 @@ export const COMMANDS: Record<keyof C.ICommandAPIs, ICommand> = {
         }
     },
 
+    /**
+     * Command: zRem
+     * @see https://redis.io/commands/zRem
+     */
+    'zRem': {
+        prepare: createDefaultPreparer('ZREM')
+    },
+
+    /**
+     * Command: zAdd
+     * @see https://redis.io/commands/zAdd
+     */
+    'zAdd': {
+        prepare: createDefaultPreparer('ZADD'),
+        process: isIntegerOne
+    },
+
+    /**
+     * Command: zRange
+     * @see https://redis.io/commands/zRange
+     */
+    'zRangeWithScores': {
+        prepare: (key: string, start: number, stop: number) => {
+
+            return {
+                'cmd': 'ZRANGE',
+                'args': [key, start, stop, 'WITHSCORES']
+            };
+        },
+        process: (items: Array<[number, Buffer]>): Array<{ member: string; score: number; }> => {
+
+            const ret: Array<{ member: string; score: number; }> = [];
+
+            for (let i = 0 ; i < items.length; i = i + 2) {
+
+                ret.push({
+                    'member': items[i][1].toString(),
+                    'score': parseFloat(items[i + 1][1].toString())
+                });
+            }
+
+            return ret;
+        }
+    },
+
+    /**
+     * Command: zRange
+     * @see https://redis.io/commands/zRange
+     */
+    'zRangeWithScores$': {
+        prepare: (key: string, start: number, stop: number) => {
+
+            return {
+                'cmd': 'ZRANGE',
+                'args': [key, start, stop, 'WITHSCORES']
+            };
+        },
+        process: (items: Array<[number, Buffer]>): Array<{ member: Buffer; score: number; }> => {
+
+            const ret: Array<{ member: Buffer; score: number; }> = [];
+
+            for (let i = 0 ; i < items.length; i = i + 2) {
+
+                ret.push({
+                    'member': items[i][1],
+                    'score': parseFloat(items[i + 1][1].toString())
+                });
+            }
+
+            return ret;
+        }
+    },
+
     /**
      * Command: pfAdd
      * @see https://redis.io/commands/pfAdd

src/lib/Common.ts

@@ -1221,6 +1221,30 @@ export interface ICommandAPIs {
      */
     rPushX(key: string, values: Array<string | Buffer>): Promise<number>;
 
+    /**
+     * Command: zAdd
+     * @see https://redis.io/commands/zAdd
+     */
+    zAdd(key: string, member: string, score: string | Buffer): Promise<boolean>;
+
+    /**
+     * Command: zRem
+     * @see https://redis.io/commands/zRem
+     */
+    zRem(key: string, members: Array<string | Buffer>): Promise<number>;
+
+    /**
+     * Command: zRange
+     * @see https://redis.io/commands/zRange
+     */
+    zRangeWithScores(key: string, start: number, stop: number): Promise<Array<{ member: string; score: number; }>>;
+
+    /**
+     * Command: zRange
+     * @see https://redis.io/commands/zRange
+     */
+    zRangeWithScores$(key: string, start: number, stop: number): Promise<Array<{ member: Buffer; score: number; }>>;
+
     /**
      * Command: pfAdd
      * @see https://redis.io/commands/pfAdd