fix: socket error restart delay

radixdlt · Jun 1, 2023 · f63b38e · f63b38e
1 parent 2a01539
commit f63b38e
Showing 1 changed file with 15 additions and 2 deletions.
diff --git a/src/connector/signaling/signaling-client.ts b/src/connector/signaling/signaling-client.ts
@@ -10,6 +10,7 @@ import {
 import { Logger } from 'tslog'
 import {
   concatMap,
+  delay,
   filter,
   first,
   from,
@@ -95,7 +96,6 @@ export const SignalingClient = (input: {
   const onError = (event: Event) => {
     logger?.debug(`🛰❌ signaling server error`, event)
     subjects.onErrorSubject.next(event)
-    input.restart()
   }
 
   const prepareMessage = ({
@@ -234,6 +234,17 @@ export const SignalingClient = (input: {
 
   subscription.add(onRemoteClientConnectionStateChange$.subscribe())
 
+  subscription.add(
+    subjects.onErrorSubject
+      .pipe(
+        delay(1_000),
+        tap(() => {
+          input.restart()
+        })
+      )
+      .subscribe()
+  )
+
   ws.onmessage = onMessage
   ws.onopen = onOpen
   ws.onclose = onClose
@@ -265,7 +276,9 @@ export const SignalingClient = (input: {
     onIceCandidate$,
     subjects,
     disconnect: () => {
-      ws.close()
+      if (ws.readyState === 1) {
+        ws.close()
+      }
     },
     destroy: () => {
       subscription.unsubscribe()