Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-01-16 20:42:58 +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 57a336b2d8
commit b2973fd8a1
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
const { cids } = await activitypub.actors.getLocalFollowers(actor);
let cid = null;
if (cids.size > 0) {
cid = Array.from(cids)[0];
}
const syncedCids = Array.from(cids);
// 1b12 announce
let cid = null;
const categoryActor = await categories.exists(actor);
if (categoryActor) {
cid = actor;
@@ -448,7 +446,7 @@ inbox.announce = async (req) => {
socketHelpers.sendNotificationToPostOwner(pid, actor, 'announce', 'notifications:activitypub.announce');
} else { // Remote object
// Follower check
if (!fromRelay && !cid) {
if (!fromRelay && !cid && !syncedCids.length) {
const { followers } = await activitypub.actors.getLocalFollowCounts(actor);
if (!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);
await activitypub.notes.updateLocalRecipients(pid, { to, cc });
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