pass down command name and search policy

Author: nkaradzhov

packages/client/lib/cluster/index.ts

@@ -188,12 +188,12 @@ export default class RedisCluster<
     return async function (this: ProxyCluster, ...args: Array<unknown>) {
       const parser = new BasicCommandParser();
       command.parseCommand(parser, ...args);
-      console.log(parser, parser.redisArgs[0]);
 
       return this._self._execute(
         parser.firstKey,
         command.IS_READ_ONLY,
         this._commandOptions,
+        parser.commandName!,
         (client, opts) => client._executeCommand(command, parser, opts, transformReply)
       );
     };
@@ -210,6 +210,7 @@ export default class RedisCluster<
         parser.firstKey,
         command.IS_READ_ONLY,
         this._self._commandOptions,
+        parser.commandName!,
         (client, opts) => client._executeCommand(command, parser, opts, transformReply)
       );
     };
@@ -228,6 +229,7 @@ export default class RedisCluster<
         parser.firstKey,
         fn.IS_READ_ONLY,
         this._self._commandOptions,
+        parser.commandName!,
         (client, opts) => client._executeCommand(fn, parser, opts, transformReply)
       );
     };
@@ -246,6 +248,7 @@ export default class RedisCluster<
         parser.firstKey,
         script.IS_READ_ONLY,
         this._commandOptions,
+        parser.commandName!,
         (client, opts) => client._executeScript(script, parser, opts, transformReply)
       );
     };
@@ -459,12 +462,16 @@ export default class RedisCluster<
     firstKey: RedisArgument | undefined,
     isReadonly: boolean | undefined,
     options: ClusterCommandOptions | undefined,
+    commandName: string,
     fn: (client: RedisClientType<M, F, S, RESP, TYPE_MAPPING>, opts?: ClusterCommandOptions) => Promise<T>
   ): Promise<T> {
-    console.log(`executing command `, firstKey, isReadonly, options);
     const maxCommandRedirections = this._options.maxCommandRedirections ?? 16;
-    const p = this._policyResolver.resolvePolicy("ping")
-    console.log(`ping policy `, p);
+    const policyResult = this._policyResolver.resolvePolicy(commandName)
+    if(policyResult.ok) {
+      //TODO
+    } else {
+      //TODO
+    }
 
     let client = await this._slots.getClient(firstKey, isReadonly);
     let i = 0;
@@ -521,6 +528,7 @@ export default class RedisCluster<
       firstKey,
       isReadonly,
       options,
+      args[0] instanceof Buffer ? args[0].toString() : args[0],
       (client, opts) => client.sendCommand(args, opts)
     );
   }

packages/client/lib/cluster/request-response-policies/test.spec.ts

@@ -1,9 +1,38 @@
 import testUtils, { GLOBAL } from '../../test-utils';
+import RediSearch from '@redis/search';
+
+import RedisBloomModules from '@redis/bloom';
+import RedisJSON from '@redis/json';
+import RedisTimeSeries from '@redis/time-series';
 
 describe('Cluster Request-Response Policies', () => {
-	testUtils.testWithCluster('should resolve policies correctly', async cluster => {
+	testUtils.testWithClient('should resolve policies correctly', async client => {
+		await client.ft.SUGADD('index', 'string', 1);
+		await client.ft.dictAdd('index', 'foo');
+	}, {
+		...GLOBAL.SERVERS.OPEN,
+		clientOptions: {
+			modules: {
+			  ft: RediSearch
+			}
+		  }
+	});
 
-		await cluster.get('foo')
+	testUtils.testWithCluster('should resolve policies correctly', async cluster => {
 
-	}, GLOBAL.CLUSTERS.OPEN);
+		await cluster.ft.SUGADD('index', 'string', 1);
+		await cluster.ft.DICTADD('index', 'foo');
+		await cluster.sendCommand(undefined, true, ['ft.dictadd', 'index', 'string']);
+		
+	}, {
+		...GLOBAL.CLUSTERS.OPEN,
+      clusterConfiguration: {
+        modules: {
+			ft: RediSearch,
+        //   ...RedisBloomModules,
+        //   json: RedisJSON,
+        //   ts: RedisTimeSeries
+        },
+      }
+	});
 });