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

fix: update follower/following counts after removing uid from zsets

Browse Source 
use batch instead of async.each
This commit is contained in:
Barış Soner Uşaklı
2024-06-19 10:15:31 -04:00
parent b98333f38c
commit 6f6cfb1a5a
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/user/delete.js
View File

@@ -209,18 +209,22 @@ module.exports = function (User) {
]); ]);
async function updateCount(uids, name, fieldName) { async function updateCount(uids, name, fieldName) {
await async.each(uids, async (uid) => { await batch.processArray(uids, async (uids) => {
let count = await db.sortedSetCard(name + uid); const counts = await db.sortedSetsCard(uids.map(uid => name + uid));
count = parseInt(count, 10) || 0; const bulkSet = counts.map(
await db.setObjectField(`user:${uid}`, fieldName, count); (count, index) => ([`user:${uids[index]}`, { [fieldName]: count || 0 }])
);
await db.setObjectBulk(bulkSet);
}, {
batch: 500,
}); });
} }
const followingSets = followers.map(uid => `following:${uid}`); const followingSets = followers.map(uid => `following:${uid}`);
const followerSets = following.map(uid => `followers:${uid}`); const followerSets = following.map(uid => `followers:${uid}`);
await db.sortedSetsRemove(followerSets.concat(followingSets), uid);
await Promise.all([ await Promise.all([
db.sortedSetsRemove(followerSets.concat(followingSets), uid),
updateCount(following, 'followers:', 'followerCount'), updateCount(following, 'followers:', 'followerCount'),
updateCount(followers, 'following:', 'followingCount'), updateCount(followers, 'following:', 'followingCount'),
]); ]);