From 84d46da67ef07aeca17b8743b7ff66756552dcdc 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: Thu, 16 May 2024 12:46:27 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20ws=E5=BF=83=E8=B7=B3=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/onebot11/server/ws/ReverseWebsocket.ts | 2 +- src/onebot11/server/ws/WebsocketServer.ts | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/onebot11/server/ws/ReverseWebsocket.ts b/src/onebot11/server/ws/ReverseWebsocket.ts index 600e354e..0f99cd9f 100644 --- a/src/onebot11/server/ws/ReverseWebsocket.ts +++ b/src/onebot11/server/ws/ReverseWebsocket.ts @@ -104,7 +104,7 @@ export class ReverseWebsocket { this.websocket.on('error', log); const wsClientInterval = setInterval(() => { - postWsEvent(new OB11HeartbeatEvent(!!selfInfo.online, true, heartInterval)); + wsReply(this.websocket!, new OB11HeartbeatEvent(!!selfInfo.online, true, heartInterval)); }, heartInterval); // 心跳包 this.websocket.on('close', () => { clearInterval(wsClientInterval); diff --git a/src/onebot11/server/ws/WebsocketServer.ts b/src/onebot11/server/ws/WebsocketServer.ts index 8486e26b..e507ea95 100644 --- a/src/onebot11/server/ws/WebsocketServer.ts +++ b/src/onebot11/server/ws/WebsocketServer.ts @@ -69,7 +69,7 @@ class OB11WebsocketServer extends WebsocketServerBase { } const { heartInterval } = ob11Config; const wsClientInterval = setInterval(() => { - postWsEvent(new OB11HeartbeatEvent(!!selfInfo.online, true, heartInterval)); + wsReply(wsClient, new OB11HeartbeatEvent(!!selfInfo.online, true, heartInterval)); }, heartInterval); // 心跳包 wsClient.on('close', () => { logError('event上报ws客户端已断开');