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

update fix_username_zsets upgrade script

Browse Source 
to show progress while deleting
This commit is contained in:
Barış Soner Uşaklı
2026-03-13 19:53:35 -04:00
parent 533ae69c46
commit 6c3daebbce
1 changed files with 22 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/upgrades/3.2.0/fix_username_zsets.js
View File

@@ -11,9 +11,28 @@ module.exports = {
method: async function () {
const { progress } = this;
await db.deleteAll(['username:uid', 'username:sorted']);
const [userNameUid, usernameSorted, usersJoindate] = await db.sortedSetsCard([
'username:uid', 'username:sorted', 'users:joindate',
]);
progress.total = userNameUid + usernameSorted + usersJoindate;
await batch.processSortedSet('username:uid', async (usernames) => {
await db.sortedSetRemove('username:uid', usernames);
progress.incr(usernames.length);
}, {
batch: 500,
alwaysStartAt: 0,
});
await batch.processSortedSet('username:sorted', async (usernames) => {
await db.sortedSetRemove('username:sorted', usernames);
progress.incr(usernames.length);
}, {
batch: 500,
alwaysStartAt: 0,
});
await batch.processSortedSet('users:joindate', async (uids) => {
progress.incr(uids.length);
const usersData = await db.getObjects(uids.map(uid => `user:${uid}`));
const bulkAdd = [];
usersData.forEach((userData) => {
@@ -23,9 +42,9 @@ module.exports = {
}
});
await db.sortedSetAddBulk(bulkAdd);
progress.incr(uids.length);
}, {
batch: 500,
progress: progress,
});
},
};