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

refactor: catch errors from digest

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2021-10-18 20:17:35 -04:00
parent f7967bdf68
commit 8e319a9b25
2 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/user/digest.js
View File

@@ -38,6 +38,7 @@ Digest.execute = async function (payload) {
winston.info(`[user/jobs] Digest (${payload.interval}) complete.`);
} catch (err) {
winston.error(`[user/jobs] Could not send digests (${payload.interval})\n${err.stack}`);
throw err;
}
};

16
src/user/jobs.js
View File

@@ -39,13 +39,17 @@ module.exports = function (User) {
function startDigestJob(name, cronString, term) {
jobs[name] = new cronJob(cronString, (async () => {
winston.verbose(`[user/jobs] Digest job (${name}) started.`);
if (name === 'digest.biweekly') {
const counter = await db.increment('biweeklydigestcounter');
if (counter % 2) {
User.digest.execute({ interval: term });
try {
if (name === 'digest.biweekly') {
const counter = await db.increment('biweeklydigestcounter');
if (counter % 2) {
await User.digest.execute({ interval: term });
}
} else {
await User.digest.execute({ interval: term });
}
} else {
User.digest.execute({ interval: term });
} catch (err) {
winston.error(err.stack);
}
}), null, true);
winston.verbose(`[user/jobs] Starting job (${name})`);