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

fix: closes #13620

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2025-08-27 00:06:32 -04:00
parent 5ee1fd02bb
commit 027d6f307c
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/activitypub/index.js
View File

@@ -16,6 +16,7 @@ const utils = require('../utils');
const ttl = require('../cache/ttl'); const ttl = require('../cache/ttl');
const batch = require('../batch'); const batch = require('../batch');
const analytics = require('../analytics'); const analytics = require('../analytics');
const crypto = require('crypto');
const requestCache = ttl({ const requestCache = ttl({
name: 'ap-request-cache', name: 'ap-request-cache',
@@ -410,7 +411,7 @@ ActivityPub.send = async (type, id, targets, payload) => {
await Promise.all(inboxBatch.map(async (uri) => { await Promise.all(inboxBatch.map(async (uri) => {
const ok = await sendMessage(uri, id, type, payload); const ok = await sendMessage(uri, id, type, payload);
if (!ok) { if (!ok) {
const queueId = `${payload.type}:${payload.id}:${new URL(uri).hostname}`; const queueId = crypto.createHash('sha256').update(`${type}:${id}:${uri}`).digest('hex');
const nextTryOn = Date.now() + oneMinute; const nextTryOn = Date.now() + oneMinute;
retryQueueAdd.push(['ap:retry:queue', nextTryOn, queueId]); retryQueueAdd.push(['ap:retry:queue', nextTryOn, queueId]);
retryQueuedSet.push([`ap:retry:queue:${queueId}`, { retryQueuedSet.push([`ap:retry:queue:${queueId}`, {