fix: requerst response missmatch, clear request

zetxx · Jul 31, 2024 · 569e962 · 569e962
1 parent d662140
commit 569e962
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/wss.js b/lib/wss.js
@@ -120,6 +120,7 @@ const requestPool = ({
                 pool.set(id, {
                     id,
                     connectionId,
+                    timeOut,
                     resolve: (...args) => {
                         clearTimeout(timeOut);
                         pool.delete(id);
@@ -302,6 +303,9 @@ const Wss = ({
                     if (decoded.id && this.requests.get(decoded.id)) {
                         return this.requests.resolve(decoded.id, decoded);
                     }
+                    if (this.isRequest && !this.isRequest(decoded)) {
+                        throw new Error('MessageMissMatch');
+                    }
                     // nowhere to send message
                     if (!config?.sink) {
                         return;