Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-03-03 11:01:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: export sendMessage as _sendMessage for use in ap jobs lib

Browse Source
This commit is contained in:
Julian Lam
2026-01-15 15:39:46 -05:00
parent c595edb4c0
commit 4bab9fb446
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/activitypub/index.js
View File

@@ -355,7 +355,7 @@ ActivityPub.get = async (type, id, uri, options) => {
} }
}; };
async function sendMessage(uri, id, type, payload) { ActivityPub._sendMessage = async function (uri, id, type, payload) {
try { try {
const keyData = await ActivityPub.getPrivateKey(type, id); const keyData = await ActivityPub.getPrivateKey(type, id);
const headers = await ActivityPub.sign(keyData, uri, payload); const headers = await ActivityPub.sign(keyData, uri, payload);
@@ -381,7 +381,7 @@ async function sendMessage(uri, id, type, payload) {
ActivityPub.helpers.log(`[activitypub/send] Could not send ${payload.type} to ${uri}; error: ${e.message}`); ActivityPub.helpers.log(`[activitypub/send] Could not send ${payload.type} to ${uri}; error: ${e.message}`);
return false; return false;
} }
} };
ActivityPub.send = async (type, id, targets, payload) => { ActivityPub.send = async (type, id, targets, payload) => {
if (!meta.config.activitypubEnabled) { if (!meta.config.activitypubEnabled) {
@@ -415,7 +415,7 @@ ActivityPub.send = async (type, id, targets, payload) => {
const retryQueuedSet = []; const retryQueuedSet = [];
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 ActivityPub._sendMessage(uri, id, type, payload);
if (!ok) { if (!ok) {
const queueId = crypto.createHash('sha256').update(`${type}:${id}:${uri}`).digest('hex'); const queueId = crypto.createHash('sha256').update(`${type}:${id}:${uri}`).digest('hex');
const nextTryOn = Date.now() + oneMinute; const nextTryOn = Date.now() + oneMinute;

2
src/activitypub/jobs.js
View File

@@ -65,7 +65,7 @@ async function retryFailedMessages() {
queueIdsToRemove.push(queueId); queueIdsToRemove.push(queueId);
return; return;
} }
const ok = await sendMessage(uri, id, type, payloadObj); const ok = await activitypub._sendMessage(uri, id, type, payloadObj);
if (ok) { if (ok) {
queueIdsToRemove.push(queueId); queueIdsToRemove.push(queueId);
} else { } else {