Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-02-04 21:59:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: use batch.processArray properly

Browse Source
This commit is contained in:
Opliko
2024-05-06 23:06:06 +02:00
parent ea6e15bf08
commit 729f0fcac1
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/activitypub/index.js
View File

@@ -284,6 +284,8 @@ async function sendMessage(uri, id, type, payload, attempts = 1) {
ActivityPub.retryQueue.set(queueId, timeoutId); ActivityPub.retryQueue.set(queueId, timeoutId);
winston.verbose(`[activitypub/send] Added ${payload.type} to ${uri} to retry queue for ${timeout}ms`); winston.verbose(`[activitypub/send] Added ${payload.type} to ${uri} to retry queue for ${timeout}ms`);
} else {
winston.warn(`[activitypub/send] Max attempts reached for ${payload.type} to ${uri}; giving up on sending`);
} }
} }
} }
@@ -305,6 +307,10 @@ ActivityPub.send = async (type, id, targets, payload) => {
await batch.processArray( await batch.processArray(
inboxes, inboxes,
async inboxBatch => Promise.all(inboxBatch.map(async uri => sendMessage(uri, id, type, payload))) async inboxBatch => Promise.all(inboxBatch.map(async uri => sendMessage(uri, id, type, payload))),
{
batch: 50,
interval: 100,
},
); );
}; };