From d00ee890e5956f640d035ff4e74bd459582183c8 Mon Sep 17 00:00:00 2001
From: Jan Prochazka <jan.prochazka@gmail.com>
Date: Mon, 20 May 2024 20:15:53 +0200
Subject: [PATCH] fixed stream

---
 packages/api/src/utility/socket.js | 19 ++++++++++++-------
 1 file changed, 12 insertions(+), 7 deletions(-)

diff --git a/packages/api/src/utility/socket.js b/packages/api/src/utility/socket.js
index ae0c9f070..a3bac6330 100644
--- a/packages/api/src/utility/socket.js
+++ b/packages/api/src/utility/socket.js
@@ -14,8 +14,8 @@ module.exports = {
   },
   addSseResponse(value, strmid) {
     sseResponses[strmid] = {
+      ...sseResponses[strmid],
       response: value,
-      filter: {},
     };
     this.ensurePing();
   },
@@ -32,11 +32,13 @@ module.exports = {
     }
     for (const strmid in sseResponses) {
       let skipThisStream = false;
-      for (const key in sseResponses[strmid].filter) {
-        if (data && data[key]) {
-          if (!sseResponses[strmid].filter[key].includes(data[key])) {
-            skipThisStream = true;
-            break;
+      if (sseResponses[strmid].filter) {
+        for (const key in sseResponses[strmid].filter) {
+          if (data && data[key]) {
+            if (!sseResponses[strmid].filter[key].includes(data[key])) {
+              skipThisStream = true;
+              break;
+            }
           }
         }
       }
@@ -55,6 +57,9 @@ module.exports = {
     // this.emit(key);
   },
   setStreamIdFilter(strmid, filter) {
-    sseResponses[strmid].filter = filter;
+    sseResponses[strmid] = {
+      ...sseResponses[strmid],
+      filter,
+    };
   },
 };