GuanM/NapCatQQ
1
0
Fork 0
mirror of https://github.com/NapNeko/NapCatQQ.git synced 2024-11-21 09:36:35 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: catch

Browse Source
This commit is contained in:
手瓜一十雪 2024-10-13 11:22:33 +08:00
parent a0c49d5f7f
commit 3068f9ee3d
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/core/helper/packet.ts
View File

@ -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<void> {