daenamnu/discordeno
1
0
Fork 0
mirror of https://github.com/discordeno/discordeno.git synced 2026-06-16 19:28:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update resume.ts

Browse Source
This commit is contained in:
ITOH
2021-04-15 10:40:34 +02:00
parent 28ff1574d8
commit 6e02b14cdc
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ws/resume.ts
+3 -3
View File
@@ -8,7 +8,7 @@ export async function resume(shardId: number) {
// NOW WE HANDLE RESUMING THIS SHARD // NOW WE HANDLE RESUMING THIS SHARD
// Get the old data for this shard necessary for resuming // Get the old data for this shard necessary for resuming
const oldShard = ws.shards.get(shardId); const oldShard = ws.shards.get(shardId);
if (!oldShard) return identify(shardId, ws.maxShards); if (!oldShard?.sessionId) return identify(shardId, ws.maxShards);
// CREATE A SHARD // CREATE A SHARD
const socket = await ws.createShard(shardId); 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."); oldShard.ws.close(3065, "Resuming the shard, closing old shard.");
} }
// STOP OLD HEARTBEAT // STOP OLD HEARTBEAT
clearInterval(oldShard.heartbeat.intervalId); clearTimeout(oldShard.heartbeat.timeoutId);
ws.shards.set(shardId, { ws.shards.set(shardId, {
id: shardId, id: shardId,
@@ -36,7 +36,7 @@ export async function resume(shardId: number) {
acknowledged: false, acknowledged: false,
keepAlive: false, keepAlive: false,
interval: 0, interval: 0,
intervalId: 0, timeoutId: 0,
}, },
queue: oldShard.queue || [], queue: oldShard.queue || [],
processingQueue: false, processingQueue: false,