From d76503995c444a32724c2cbe1b14c9801a0fc36a 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: Mon, 19 Aug 2024 20:24:26 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20ws=E5=BF=83=E8=B7=B3=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/onebot/network/active-websocket.ts | 6 ++++++ src/onebot/network/passive-websocket.ts | 6 ++++++ 2 files changed, 12 insertions(+) diff --git a/src/onebot/network/active-websocket.ts b/src/onebot/network/active-websocket.ts index 3419d9d4..b8aa4530 100644 --- a/src/onebot/network/active-websocket.ts +++ b/src/onebot/network/active-websocket.ts @@ -79,6 +79,12 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter { }, }); + this.connection.on('ping', () => { + this.connection?.pong(); + }); + this.connection.on('pong', () => { + //this.logger.logDebug('[OneBot] [WebSocket Client] 收到pong'); + }); this.connection.on('open', () => { try { this.connectEvent(this.coreContext); diff --git a/src/onebot/network/passive-websocket.ts b/src/onebot/network/passive-websocket.ts index 9823e713..0ded05a9 100644 --- a/src/onebot/network/passive-websocket.ts +++ b/src/onebot/network/passive-websocket.ts @@ -50,6 +50,12 @@ export class OB11PassiveWebSocketAdapter implements IOB11NetworkAdapter { wsClient.on('message', (message) => { this.handleMessage(wsClient, message).then().catch(this.logger.logError); }); + wsClient.on('ping', () => { + wsClient.pong(); + }); + wsClient.on('pong', () => { + //this.logger.logDebug('[OneBot] [WebSocket Server] Pong received'); + }); wsClient.once('close', () => { this.wsClientsMutex.runExclusive(async () => { const index = this.wsClients.indexOf(wsClient);