diff --git a/src/ws/identify.ts b/src/ws/identify.ts index eefe04226..aa077638b 100644 --- a/src/ws/identify.ts +++ b/src/ws/identify.ts @@ -33,7 +33,7 @@ export async function identify(shardId: number, maxShards: number) { }, queue: [], processingQueue: false, - queueMinuteTimestamp: Date.now(), + queueStartedAt: Date.now(), }); socket.onopen = () => { diff --git a/src/ws/process_queue.ts b/src/ws/process_queue.ts index 2782d6447..218f189a4 100644 --- a/src/ws/process_queue.ts +++ b/src/ws/process_queue.ts @@ -17,8 +17,8 @@ export async function processQueue(id: number) { } const now = Date.now(); - if (now - shard.queueMinuteTimestamp >= 60000) { - shard.queueMinuteTimestamp = now; + if (now - shard.queueStartedAt >= 60000) { + shard.queueStartedAt = now; counter = 0; } diff --git a/src/ws/resume.ts b/src/ws/resume.ts index c8d2e1d16..e448b5e45 100644 --- a/src/ws/resume.ts +++ b/src/ws/resume.ts @@ -43,7 +43,7 @@ export async function resume(shardId: number) { }, queue: oldShard?.queue || [], processingQueue: false, - queueMinuteTimestamp: Date.now(), + queueStartedAt: Date.now(), }); // Resume on open diff --git a/src/ws/ws.ts b/src/ws/ws.ts index 22fc68d68..7af2baa8b 100644 --- a/src/ws/ws.ts +++ b/src/ws/ws.ts @@ -146,7 +146,7 @@ export interface DiscordenoShard { /** Whether or not the queue for this shard is being processed. */ processingQueue: boolean; /** When the first request for this minute has been sent. */ - queueMinuteTimestamp: number; + queueStartedAt: number; } export interface WebSocketRequest {