dev: Fix race condition in event stream opening logic

TheThingsNetwork · Dec 12, 2023 · 30dc2f1 · 30dc2f1
1 parent c0687cf
commit 30dc2f1
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 6 deletions.
diff --git a/pkg/webui/console/store/middleware/logics/events.js b/pkg/webui/console/store/middleware/logics/events.js
@@ -275,6 +275,7 @@ const createEventsConnectLogics = (reducerName, entityName, onEventsStart) => {
     }),
     createLogic({
       type: SET_EVENT_FILTER,
+      debounce: 250,
       process: async ({ action }, dispatch, done) => {
         if (channel) {
           try {

diff --git a/sdk/js/src/api/stream/subscribeToWebSocketStream.js b/sdk/js/src/api/stream/subscribeToWebSocketStream.js
@@ -93,11 +93,6 @@ export default async (
             `ttn.lorawan.v3.header.authorization.bearer.${tokenParsed}`,
           ])
 
-          // Event listener for 'open'
-          wsInstances[url].addEventListener('open', () => {
-            wsInstances[url].send(subscriptionPayload)
-          })
-
           // Broadcast connection errors to all listeners.
           wsInstances[url].addEventListener('error', error => {
             Object.values(subscriptions)
@@ -163,9 +158,16 @@ export default async (
               }
             }
           })
-        } else if (wsInstances[url] && wsInstances[url].readyState === WebSocket.OPEN) {
+        }
+
+        if (wsInstances[url] && wsInstances[url].readyState === WebSocket.OPEN) {
           // If the WebSocket connection is already open, only add the subscription.
           wsInstances[url].send(subscriptionPayload)
+        } else if (wsInstances[url] && wsInstances[url].readyState === WebSocket.CONNECTING) {
+          // Otherwise wait for the connection to open and then add the subscription.
+          wsInstances[url].addEventListener('open', () => {
+            wsInstances[url].send(subscriptionPayload)
+          })
         }
       } catch (error) {
         const err = error instanceof Error ? error : new Error(error)