fix redis#1854 - fix __redis__:invalidate messages handler (redis#1856)

ltwlf · Jan 24, 2022 · 551d204 · 551d204
1 parent cf120c3
commit 551d204
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/packages/client/lib/client/commands-queue.ts b/packages/client/lib/client/commands-queue.ts
@@ -82,10 +82,12 @@ export default class RedisCommandsQueue {
 
         if (!listeners.strings.size) return;
 
-        // https://github.com/redis/redis/pull/7469
-        // https://github.com/redis/redis/issues/7463
-        const messageString = (Array.isArray(message) ? message.map(m => m.toString()) as any : message.toString()),
-            channelString = pattern ? channel.toString() : keyString;
+        const channelString = pattern ? channel.toString() : keyString,
+            messageString = channelString === '__redis__:invalidate' ?
+                // https://github.com/redis/redis/pull/7469
+                // https://github.com/redis/redis/issues/7463
+                (message === null ? null : (message as any as Array<Buffer>).map(x => x.toString())) as any :
+                message.toString();
         for (const listener of listeners.strings) {
             listener(messageString, channelString);
         }