From bda174bed4d54a790da345859305c8c201c8c95d 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: Sat, 16 Nov 2024 20:13:36 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=BC=82=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/onebot/network/active-websocket.ts | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/onebot/network/active-websocket.ts b/src/onebot/network/active-websocket.ts index 6fbe621f..b68cd51c 100644 --- a/src/onebot/network/active-websocket.ts +++ b/src/onebot/network/active-websocket.ts @@ -106,7 +106,7 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter { if (!isClosedByError) { this.logger.logError.bind(this.logger)(`[OneBot] [WebSocket Client] 反向WebSocket (${this.config.url}) 连接意外关闭`); this.logger.logError.bind(this.logger)(`[OneBot] [WebSocket Client] 在 ${Math.floor(this.config.reconnectInterval / 1000)} 秒后尝试重新连接`); - if (this.isEnable) { + if (!this.isEnable) { this.connection = null; setTimeout(() => this.tryConnect(), this.config.reconnectInterval); } @@ -116,7 +116,7 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter { isClosedByError = true; this.logger.logError.bind(this.logger)(`[OneBot] [WebSocket Client] 反向WebSocket (${this.config.url}) 连接错误`, err); this.logger.logError.bind(this.logger)(`[OneBot] [WebSocket Client] 在 ${Math.floor(this.config.reconnectInterval / 1000)} 秒后尝试重新连接`); - if (this.isEnable) { + if (!this.isEnable) { this.connection = null; setTimeout(() => this.tryConnect(), this.config.reconnectInterval); } @@ -159,7 +159,7 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter { const oldUrl = this.config.url; const oldHeartInterval = this.config.heartInterval; this.config = newConfig; - + if (newConfig.enable && !wasEnabled) { this.open(); return OB11NetworkReloadType.NetWorkOpen; @@ -167,7 +167,7 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter { this.close(); return OB11NetworkReloadType.NetWorkClose; } - + if (oldUrl !== newConfig.url) { this.close(); if (newConfig.enable) { @@ -175,7 +175,7 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter { } return OB11NetworkReloadType.NetWorkReload; } - + if (oldHeartInterval !== newConfig.heartInterval) { if (this.heartbeatRef) { clearInterval(this.heartbeatRef); @@ -190,7 +190,7 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter { } return OB11NetworkReloadType.NetWorkReload; } - + return OB11NetworkReloadType.Normal; } }