feat: Implement CLIENT GETREDIR (#191)

denodrivers · Feb 21, 2021 · b372711 · b372711
1 parent bb046fb
commit b372711
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 0 deletions.
diff --git a/command.ts b/command.ts
@@ -992,6 +992,12 @@ XRANGE somestream - +
    */
   clientGetName(): Promise<Bulk>;
 
+  /**
+   * Returns the client ID we are redirecting our tracking notifications to.
+   * @see https://redis.io/commands/client-getredir
+   */
+  clientGetRedir(): Promise<Integer>;
+
   /**
    * Returns the id of the current redis connection.
    */

diff --git a/redis.ts b/redis.ts
@@ -324,6 +324,10 @@ export class RedisImpl implements Redis {
     return this.execBulkReply("CLIENT", "GETNAME");
   }
 
+  clientGetRedir() {
+    return this.execIntegerReply("CLIENT", "GETREDIR");
+  }
+
   clientID() {
     return this.execIntegerReply("CLIENT", "ID");
   }

diff --git a/tests/connection_test.ts b/tests/connection_test.ts
@@ -77,6 +77,21 @@ suite.test("client setname & getname", async () => {
   assertEquals(await client.clientGetName(), "deno-redis");
 });
 
+suite.test("client getredir with no redirect", async () => {
+  assertEquals(await client.clientGetRedir(), -1);
+});
+
+suite.test("client getredir with redirect", async () => {
+  const tempClient = await newClient({ hostname: "127.0.0.1", port: 7003 });
+  try {
+    const id = await tempClient.clientID();
+    await client.clientTracking({ mode: "ON", redirect: id });
+    assertEquals(await client.clientGetRedir(), id);
+  } finally {
+    tempClient.close();
+  }
+});
+
 suite.test("client pause", async () => {
   assertEquals(await client.clientPause(10), "OK");
 });