diff --git a/lib/core.js b/lib/core.js index b2e5df6..e8a0374 100644 --- a/lib/core.js +++ b/lib/core.js @@ -244,10 +244,8 @@ function createServer() { wss.on("connection", (ws, req)=>{ ws.on("error", ()=>{}); if (config.access_token) { - if (!req.headers["authorization"]) - return ws.close(1401); - if (!req.headers["authorization"].includes(config.access_token)) - return ws.close(1403); + if (!req.headers["authorization"] || !req.headers["authorization"].includes(config.access_token)) + return ws.close(1002); } onWSOpen(ws); }); @@ -309,8 +307,8 @@ function createWSClient(url, headers) { websockets.add(ws); onWSOpen(ws); }); - ws.on("close", ()=>{ - bot.logger.error(`反向ws连接(${url})被关闭,将在${config.ws_reverse_reconnect_interval}毫秒后尝试连接。`); + ws.on("close", (code)=>{ + bot.logger.error(`反向ws连接(${url})被关闭,关闭码${code},将在${config.ws_reverse_reconnect_interval}毫秒后尝试连接。`); websockets.delete(ws); setTimeout(()=>{ createWSClient(url, headers);