import { SyncedCron } from 'meteor/percolatestudio:synced-cron'; import moment from 'moment'; import Newsletter from '../namespace.js'; import { getSetting } from 'meteor/nova:core'; const defaultFrequency = [1]; // every monday const defaultTime = '00:00'; // GMT SyncedCron.options = { log: true, collectionName: 'cronHistory', utc: false, collectionTTL: 172800 }; const addZero = num => { return num < 10 ? "0"+num : num; }; var getSchedule = function (parser) { var frequency = getSetting('newsletterFrequency', defaultFrequency); var recur = parser.recur(); var schedule; // Default is once a week (Mondays) if (!!frequency) { schedule = recur.on(frequency).dayOfWeek(); } else { schedule = recur.on(2).dayOfWeek(); } const offsetInMinutes = new Date().getTimezoneOffset(); const GMTtime = moment.duration(getSetting('newsletterTime', defaultTime)); const serverTime = GMTtime.subtract(offsetInMinutes, "minutes"); const serverTimeString = addZero(serverTime.hours()) + ":" + addZero(serverTime.minutes()); // console.log("// scheduled for: (GMT): "+getSetting('newsletterTime', defaultTime)); // console.log("// server offset (minutes): "+offsetInMinutes); // console.log("// server scheduled time (minutes): "+serverTime.asMinutes()); // console.log("// server scheduled time: "+serverTimeString); return schedule.on(serverTimeString).time(); }; Meteor.methods({ getNextJob: function () { var nextJob = SyncedCron.nextScheduledAtDate('scheduleNewsletter'); console.log(nextJob); // eslint-disable-line return nextJob; } }); var addJob = function () { SyncedCron.add({ name: 'scheduleNewsletter', schedule: function(parser) { // parser is a later.parse object return getSchedule(parser); }, job: function() { // only schedule newsletter campaigns in production if (process.env.NODE_ENV === "production" || getSetting("enableNewsletterInDev", false)) { console.log("// Scheduling newsletter…"); // eslint-disable-line console.log(new Date()); // eslint-disable-line Newsletter.scheduleNextWithMailChimp(); } } }); }; Meteor.startup(function () { if (getSetting('enableNewsletter', true) && getSetting('mailChimpAPIKey') && getSetting('mailChimpListId')) { addJob(); } });