Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-31 19:15:58 +01:00
Code Issues Packages Projects Releases Wiki Activity

Revert "refactor: use getSortedSetUnion in syncUserInboxes instead"

Browse Source 
This reverts commit 6c1a0fb1dc.
This commit is contained in:
Julian Lam
2024-03-26 16:41:51 -04:00
parent f078e1e267
commit a38d0c14ab
1 changed files with 4 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/activitypub/notes.js
View File

@@ -318,15 +318,12 @@ Notes.syncUserInboxes = async function (tid) {
]); ]);
pids.unshift(mainPid); pids.unshift(mainPid);
const uids = await db.getSortedSetUnion({ const recipients = await db.getSetsMembers(pids.map(id => `post:${id}:recipients`));
sets: pids.map(id => `post:${id}:recipients`), const uids = recipients.reduce((set, uids) => new Set([...set, ...uids.map(u => parseInt(u, 10))]), new Set());
start: 0, const keys = Array.from(uids).map(uid => `uid:${uid}:inbox`);
stop: -1,
});
const keys = uids.map(uid => `uid:${uid}:inbox`);
const score = await db.sortedSetScore(`cid:${cid}:tids`, tid); const score = await db.sortedSetScore(`cid:${cid}:tids`, tid);
winston.verbose(`[activitypub/syncUserInboxes] Syncing tid ${tid} with ${uids.length} inboxes`); winston.verbose(`[activitypub/syncUserInboxes] Syncing tid ${tid} with ${uids.size} inboxes`);
await db.sortedSetsAdd(keys, keys.map(() => score || Date.now()), tid); await db.sortedSetsAdd(keys, keys.map(() => score || Date.now()), tid);
}; };