mirror of
https://github.com/NodeBB/NodeBB.git
synced 2025-10-26 16:46:12 +01:00
fix: Notes.delete to delete announcer zsets too
This commit is contained in:
@@ -364,15 +364,11 @@ Notes.delete = async (pids) => {
|
|||||||
pids = [pids];
|
pids = [pids];
|
||||||
}
|
}
|
||||||
|
|
||||||
// Valid and remote content only
|
|
||||||
pids = pids.filter(pid => !utils.isNumber(pid));
|
|
||||||
const exists = await posts.exists(pids);
|
const exists = await posts.exists(pids);
|
||||||
pids = pids.filter((_, idx) => exists[idx]);
|
pids = pids.filter((_, idx) => exists[idx]);
|
||||||
|
|
||||||
let tids = await posts.getPostsFields(pids, ['tid']);
|
|
||||||
tids = new Set(tids.map(obj => obj.tid));
|
|
||||||
|
|
||||||
const recipientSets = pids.map(id => `post:${id}:recipients`);
|
const recipientSets = pids.map(id => `post:${id}:recipients`);
|
||||||
await db.deleteAll(recipientSets);
|
const announcerSets = pids.map(id => `pid:${id}:announces`);
|
||||||
await Promise.all(Array.from(tids).map(async tid => Notes.syncUserInboxes(tid)));
|
|
||||||
|
await db.deleteAll([...recipientSets, ...announcerSets]);
|
||||||
};
|
};
|
||||||
|
|||||||
Reference in New Issue
Block a user