feat: add delex command and tests

Author: PavelPashov

packages/client/lib/commands/DELEX.spec.ts

@@ -0,0 +1,81 @@
+import { strict as assert } from "node:assert";
+import DELEX, { DelexCondition } from "./DELEX";
+import { parseArgs } from "./generic-transformers";
+import testUtils, { GLOBAL } from "../test-utils";
+
+describe("DELEX", () => {
+  describe("transformArguments", () => {
+    it("no condition", () => {
+      assert.deepEqual(parseArgs(DELEX, "key"), ["DELEX", "key"]);
+    });
+
+    it("with condition", () => {
+      assert.deepEqual(
+        parseArgs(DELEX, "key", {
+          condition: DelexCondition.IFEQ,
+          matchValue: "some-value",
+        }),
+        ["DELEX", "key", "IFEQ", "some-value"]
+      );
+    });
+  });
+
+  testUtils.testAll(
+    "non-existing key",
+    async (client) => {
+      assert.equal(await client.delEx("key{tag}"), 0);
+    },
+    {
+      client: { ...GLOBAL.SERVERS.OPEN, minimumDockerVersion: [8, 4] },
+      cluster: { ...GLOBAL.CLUSTERS.OPEN, minimumDockerVersion: [8, 4] },
+    }
+  );
+
+  testUtils.testAll(
+    "non-existing key with condition",
+    async (client) => {
+      assert.equal(
+        await client.delEx("key{tag}", {
+          condition: DelexCondition.IFDEQ,
+          matchValue: "digest",
+        }),
+        0
+      );
+    },
+    {
+      client: { ...GLOBAL.SERVERS.OPEN, minimumDockerVersion: [8, 4] },
+      cluster: { ...GLOBAL.CLUSTERS.OPEN, minimumDockerVersion: [8, 4] },
+    }
+  );
+
+  testUtils.testAll(
+    "existing key no condition",
+    async (client) => {
+      await client.set("key{tag}", "value");
+      assert.equal(await client.delEx("key{tag}"), 1);
+    },
+    {
+      client: { ...GLOBAL.SERVERS.OPEN, minimumDockerVersion: [8, 4] },
+      cluster: { ...GLOBAL.CLUSTERS.OPEN, minimumDockerVersion: [8, 4] },
+    }
+  );
+
+  testUtils.testAll(
+    "existing key and condition",
+    async (client) => {
+      await client.set("key{tag}", "some-value");
+      
+      assert.equal(
+        await client.delEx("key{tag}", {
+          condition: DelexCondition.IFEQ,
+          matchValue: "some-value",
+        }),
+        1
+      );
+    },
+    {
+      client: { ...GLOBAL.SERVERS.OPEN, minimumDockerVersion: [8, 4] },
+      cluster: { ...GLOBAL.CLUSTERS.OPEN, minimumDockerVersion: [8, 4] },
+    }
+  );
+});

packages/client/lib/commands/DELEX.ts

@@ -0,0 +1,60 @@
+import { CommandParser } from "../client/parser";
+import { NumberReply, Command, RedisArgument } from "../RESP/types";
+
+export const DelexCondition = {
+  /**
+   * Delete if value equals match-value.
+   */
+  IFEQ: "IFEQ",
+  /**
+   * Delete if value does not equal match-value.
+   */
+  IFNE: "IFNE",
+  /**
+   * Delete if value digest equals match-digest.
+   */
+  IFDEQ: "IFDEQ",
+  /**
+   * Delete if value digest does not equal match-digest.
+   */
+  IFDNE: "IFDNE",
+} as const;
+
+type DelexCondition = (typeof DelexCondition)[keyof typeof DelexCondition];
+
+export default {
+  IS_READ_ONLY: false,
+  /**
+   * Conditionally removes the specified key based on value or digest comparison.
+   *
+   * @param parser - The Redis command parser
+   * @param key - Key to delete
+   */
+  parseCommand(
+    parser: CommandParser,
+    key: RedisArgument,
+    options?: {
+      /**
+       * The condition to apply when deleting the key.
+       * - `IFEQ` - Delete if value equals match-value
+       * - `IFNE` - Delete if value does not equal match-value
+       * - `IFDEQ` - Delete if value digest equals match-digest
+       * - `IFDNE` - Delete if value digest does not equal match-digest
+       */
+      condition: DelexCondition;
+      /**
+       * The value or digest to compare against
+       */
+      matchValue: RedisArgument;
+    }
+  ) {
+    parser.push("DELEX");
+    parser.pushKey(key);
+
+    if (options) {
+      parser.push(options.condition);
+      parser.push(options.matchValue);
+    }
+  },
+  transformReply: undefined as unknown as () => NumberReply<1 | 0>,
+} as const satisfies Command;

packages/client/lib/commands/index.ts

@@ -84,6 +84,7 @@ import DBSIZE from './DBSIZE';
 import DECR from './DECR';
 import DECRBY from './DECRBY';
 import DEL from './DEL';
+import DELEX from './DELEX';
 import DIGEST from './DIGEST';
 import DUMP from './DUMP';
 import ECHO from './ECHO';
@@ -544,6 +545,8 @@ export default {
   decrBy: DECRBY,
   DEL,
   del: DEL,
+  DELEX,
+  delEx: DELEX,
   DIGEST,
   digest: DIGEST,
   DUMP,