Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-31 19:15:58 +01:00
Code Issues Packages Projects Releases Wiki Activity

refactor: use batch.processArray for sending AP messages

Browse Source
This commit is contained in:
Opliko
2024-05-06 22:52:48 +02:00
parent 50bc9a37c5
commit ea6e15bf08
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/activitypub/index.js
View File

@@ -11,6 +11,7 @@ const user = require('../user');
const utils = require('../utils'); const utils = require('../utils');
const ttl = require('../cache/ttl'); const ttl = require('../cache/ttl');
const lru = require('../cache/lru'); const lru = require('../cache/lru');
const batch = require('../batch');
const requestCache = ttl({ ttl: 1000 * 60 * 5 }); // 5 minutes const requestCache = ttl({ ttl: 1000 * 60 * 5 }); // 5 minutes
const ActivityPub = module.exports; const ActivityPub = module.exports;
@@ -302,5 +303,8 @@ ActivityPub.send = async (type, id, targets, payload) => {
...payload, ...payload,
}; };
await Promise.all(inboxes.map(async uri => sendMessage(uri, id, type, payload))); await batch.processArray(
inboxes,
async inboxBatch => Promise.all(inboxBatch.map(async uri => sendMessage(uri, id, type, payload)))
);
}; };