perf: single db call to add all uids

This commit is contained in:
Barış Soner Uşaklı
2021-02-10 00:58:07 -05:00
parent a5fa212fc7
commit 90d5c9da44

View File

@@ -140,11 +140,11 @@ Digest.send = async function (data) {
interval: data.interval, interval: data.interval,
showUnsubscribe: true, showUnsubscribe: true,
}).catch(err => winston.error(`[user/jobs] Could not send digest email\n[emailer.send] ${err.stack}`)); }).catch(err => winston.error(`[user/jobs] Could not send digest email\n[emailer.send] ${err.stack}`));
if (data.interval !== 'alltime') {
await db.sortedSetAdd('digest:delivery', now.getTime(), userObj.uid);
}
})); }));
if (data.interval !== 'alltime') {
const now = Date.now();
await db.sortedSetAdd('digest:delivery', userData.map(() => now), userData.map(u => u.uid));
}
}, { }, {
interval: 1000, interval: 1000,
batch: 100, batch: 100,