Joplin
/
joplin
mirror of https://github.com/laurent22/joplin.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Server: Improved logging and reliability of cron tasks

pull/5156/head
Laurent Cozic 2021-07-03 19:23:43 +01:00
parent 7d9a222fbb
commit d99c34f1dd
1 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
packages/server/src/services/CronService.ts
View File

@ -4,21 +4,26 @@ const cron = require('node-cron');
const logger = Logger.create('cron');
async function runCronTask(name: string, callback: Function) {
const startTime = Date.now();
logger.info(`Running task "${name}"`);
try {
await callback();
} catch (error) {
logger.error(`On task "${name}"`, error);
}
logger.info(`Completed task "${name}" in ${Date.now() - startTime}ms`);
}
export default class CronService extends BaseService {
public async runInBackground() {
cron.schedule('0 */6 * * *', async () => {
const startTime = Date.now();
logger.info('Deleting expired tokens...');
await this.models.token().deleteExpiredTokens();
logger.info(`Expired tokens deleted in ${Date.now() - startTime}ms`);
await runCronTask('deleteExpiredTokens', async () => this.models.token().deleteExpiredTokens());
});
cron.schedule('0 * * * *', async () => {
const startTime = Date.now();
logger.info('Updating total sizes...');
await this.models.item().updateTotalSizes();
logger.info(`Total sizes updated in ${Date.now() - startTime}ms`);
await runCronTask('updateTotalSizes', async () => this.models.item().updateTotalSizes());
});
}