Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-07-04 15:58:17 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' into develop

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2026-01-25 19:56:17 -05:00
parent 5c15a0db7d a82f18ccfb
commit 561e0284df
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/upgrades/4.8.2/clean_ap_tids_from_topic_zsets.js
View File

@@ -5,7 +5,7 @@ const batch = require('../../batch');
const utils = require('../../utils'); const utils = require('../../utils');
module.exports = { module.exports = {
name: 'Remote AP tids from topics:recent, topics:views, topics:posts, topics:votes zsets', name: 'Remove AP tids from topics:recent, topics:views, topics:posts, topics:votes zsets',
timestamp: Date.UTC(2026, 0, 25), timestamp: Date.UTC(2026, 0, 25),
method: async function () { method: async function () {
const { progress } = this; const { progress } = this;
@@ -14,7 +14,7 @@ module.exports = {
]); ]);
progress.total = recent + views + posts + votes; progress.total = recent + views + posts + votes;
async function cleanupSet(setName, count) { async function cleanupSet(setName) {
const tidsToRemove = []; const tidsToRemove = [];
await batch.processSortedSet(setName, async (tids) => { await batch.processSortedSet(setName, async (tids) => {
const topicData = await db.getObjectsFields(tids.map(tid => `topic:${tid}`), ['tid', 'cid']); const topicData = await db.getObjectsFields(tids.map(tid => `topic:${tid}`), ['tid', 'cid']);
@@ -22,7 +22,7 @@ module.exports = {
t => t && (!t.cid || !utils.isNumber(t.cid) || t.cid === -1) t => t && (!t.cid || !utils.isNumber(t.cid) || t.cid === -1)
).map(t => t.tid); ).map(t => t.tid);
tidsToRemove.push(...batchTids); tidsToRemove.push(...batchTids);
progress.incr(batchTids.length); progress.incr(tids.length);
}, { }, {
batch: 500, batch: 500,
}); });
@@ -32,11 +32,11 @@ module.exports = {
}, { }, {
batch: 500, batch: 500,
}); });
progress.incr(count);
} }
await cleanupSet('topics:recent', recent); await cleanupSet('topics:recent');
await cleanupSet('topics:views', views); await cleanupSet('topics:views');
await cleanupSet('topics:posts', posts); await cleanupSet('topics:posts');
await cleanupSet('topics:votes', votes); await cleanupSet('topics:votes');
}, },
}; };