Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-02-26 16:41:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: biweekly digest #8053

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2021-10-19 12:21:54 -04:00
parent 44687394dc
commit 9cb4de50a2
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/user/jobs.js
View File

@@ -25,29 +25,25 @@ module.exports = function (User) {
startDigestJob('digest.daily', `0 ${digestHour} * * *`, 'day'); startDigestJob('digest.daily', `0 ${digestHour} * * *`, 'day');
startDigestJob('digest.weekly', `0 ${digestHour} * * 0`, 'week'); startDigestJob('digest.weekly', `0 ${digestHour} * * 0`, 'week');
startDigestJob('digest.biweekly', `0 ${digestHour} * * 0`, 'week');
startDigestJob('digest.monthly', `0 ${digestHour} 1 * *`, 'month'); startDigestJob('digest.monthly', `0 ${digestHour} 1 * *`, 'month');
started += 3;
jobs['reset.clean'] = new cronJob('0 0 * * *', User.reset.clean, null, true); jobs['reset.clean'] = new cronJob('0 0 * * *', User.reset.clean, null, true);
winston.verbose('[user/jobs] Starting job (reset.clean)'); winston.verbose('[user/jobs] Starting job (reset.clean)');
started += 1;
winston.verbose(`[user/jobs] ${started} jobs started`); winston.verbose(`[user/jobs] jobs started`);
}; };
function startDigestJob(name, cronString, term) { function startDigestJob(name, cronString, term) {
jobs[name] = new cronJob(cronString, (async () => { jobs[name] = new cronJob(cronString, (async () => {
winston.verbose(`[user/jobs] Digest job (${name}) started.`); winston.verbose(`[user/jobs] Digest job (${name}) started.`);
try { try {
if (name === 'digest.biweekly') { if (name === 'digest.weekly') {
const counter = await db.increment('biweeklydigestcounter'); const counter = await db.increment('biweeklydigestcounter');
if (counter % 2) { if (counter % 2) {
await User.digest.execute({ interval: term }); await User.digest.execute({ interval: 'biweek' });
} }
} else {
await User.digest.execute({ interval: term });
} }
await User.digest.execute({ interval: term });
} catch (err) { } catch (err) {
winston.error(err.stack); winston.error(err.stack);
} }