Added lMove, lMove$, bLMove, bLMove$ methods.

Author: yunbookf

src/lib/Commands.ts

@@ -2085,6 +2085,64 @@ export const COMMANDS: Record<keyof C.ICommandAPIs, ICommand> = {
         }
     },
 
+    /**
+     * Command: lMove
+     * @see https://redis.io/docs/latest/commands/lmove
+     */
+    'lMove': {
+        prepare(srcKey: string, destKey: string, srcDir: 'LEFT' | 'RIGHT', destDir: 'LEFT' | 'RIGHT'): IPrepareResult {
+
+            return {
+                cmd: 'LMOVE',
+                args: [srcKey, destKey, srcDir, destDir]
+            };
+        },
+        process: U.nullableBuffer2String
+    },
+
+    /**
+     * Command: lMove
+     * @see https://redis.io/docs/latest/commands/lmove
+     */
+    'lMove$': {
+        prepare(srcKey: string, destKey: string, srcDir: 'LEFT' | 'RIGHT', destDir: 'LEFT' | 'RIGHT'): IPrepareResult {
+
+            return {
+                cmd: 'LMOVE',
+                args: [srcKey, destKey, srcDir, destDir]
+            };
+        }
+    },
+
+    /**
+     * Command: bLMove
+     * @see https://redis.io/docs/latest/commands/blmove
+     */
+    'bLMove': {
+        prepare(srcKey: string, destKey: string, srcDir: 'LEFT' | 'RIGHT', destDir: 'LEFT' | 'RIGHT', timeout: number): IPrepareResult {
+
+            return {
+                cmd: 'BLMOVE',
+                args: [srcKey, destKey, srcDir, destDir, timeout]
+            };
+        },
+        process: U.nullableBuffer2String
+    },
+
+    /**
+     * Command: bLMove
+     * @see https://redis.io/docs/latest/commands/blmove
+     */
+    'bLMove$': {
+        prepare(srcKey: string, destKey: string, srcDir: 'LEFT' | 'RIGHT', destDir: 'LEFT' | 'RIGHT', timeout: number): IPrepareResult {
+
+            return {
+                cmd: 'BLMOVE',
+                args: [srcKey, destKey, srcDir, destDir, timeout]
+            };
+        }
+    },
+
     /**
      * Command: zRem
      * @see https://redis.io/docs/latest/commands/zrem

src/lib/Common.ts

@@ -1221,6 +1221,30 @@ export interface ICommandAPIs {
      */
     rPushX(key: string, values: Array<string | Buffer>): Promise<number>;
 
+    /**
+     * Command: lMove
+     * @see https://redis.io/docs/latest/commands/lmove
+     */
+    lMove(srcKey: string, destKey: string, srcDir: 'LEFT' | 'RIGHT', destDir: 'LEFT' | 'RIGHT'): Promise<string | null>;
+
+    /**
+     * Command: lMove
+     * @see https://redis.io/docs/latest/commands/lmove
+     */
+    lMove$(srcKey: string, destKey: string, srcDir: 'LEFT' | 'RIGHT', destDir: 'LEFT' | 'RIGHT'): Promise<Buffer | null>;
+
+    /**
+     * Command: bLMove
+     * @see https://redis.io/docs/latest/commands/blmove
+     */
+    bLMove(srcKey: string, destKey: string, srcDir: 'LEFT' | 'RIGHT', destDir: 'LEFT' | 'RIGHT', timeout: number): Promise<string | null>;
+
+    /**
+     * Command: bLMove
+     * @see https://redis.io/docs/latest/commands/blmove
+     */
+    bLMove$(srcKey: string, destKey: string, srcDir: 'LEFT' | 'RIGHT', destDir: 'LEFT' | 'RIGHT', timeout: number): Promise<Buffer | null>;
+
     /**
      * Command: zAdd
      * @see https://redis.io/docs/latest/commands/zadd

src/test/commands/blmove.ts

@@ -0,0 +1,56 @@
+import { test } from 'node:test';
+import * as Assert from 'node:assert';
+import { cmdCli } from '../common';
+
+const TEST_KEY_PREFIX = 'test_hash_';
+
+test('Command For Lmove/Blmove', async (t) => {
+
+    await cmdCli.del([...await cmdCli.keys(`${TEST_KEY_PREFIX}*`), 'any']);
+
+    await t.test('Append multiple items to the end of mylist', async () => {
+
+        Assert.strictEqual(await cmdCli.rPush(`${TEST_KEY_PREFIX}mylist`, ['one', 'two']), 2);
+        Assert.strictEqual(await cmdCli.rPush(`${TEST_KEY_PREFIX}mylist`, ['three', 'four']), 4);
+
+    });
+
+    await t.test('Manipulate mylist using the lMove operation', async () => {
+
+        Assert.strictEqual(await cmdCli.lMove(`${TEST_KEY_PREFIX}mylist`, `${TEST_KEY_PREFIX}myotherlist`, 'RIGHT', 'LEFT'), 'four');
+
+    });
+
+    await t.test('Manipulate mylist using the bLMove operation', async () => {
+
+        Assert.strictEqual(await cmdCli.bLMove(`${TEST_KEY_PREFIX}mylist`, `${TEST_KEY_PREFIX}myotherlist`, 'LEFT', 'RIGHT', 2), 'one');
+
+    });
+
+    await t.test('Detect and remove data from mylist and myotherlist after operations', async () => {
+
+        Assert.deepEqual(await cmdCli.lRange(`${TEST_KEY_PREFIX}mylist`, 0, -1), ['two', 'three']);
+        Assert.deepEqual(await cmdCli.lRange(`${TEST_KEY_PREFIX}myotherlist`,0, -1), ['four', 'one']);
+        Assert.deepEqual(await cmdCli.lPop(`${TEST_KEY_PREFIX}mylist`, 2), ['two', 'three']);
+        Assert.deepEqual(await cmdCli.lPop(`${TEST_KEY_PREFIX}myotherlist`, 2), ['four', 'one']);
+
+    });
+
+    await t.test('Perform the lMove operation on an empty list', async () => {
+
+        Assert.strictEqual(await cmdCli.lMove(`${TEST_KEY_PREFIX}mylist`, `${TEST_KEY_PREFIX}myotherlist`, 'RIGHT', 'LEFT'), null);
+
+    });
+
+    await t.test('Perform the bLMove operation on an empty list', async () => {
+
+        Assert.strictEqual(await cmdCli.bLMove(`${TEST_KEY_PREFIX}mylist`, `${TEST_KEY_PREFIX}myotherlist`, 'LEFT', 'RIGHT', 2), null);
+
+    });
+
+});
+
+test.after(async () => {
+
+    await cmdCli.close();
+});