From 6afb040ffd375e2371f85153438d9637b6a3ae6a Mon Sep 17 00:00:00 2001 From: Lea Date: Sat, 26 Aug 2023 21:12:21 +0200 Subject: [PATCH] fix: send alerts in chunks --- lib/actions.ts | 32 ++++++++++++++++++-------------- 1 file changed, 18 insertions(+), 14 deletions(-) diff --git a/lib/actions.ts b/lib/actions.ts index 567f597..cca188f 100644 --- a/lib/actions.ts +++ b/lib/actions.ts @@ -720,21 +720,25 @@ export async function quarantineServer(serverId: string, message: string) { id: serverId, }); - await Promise.allSettled( - members.map(async (member) => { - const messageId = ulid(); + while (members.length) { + const m = members.splice(0, 50); - let dm = await findDM(PLATFORM_MOD_ID, member._id.user); - if (!dm) dm = await createDM(PLATFORM_MOD_ID, member._id.user, messageId); - - await sendChatMessage({ - _id: messageId, - author: PLATFORM_MOD_ID, - channel: dm._id, - content: message, - }); - }) - ); + await Promise.allSettled( + m.map(async (member) => { + const messageId = ulid(); + + let dm = await findDM(PLATFORM_MOD_ID, member._id.user); + if (!dm) dm = await createDM(PLATFORM_MOD_ID, member._id.user, messageId); + + await sendChatMessage({ + _id: messageId, + author: PLATFORM_MOD_ID, + channel: dm._id, + content: message, + }); + }) + ); + } } export async function deleteInvite(invite: string) {