From 1bce4879651ee9769db7832c797b7c5338491ff9 Mon Sep 17 00:00:00 2001 From: Johann150 Date: Sat, 11 Mar 2023 01:05:31 +0100 Subject: [PATCH] activitypub: allow to group elements for delivery --- packages/backend/src/queue/processors/deliver.ts | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/packages/backend/src/queue/processors/deliver.ts b/packages/backend/src/queue/processors/deliver.ts index 234d546fd..c581942c7 100644 --- a/packages/backend/src/queue/processors/deliver.ts +++ b/packages/backend/src/queue/processors/deliver.ts @@ -19,8 +19,13 @@ export default async (job: Bull.Job) => { if (await shouldSkipInstance(puny)) return 'skip'; try { - - await request(job.data.user, job.data.to, job.data.content); + if (Array.isArray(job.data.content)) { + await Promise.all( + job.data.content.map(x => request(job.data.user, job.data.to, x)) + ); + } else { + await request(job.data.user, job.data.to, job.data.content); + } // Update stats registerOrFetchInstanceDoc(host).then(i => {