From 6e02b14cdc2cdb2a3c06e8c637c380aa552ce214 Mon Sep 17 00:00:00 2001 From: ITOH <72305210+itohatweb@users.noreply.github.com> Date: Thu, 15 Apr 2021 10:40:34 +0200 Subject: [PATCH] Update resume.ts --- src/ws/resume.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/ws/resume.ts b/src/ws/resume.ts index 19688a52c..46c345f24 100644 --- a/src/ws/resume.ts +++ b/src/ws/resume.ts @@ -8,7 +8,7 @@ export async function resume(shardId: number) { // NOW WE HANDLE RESUMING THIS SHARD // Get the old data for this shard necessary for resuming const oldShard = ws.shards.get(shardId); - if (!oldShard) return identify(shardId, ws.maxShards); + if (!oldShard?.sessionId) return identify(shardId, ws.maxShards); // CREATE A SHARD const socket = await ws.createShard(shardId); @@ -19,7 +19,7 @@ export async function resume(shardId: number) { oldShard.ws.close(3065, "Resuming the shard, closing old shard."); } // STOP OLD HEARTBEAT - clearInterval(oldShard.heartbeat.intervalId); + clearTimeout(oldShard.heartbeat.timeoutId); ws.shards.set(shardId, { id: shardId, @@ -36,7 +36,7 @@ export async function resume(shardId: number) { acknowledged: false, keepAlive: false, interval: 0, - intervalId: 0, + timeoutId: 0, }, queue: oldShard.queue || [], processingQueue: false,