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 handle_on_message.ts

Browse Source
This commit is contained in:
ITOH
2021-04-16 19:16:08 +02:00
parent 6a0ab380e7
commit 320c9b4b91
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/ws/handle_on_message.ts
+3 -3
View File
@@ -8,6 +8,7 @@ import { delay } from "../util/utils.ts";
import { decompressWith } from "./deps.ts"; import { decompressWith } from "./deps.ts";
import { identify } from "./identify.ts"; import { identify } from "./identify.ts";
import { resume } from "./resume.ts"; import { resume } from "./resume.ts";
import { sendShardMessage } from "./send_shard_message.ts";
import { ws } from "./ws.ts"; import { ws } from "./ws.ts";
/** Handler for handling every message event from websocket. */ /** Handler for handling every message event from websocket. */
@@ -38,11 +39,10 @@ export async function handleOnMessage(message: any, shardId: number) {
shard.heartbeat.lastSentAt = Date.now(); shard.heartbeat.lastSentAt = Date.now();
// Discord randomly sends this requiring an immediate heartbeat back // Discord randomly sends this requiring an immediate heartbeat back
shard.queue.unshift({ sendShardMessage(shard, {
op: DiscordGatewayOpcodes.Heartbeat, op: DiscordGatewayOpcodes.Heartbeat,
d: shard?.previousSequenceNumber, d: shard?.previousSequenceNumber,
}); }, true);
ws.processQueue(shard.id);
break; break;
case DiscordGatewayOpcodes.Hello: case DiscordGatewayOpcodes.Hello:
ws.heartbeat( ws.heartbeat(