From 027d6f307c8ef7b5d6a6b6ef5c309b44e515d25b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bar=C4=B1=C5=9F=20Soner=20U=C5=9Fakl=C4=B1?= Date: Wed, 27 Aug 2025 00:06:32 -0400 Subject: [PATCH] fix: closes #13620 --- src/activitypub/index.js | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/activitypub/index.js b/src/activitypub/index.js index bc4b66bf53..f413b9f644 100644 --- a/src/activitypub/index.js +++ b/src/activitypub/index.js @@ -16,6 +16,7 @@ const utils = require('../utils'); const ttl = require('../cache/ttl'); const batch = require('../batch'); const analytics = require('../analytics'); +const crypto = require('crypto'); const requestCache = ttl({ name: 'ap-request-cache', @@ -410,7 +411,7 @@ ActivityPub.send = async (type, id, targets, payload) => { await Promise.all(inboxBatch.map(async (uri) => { const ok = await sendMessage(uri, id, type, payload); 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; retryQueueAdd.push(['ap:retry:queue', nextTryOn, queueId]); retryQueuedSet.push([`ap:retry:queue:${queueId}`, {