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

fix: update category sync logic to utilise crossposts instead

Browse Source
This commit is contained in:
Julian Lam
2025-12-29 15:08:04 -05:00
parent 28249efbe6
commit e5ee52e5da
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/activitypub/inbox.js
View File

@@ -388,12 +388,10 @@ inbox.announce = async (req) => {
// Category sync, remove when cross-posting available // Category sync, remove when cross-posting available
const { cids } = await activitypub.actors.getLocalFollowers(actor); const { cids } = await activitypub.actors.getLocalFollowers(actor);
let cid = null; const syncedCids = Array.from(cids);
if (cids.size > 0) {
cid = Array.from(cids)[0];
}
// 1b12 announce // 1b12 announce
let cid = null;
const categoryActor = await categories.exists(actor); const categoryActor = await categories.exists(actor);
if (categoryActor) { if (categoryActor) {
cid = actor; cid = actor;
@@ -448,7 +446,7 @@ inbox.announce = async (req) => {
socketHelpers.sendNotificationToPostOwner(pid, actor, 'announce', 'notifications:activitypub.announce'); socketHelpers.sendNotificationToPostOwner(pid, actor, 'announce', 'notifications:activitypub.announce');
} else { // Remote object } else { // Remote object
// Follower check // Follower check
if (!fromRelay && !cid) { if (!fromRelay && !cid && !syncedCids.length) {
const { followers } = await activitypub.actors.getLocalFollowCounts(actor); const { followers } = await activitypub.actors.getLocalFollowCounts(actor);
if (!followers) { if (!followers) {
winston.verbose(`[activitypub/inbox.announce] Rejecting ${object.id} via ${actor} due to no followers`); winston.verbose(`[activitypub/inbox.announce] Rejecting ${object.id} via ${actor} due to no followers`);
@@ -471,6 +469,12 @@ inbox.announce = async (req) => {
({ tid } = assertion); ({ tid } = assertion);
await activitypub.notes.updateLocalRecipients(pid, { to, cc }); await activitypub.notes.updateLocalRecipients(pid, { to, cc });
await activitypub.notes.syncUserInboxes(tid); await activitypub.notes.syncUserInboxes(tid);
if (syncedCids) {
await Promise.all(syncedCids.map(async (cid) => {
await topics.crossposts.add(tid, cid, 0);
}));
}
} }
if (!cid) { // Topic events from actors followed by users only if (!cid) { // Topic events from actors followed by users only