From 3068f9ee3d9996da967b54c9a4079a8eaf849142 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=89=8B=E7=93=9C=E4=B8=80=E5=8D=81=E9=9B=AA?= Date: Sun, 13 Oct 2024 11:22:33 +0800 Subject: [PATCH] fix: catch --- src/core/helper/packet.ts | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/src/core/helper/packet.ts b/src/core/helper/packet.ts index b287db42..5a09a379 100644 --- a/src/core/helper/packet.ts +++ b/src/core/helper/packet.ts @@ -33,7 +33,7 @@ export class PacketClient { this.websocket.onmessage = (event) => { // const message = JSON.parse(event.data.toString()); // console.log("Received message:", message); - this.handleMessage(event.data); + this.handleMessage(event.data).then().catch(); }; this.websocket.onclose = () => { @@ -49,12 +49,16 @@ export class PacketClient { if (this.reconnectAttempts < this.maxReconnectAttempts) { this.reconnectAttempts++; this.logger.logError.bind(this.logger)(`Reconnecting attempt ${this.reconnectAttempts}`); - setTimeout(() => this.connect().then().catch(), 1000 * this.reconnectAttempts); + setTimeout(() => { + this.connect().catch((error) => { + this.logger.logError.bind(this.logger)(`Reconnect attempt failed: ${error.message}`); + }); + }, 5000 * this.reconnectAttempts); } else { this.logger.logError.bind(this.logger)(`Max reconnect attempts reached. Could not reconnect to ${this.url}`); } - } catch (error) { - this.logger.logError.bind(this.logger)(`Error attempting to reconnect: ${error}`); + } catch (error: any) { + this.logger.logError.bind(this.logger)(`Error attempting to reconnect: ${error.message}`); } } async registerCallback(trace_id: string, type: string, callback: any): Promise {