From 83176d3133b5eedbe0951112f796807d9c49183e Mon Sep 17 00:00:00 2001 From: marlon-erler Date: Wed, 8 Apr 2026 11:08:13 +0000 Subject: [PATCH] handle errors when sending pings --- websocket-handler.ts | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/websocket-handler.ts b/websocket-handler.ts index a8a9911..ec069ee 100644 --- a/websocket-handler.ts +++ b/websocket-handler.ts @@ -78,12 +78,12 @@ export function forgetSubscription( } // AUDIT -export function getWebSocketStats(): [string, string|number][] { - function listString(list: Set|Map, map: (x: T) => string): string { +export function getWebSocketStats(): [string, string | number][] { + function listString(list: Set | Map, map: (x: T) => string): string { if (list.size == 0) return ""; return [...list.values()].map(map).join("\n"); } - + return [ ["channels", subscriptionMap.subscribersPerChannel.size], ["clients connected", clientsConnected.size], @@ -103,8 +103,10 @@ export function connectServers(config: typeof defaultConfig): void { export function reconnectServers(config: typeof defaultConfig): void { config.connectedServers .map(address => address.replace("ws", "http")) - .forEach(address => { - fetch(address); + .forEach(async address => { + try { + await fetch(address); + } catch (error) { writeError(`failed to ping server at "${address}": ${error}`) } }); [...serversDisconnected.values()].forEach((address) => {