Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-26 16:46:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

refactor: remove invalid queued items

Browse Source 
catch invalid json in payload
This commit is contained in:
Barış Soner Uşaklı
2025-08-28 12:39:44 -04:00
parent 5f7085f34d
commit b73ee309e0
1 changed files with 20 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
src/activitypub/index.js
View File

@@ -441,20 +441,34 @@ ActivityPub.send = async (type, id, targets, payload) => {
async function retryFailedMessages() {
const queueIds = await db.getSortedSetRangeByScore('ap:retry:queue', 0, 50, '-inf', Date.now());
const queuedData = (await db.getObjects(queueIds.map(id => `ap:retry:queue:${id}`))).filter(Boolean);
const queuedData = (await db.getObjects(queueIds.map(id => `ap:retry:queue:${id}`)));
const retryQueueAdd = [];
const retryQueuedSet = [];
const queueIdsToRemove = [];
const oneMinute = 1000 * 60;
await Promise.all(queuedData.map(async (data) => {
const { queueId, uri, id, type, attempts, payload } = data;
const payloadObj = JSON.parse(payload);
await Promise.all(queuedData.map(async (data, index) => {
const queueId = queueIds[index];
if (!data) {
queueIdsToRemove.push(queueId);
return;
}
const { uri, id, type, attempts, payload } = data;
if (!uri || !id || !type || !payload || attempts > 10) {
queueIdsToRemove.push(queueId);
return;
}
let payloadObj;
try {
payloadObj = JSON.parse(payload);
} catch (err) {
queueIdsToRemove.push(queueId);
return;
}
const ok = await sendMessage(uri, id, type, payloadObj);
if (ok || attempts > 10) {
if (ok) {
queueIdsToRemove.push(queueId);
} else {
const nextAttempt = (parseInt(attempts, 10) || 0) + 1;