tiramisu/seyfert
5
0
Fork 0
mirror of https://github.com/tiramisulabs/seyfert.git synced 2025-07-01 20:46:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: zombie connection

Browse Source
This commit is contained in:
MARCROCK22 2024-09-30 02:23:36 +00:00
parent dd8fbd2789
commit 9f54a8df9c
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/websocket/discord/shard.ts
View File

@ -335,9 +335,9 @@ export class Shard {
async close(code: number, reason: string) { async close(code: number, reason: string) {
clearInterval(this.heart.nodeInterval); clearInterval(this.heart.nodeInterval);
if (!this.isOpen) { if (!this.isOpen) {
return this.debugger?.warn(`[Shard #${this.id}] Is not open`); return this.debugger?.warn(`[Shard #${this.id}] Is not open, reason:`, reason);
} }
this.debugger?.debug(`[Shard #${this.id}] Called close`); this.debugger?.debug(`[Shard #${this.id}] Called close with reason:`, reason);
this.websocket?.close(code, reason); this.websocket?.close(code, reason);
} }

3
src/websocket/discord/socket/custom.ts
View File

@ -234,7 +234,10 @@ export class SeyfertWebSocket {
buffer.write(reason, 2); buffer.write(reason, 2);
// message, close opcode // message, close opcode
this._write(buffer, 0x8); this._write(buffer, 0x8);
this.socket?.end(); this.socket?.end();
this.onclose({ code, reason });
} }
pong(data: string) { pong(data: string) {