fix: prevent message over closed WS

radixdlt · Oct 9, 2023 · ba5d149 · ba5d149
1 parent bac745a
commit ba5d149
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/connector/signaling/signaling-client.ts b/src/connector/signaling/signaling-client.ts
@@ -143,10 +143,14 @@ export const SignalingClient = (input: {
         const sendMessage$ = of(stringify(encryptedMessage)).pipe(
           tap((result) =>
             result.map((data) => {
-              logger?.trace(
-                `🛰💬⬆️ sending: ${message.method} (${encryptedMessage.requestId})`,
-              )
-              return ws.send(data)
+              const incorrectStates: number[] = [ws.CLOSED, ws.CLOSING]
+              if (!incorrectStates.includes(ws.readyState)) {
+                logger?.trace(
+                  `🛰💬⬆️ sending: ${message.method} (${encryptedMessage.requestId})`,
+                )
+
+                return ws.send(data)
+              }
             }),
           ),
           filter(() => false),