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: ws心跳问题

Browse Source
This commit is contained in:
手瓜一十雪 2024-05-16 12:46:27 +08:00
parent eb9d6240d7
commit 84d46da67e
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/onebot11/server/ws/ReverseWebsocket.ts
View File

@ -104,7 +104,7 @@ export class ReverseWebsocket {
this.websocket.on('error', log); this.websocket.on('error', log);
const wsClientInterval = setInterval(() => { const wsClientInterval = setInterval(() => {
postWsEvent(new OB11HeartbeatEvent(!!selfInfo.online, true, heartInterval)); wsReply(this.websocket!, new OB11HeartbeatEvent(!!selfInfo.online, true, heartInterval));
}, heartInterval); // 心跳包 }, heartInterval); // 心跳包
this.websocket.on('close', () => { this.websocket.on('close', () => {
clearInterval(wsClientInterval); clearInterval(wsClientInterval);

2
src/onebot11/server/ws/WebsocketServer.ts
View File

@ -69,7 +69,7 @@ class OB11WebsocketServer extends WebsocketServerBase {
} }
const { heartInterval } = ob11Config; const { heartInterval } = ob11Config;
const wsClientInterval = setInterval(() => { const wsClientInterval = setInterval(() => {
postWsEvent(new OB11HeartbeatEvent(!!selfInfo.online, true, heartInterval)); wsReply(wsClient, new OB11HeartbeatEvent(!!selfInfo.online, true, heartInterval));
}, heartInterval); // 心跳包 }, heartInterval); // 心跳包
wsClient.on('close', () => { wsClient.on('close', () => {
logError('event上报ws客户端已断开'); logError('event上报ws客户端已断开');