Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-26 16:46:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: maybe last tweak

Browse Source
This commit is contained in:
Julian Lam
2024-04-04 13:02:16 -04:00
parent ae146024af
commit 42bdffdc94
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/upgrades/4.0.0/remote_user_urls.js
View File

@@ -13,10 +13,15 @@ module.exports = {
const { progress } = this; const { progress } = this;
const interval = 1500; const interval = 1500;
await batch.processSortedSet('usersRemote:lastCrawled', async (ids) => { let actorIds = await db.getSortedSetMembers('usersRemote:lastCrawled');
const exists = await Promise.all(ids.map(async id => await db.isObjectField(`userRemote:${id}`, 'url'))); progress.total = actorIds.length;
ids = ids.filter((id, idx) => exists[idx]); const exists = await Promise.all(actorIds.map(async id => await db.isObjectField(`userRemote:${id}`, 'url')));
actorIds = actorIds.filter((id, idx) => exists[idx]);
// Increment ones that were already completed
progress.incr(progress.total - actorIds.length);
await batch.processArray(actorIds, async (ids) => {
try { try {
await activitypub.actors.assert(ids, { update: true }); await activitypub.actors.assert(ids, { update: true });
} catch (e) { } catch (e) {