fix: 🐛 wait for routing table in EVAL command

src/cluster/RedisCluster.ts

@@ -369,6 +369,7 @@ export class RedisCluster implements Printable {
     args: (string | Uint8Array)[],
     opts?: CmdOpts,
   ): Promise<unknown> {
+    if (!this._routerReady) await this.whenRouterReady();
     const script = this.scripts.get(id);
     if (!script) throw new Error('SCRIPT_NOT_REGISTERED');
     const isWrite = true;

src/cluster/__tests__/scripts.spec.ts

@@ -0,0 +1,38 @@
+import {RedisCluster} from '../RedisCluster';
+
+const setup = () => {
+  const cluster = new RedisCluster({
+    seeds: [{host: '127.0.0.1', port: 7000}],
+  });
+  return {cluster};
+};
+
+let keyCnt = 1;
+const getKey = () => '{redis-cluster-script}-test-' + keyCnt++;
+
+if (process.env.TEST_LOCAL_CLUSTER) {
+  test('can execute a script', async () => {
+    const {cluster} = setup();
+    cluster.start();
+    const scriptId = 'hello-scripting-cluster-test-' + Date.now();
+    cluster.scripts.set(scriptId, "return 'Hello, scripting!'");
+    const res = await cluster.eval(scriptId, 0, [], [], {utf8Res: true});
+    expect(res).toBe('Hello, scripting!');
+    cluster.stop();
+  });
+
+  test('can run a with keys and arguments', async () => {
+    const {cluster} = setup();
+    cluster.start();
+    const scriptName = '{add-script-cluster}-' + Date.now();
+    cluster.scripts.set(scriptName, `return tonumber(redis.call("get",KEYS[1])) + tonumber(ARGV[1])`);
+    const key = getKey();
+    await cluster.cmd(['SET', key, '1']);
+    const res = await cluster.eval(scriptName, 1, [key], ['2'], {utf8Res: true});
+    expect(res).toBe(3);
+    cluster.stop();
+  });
+
+} else {
+  test.todo('To enable cluster tests, set TEST_LOCAL_CLUSTER=1 in your environment variables.');
+}

src/standalone/StandaloneClient.ts

@@ -157,12 +157,10 @@ export class StandaloneClient {
         const call = responses[i];
         if (call) decoder.tryUtf8 = !!call.utf8Res;
         const msg = decoder.read();
-        // console.log(msg);
         if (msg === undefined) break;
         if (msg instanceof RespPush) {
           this.onPush.emit(msg);
           const val = msg.val;
-          // console.log('push', Buffer.from(val[0] as any).toString());
           if (isPushMessage(val)) {
             const fanout = this.subs.get(val[1] as Uint8Array);
             if (fanout) fanout.emit(val[2] as Uint8Array);