fix: handle restart on socket error

radixdlt · May 24, 2023 · fe811fe · fe811fe
1 parent a742862
commit fe811fe
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/src/connector/connector-client.ts b/src/connector/connector-client.ts
@@ -80,6 +80,7 @@ export const ConnectorClient = (input: {
         logger,
         subjects: createSignalingSubjects(),
         secrets,
+        restart: () => triggerRestartSubject.next(),
       })
 
       const webRtcClient = WebRtcClient({

diff --git a/src/connector/signaling/signaling-client.ts b/src/connector/signaling/signaling-client.ts
@@ -46,6 +46,7 @@ export const SignalingClient = (input: {
   target: MessageSources
   source: MessageSources
   logger?: Logger<unknown>
+  restart: () => void
 }) => {
   const logger = input.logger
   const subjects = input.subjects
@@ -94,6 +95,7 @@ export const SignalingClient = (input: {
   const onError = (event: Event) => {
     logger?.debug(`🛰❌ signaling server error`, event)
     subjects.onErrorSubject.next(event)
+    input.restart()
   }
 
   const prepareMessage = ({