| 123456789101112131415161718192021222324252627282930 |
- const cron = require('node-cron');
- const { annoyUsers } = require('server/routes/annoy');
- function setupCron(config, db, logger) {
- if (!config.schedule) {
- logger.warn('Not setting up schedule as it is not defined. Please define the SCHEDULE_ANNOY env variable as a cron schedule, e.g. SCHEDULE_ANNOY=10 1 * * *');
- return;
- }
- const task = async () => {
- logger.verbose('Running annoy on schedule!');
- await annoyUsers(config, db, logger);
- };
- const schedules = config.schedule.split(',');
- schedules.forEach(schedule => {
- logger.verbose('Scheduling annoy at', schedule);
- cron.schedule(schedule, task);
- });
- }
- module.exports = {
- setupCron
- };
|