activitypub: allow to group elements for delivery

2023-03-11 01:05:31 +01:00 · 2023-03-11 01:05:31 +01:00 · 1bce487965
parent 78c93c5539
commit 1bce487965
1 changed files with 7 additions and 2 deletions
--- 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<DeliverJobData>) => {
 	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 => {