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客户端已断开');