daenamnu/discordeno
1
0
Fork 0
mirror of https://github.com/discordeno/discordeno.git synced 2026-06-03 09:20:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update heartbeat.ts

Browse Source
This commit is contained in:
ITOH
2021-04-16 19:15:01 +02:00
parent 6315ba75fc
commit 2ce185a696
1 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/ws/heartbeat.ts
View File

@@ -12,20 +12,21 @@ export async function heartbeat(shardId: number, interval: number) {
ws.log("HEARTBEATING_DETAILS", { shardId, interval, shard });
// The first heartbeat is special so we send it without setInterval: https://discord.com/developers/docs/topics/gateway#heartbeating
await delay(Math.floor(shard.heartbeat.interval * Math.random()));
if (shard.ws.readyState !== WebSocket.OPEN) return;
shard.ws.send(JSON.stringify({
op: DiscordGatewayOpcodes.Heartbeat,
d: shard.previousSequenceNumber,
}));
shard.heartbeat.keepAlive = true;
shard.heartbeat.acknowledged = false;
shard.heartbeat.lastSentAt = Date.now();
shard.heartbeat.interval = interval;
// The first heartbeat is special so we send it without setInterval: https://discord.com/developers/docs/topics/gateway#heartbeating
await delay(Math.floor(shard.heartbeat.interval * Math.random()));
shard.queue.unshift({
op: DiscordGatewayOpcodes.Heartbeat,
d: shard.previousSequenceNumber,
});
ws.processQueue(shard.id);
shard.heartbeat.intervalId = setInterval(() => {
ws.log("DEBUG", `Running setInterval in heartbeat file.`);
const currentShard = ws.shards.get(shardId);
@@ -50,11 +51,11 @@ export async function heartbeat(shardId: number, interval: number) {
if (currentShard.ws.readyState !== WebSocket.OPEN) return;
currentShard.heartbeat.acknowledged = false;
currentShard.ws.send(JSON.stringify({
op: DiscordGatewayOpcodes.Heartbeat,
d: currentShard.previousSequenceNumber,
}));
currentShard.heartbeat.acknowledged = false;
}, shard.heartbeat.interval);
}