Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-02-28 01:21:13 +01:00
Code Issues Packages Projects Releases Wiki Activity

feat: add additional logic that checks whether a cid follows the activity actor, and asserts note into that category if so

Browse Source 
closes #13232
This commit is contained in:
Julian Lam
2025-03-06 10:45:30 -05:00
parent 4324857836
commit 3589c570b5
1 changed files with 16 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/activitypub/inbox.js
View File

@@ -33,7 +33,7 @@ function reject(type, object, target, senderType = 'uid', id = 0) {
} }
inbox.create = async (req) => { inbox.create = async (req) => {
const { object } = req.body; const { object, actor } = req.body;
// Alternative logic for non-public objects // Alternative logic for non-public objects
const isPublic = [...(object.to || []), ...(object.cc || [])].includes(activitypub._constants.publicAddress); const isPublic = [...(object.to || []), ...(object.cc || [])].includes(activitypub._constants.publicAddress);
@@ -41,7 +41,13 @@ inbox.create = async (req) => {
return await activitypub.notes.assertPrivate(object); return await activitypub.notes.assertPrivate(object);
} }
const asserted = await activitypub.notes.assert(0, object); const { cids } = await activitypub.actors.getLocalFollowers(actor);
let cid = null;
if (cids.size > 0) {
cid = Array.from(cids)[0];
}
const asserted = await activitypub.notes.assert(0, object, { cid });
if (asserted) { if (asserted) {
activitypub.feps.announce(object.id, req.body); activitypub.feps.announce(object.id, req.body);
api.activitypub.add(req, { pid: object.id }); api.activitypub.add(req, { pid: object.id });
@@ -111,7 +117,13 @@ inbox.update = async (req) => {
return await activitypub.notes.assertPrivate(object); return await activitypub.notes.assertPrivate(object);
} }
const asserted = await activitypub.notes.assert(0, object.id); const { cids } = await activitypub.actors.getLocalFollowers(actor);
let cid = null;
if (cids.size > 0) {
cid = Array.from(cids)[0];
}
const asserted = await activitypub.notes.assert(0, object.id, { cid });
if (asserted) { if (asserted) {
activitypub.feps.announce(object.id, req.body); activitypub.feps.announce(object.id, req.body);
} }
@@ -291,7 +303,7 @@ inbox.announce = async (req) => {
return; return;
} }
const assertion = await activitypub.notes.assert(0, pid, { cid, skipChecks: true }); // checks skipped; done above. const assertion = await activitypub.notes.assert(0, pid, { cid });
if (!assertion) { if (!assertion) {
return; return;
} }