summary refs log tree commit diff
diff options
context:
space:
mode:
authorRory& <root@rory.gay>2026-03-11 01:42:59 +0100
committerRory& <root@rory.gay>2026-03-11 01:51:31 +0100
commited315b028b54054c96f8b83f04553edd8643bd37 (patch)
tree8919bcdeb69d1ee5f346fa9c9e4200ae63a830c7
parentrequestguildmembers: bulk query sessions (diff)
downloadserver-ts-ed315b028b54054c96f8b83f04553edd8643bd37.tar.xz
requestguildmembers: log chunks
-rw-r--r--src/gateway/opcodes/RequestGuildMembers.ts9
1 files changed, 7 insertions, 2 deletions
diff --git a/src/gateway/opcodes/RequestGuildMembers.ts b/src/gateway/opcodes/RequestGuildMembers.ts

index b87481f6..046eefab 100644 --- a/src/gateway/opcodes/RequestGuildMembers.ts +++ b/src/gateway/opcodes/RequestGuildMembers.ts
@@ -127,7 +127,8 @@ export async function onRequestGuildMembers(this: WebSocket, { d }: Payload) { nonce, }; - const chunkCount = Math.ceil(members.length / 1000); + const chunkSize = 1000; + const chunkCount = Math.ceil(members.length / chunkSize); let notFound: string[] = []; if (user_ids && user_ids.length > 0) notFound = user_ids.filter((id) => !members.some((member) => member.id == id)); @@ -136,7 +137,7 @@ export async function onRequestGuildMembers(this: WebSocket, { d }: Payload) { const chunks: GuildMembersChunkEvent["data"][] = []; while (members.length > 0) { - const chunk: Member[] = members.splice(0, 1000); + const chunk: Member[] = members.splice(0, chunkSize); const presenceList: Presence[] = []; if (presences) { @@ -163,6 +164,10 @@ export async function onRequestGuildMembers(this: WebSocket, { d }: Payload) { chunk_index: chunks.length, chunk_count: chunkCount, }); + + console.log( + `[Gateway/${this.user_id}] REQUEST_GUILD_MEMBERS @ ${Date.now() - startTime}ms for guild ${guild_id}: pushed ${chunks.length}/${chunkCount} chunks (${members.length} total members considered)`, + ); } if (chunks.length == 0) {