From 8fbabdc2cbb5cfe5c0777fb8d9cac9e9739f00f8 Mon Sep 17 00:00:00 2001 From: Heikki Hellgren Date: Tue, 5 Dec 2023 09:31:46 +0200 Subject: [PATCH] chore: add check for connection status before sending Signed-off-by: Heikki Hellgren --- plugins/signals-node/src/SignalsService.ts | 5 +++++ plugins/signals/src/api/SignalsClient.ts | 2 +- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/plugins/signals-node/src/SignalsService.ts b/plugins/signals-node/src/SignalsService.ts index 6a1547a6bb..c743c958dd 100644 --- a/plugins/signals-node/src/SignalsService.ts +++ b/plugins/signals-node/src/SignalsService.ts @@ -206,6 +206,11 @@ export class SignalsService implements EventSubscriber { ) { return; } + + if (conn.ws.readyState !== WebSocket.OPEN) { + return; + } + conn.ws.send(jsonMessage); }); diff --git a/plugins/signals/src/api/SignalsClient.ts b/plugins/signals/src/api/SignalsClient.ts index d8d3328411..1fbe374ad9 100644 --- a/plugins/signals/src/api/SignalsClient.ts +++ b/plugins/signals/src/api/SignalsClient.ts @@ -126,7 +126,7 @@ export class SignalsClient implements SignalsApi { const { token } = await this.identity.getCredentials(); const url = new URL(apiUrl); - url.protocol = url.protocol === 'http:' ? 'ws' : 'wss'; + url.protocol = url.protocol === 'http:' ? 'ws:' : 'wss:'; this.ws = new WebSocket(url.toString(), token); this.ws.onmessage = (data: MessageEvent) => {