Re-write emitInvalidate logic

Author: sastcsgh

packages/client/lib/client/index.ts

@@ -530,6 +530,19 @@ export default class RedisClient<
           this.#clientSideCache?.invalidate(null)
         }
 
+        return true
+      });
+    } else if (options?.emitInvalidate) {
+      this.#queue.addPushHandler((push: Array<any>): boolean => {
+        if (push[0].toString() !== 'invalidate') return false;
+
+        if (push[1] !== null) {
+          for (const key of push[1]) {
+            this.emit('invalidate', key);
+          }
+        } else {
+          this.emit('invalidate', null);
+        }
         return true
       });
     }
@@ -539,14 +552,15 @@ export default class RedisClient<
     if (options?.clientSideCache && options?.RESP !== 3) {
       throw new Error('Client Side Caching is only supported with RESP3');
     }
+    if (options?.emitInvalidate && options?.RESP !== 3) {
+      throw new Error('emitInvalidate is only supported with RESP3');
+    }
     if (options?.clientSideCache && options?.emitInvalidate) {
       throw new Error('emitInvalidate is not supported (or necessary) when clientSideCache is enabled');
+    }
     if (options?.maintPushNotifications && options?.maintPushNotifications !== 'disabled' && options?.RESP !== 3) {
       throw new Error('Graceful Maintenance is only supported with RESP3');
-      }
-
-  }
-
+    }
   }
 
   #initiateOptions(options?: RedisClientOptions<M, F, S, RESP, TYPE_MAPPING>): RedisClientOptions<M, F, S, RESP, TYPE_MAPPING> | undefined {
@@ -756,6 +770,10 @@ export default class RedisClient<
       commands.push({cmd: this.#clientSideCache.trackingOn()});
     }
 
+    if (this.#options?.emitInvalidate) {
+      commands.push({cmd: ['CLIENT', 'TRACKING', 'ON']});
+    }
+    
     const { tls, host } = this.#options!.socket as RedisTcpSocketOptions;
     const maintenanceHandshakeCmd = await EnterpriseMaintenanceManager.getHandshakeCommand(!!tls, host!, this.#options!);
     if(maintenanceHandshakeCmd) {