'use strict'; // Load Date class extensions var CronDate = require('./date'); // Get Number.isNaN or the polyfill var safeIsNaN = require('is-nan'); /** * Construct a new expression parser * * Options: * currentDate: iterator start date * endDate: iterator end date * * @constructor * @private * @param {Object} fields Expression fields parsed values * @param {Object} options Parser options */ function CronExpression (fields, options) { this._options = options; this._utc = options.utc || false; this._tz = this._utc ? 'UTC' : options.tz; this._currentDate = new CronDate(options.currentDate, this._tz); this._startDate = options.startDate ? new CronDate(options.startDate, this._tz) : null; this._endDate = options.endDate ? new CronDate(options.endDate, this._tz) : null; this._fields = {}; this._isIterator = options.iterator || false; this._hasIterated = false; // Map fields for (var i = 0, c = CronExpression.map.length; i < c; i++) { var key = CronExpression.map[i]; this._fields[key] = fields[i]; } } /** * Field mappings * @type {Array} */ CronExpression.map = [ 'second', 'minute', 'hour', 'dayOfMonth', 'month', 'dayOfWeek' ]; /** * Prefined intervals * @type {Object} */ CronExpression.predefined = { '@yearly': '0 0 1 1 *', '@monthly': '0 0 1 * *', '@weekly': '0 0 * * 0', '@daily': '0 0 * * *', '@hourly': '0 * * * *' }; /** * Fields constraints * @type {Array} */ CronExpression.constraints = [ [ 0, 59 ], // Second [ 0, 59 ], // Minute [ 0, 23 ], // Hour [ 1, 31 ], // Day of month [ 1, 12 ], // Month [ 0, 7 ] // Day of week ]; /** * Days in month * @type {number[]} */ CronExpression.daysInMonth = [ 31, 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31 ]; /** * Field aliases * @type {Object} */ CronExpression.aliases = { month: { jan: 1, feb: 2, mar: 3, apr: 4, may: 5, jun: 6, jul: 7, aug: 8, sep: 9, oct: 10, nov: 11, dec: 12 }, dayOfWeek: { sun: 0, mon: 1, tue: 2, wed: 3, thu: 4, fri: 5, sat: 6 } }; /** * Field defaults * @type {Array} */ CronExpression.parseDefaults = [ '0', '*', '*', '*', '*', '*' ]; CronExpression.standardValidCharacters = /^[\d|/|*|\-|,]+$/; CronExpression.dayValidCharacters = /^[\d|/|*|\-|,|\?]+$/; CronExpression.validCharacters = { second: CronExpression.standardValidCharacters, minute: CronExpression.standardValidCharacters, hour: CronExpression.standardValidCharacters, dayOfMonth: CronExpression.dayValidCharacters, month: CronExpression.standardValidCharacters, dayOfWeek: CronExpression.dayValidCharacters, } /** * Parse input interval * * @param {String} field Field symbolic name * @param {String} value Field value * @param {Array} constraints Range upper and lower constraints * @return {Array} Sequence of sorted values * @private */ CronExpression._parseField = function _parseField (field, value, constraints) { // Replace aliases switch (field) { case 'month': case 'dayOfWeek': var aliases = CronExpression.aliases[field]; value = value.replace(/[a-z]{1,3}/gi, function(match) { match = match.toLowerCase(); if (typeof aliases[match] !== undefined) { return aliases[match]; } else { throw new Error('Cannot resolve alias "' + match + '"') } }); break; } // Check for valid characters. if (!(CronExpression.validCharacters[field].test(value))) { throw new Error('Invalid characters, got value: ' + value) } // Replace '*' and '?' if (value.indexOf('*') !== -1) { value = value.replace(/\*/g, constraints.join('-')); } else if (value.indexOf('?') !== -1) { value = value.replace(/\?/g, constraints.join('-')); } // // Inline parsing functions // // Parser path: // - parseSequence // - parseRepeat // - parseRange /** * Parse sequence * * @param {String} val * @return {Array} * @private */ function parseSequence (val) { var stack = []; function handleResult (result) { var max = stack.length > 0 ? Math.max.apply(Math, stack) : -1; if (result instanceof Array) { // Make sequence linear for (var i = 0, c = result.length; i < c; i++) { var value = result[i]; // Check constraints if (value < constraints[0] || value > constraints[1]) { throw new Error( 'Constraint error, got value ' + value + ' expected range ' + constraints[0] + '-' + constraints[1] ); } if (value > max) { stack.push(value); } max = Math.max.apply(Math, stack); } } else { // Scalar value result = +result; // Check constraints if (result < constraints[0] || result > constraints[1]) { throw new Error( 'Constraint error, got value ' + result + ' expected range ' + constraints[0] + '-' + constraints[1] ); } if (field == 'dayOfWeek') { result = result % 7; } stack.push(result); } } var atoms = val.split(','); if (atoms.length > 1) { for (var i = 0, c = atoms.length; i < c; i++) { handleResult(parseRepeat(atoms[i])); } } else { handleResult(parseRepeat(val)); } stack.sort(function(a, b) { return a - b; }); return stack; } /** * Parse repetition interval * * @param {String} val * @return {Array} */ function parseRepeat (val) { var repeatInterval = 1; var atoms = val.split('/'); if (atoms.length > 1) { return parseRange(atoms[0], atoms[atoms.length - 1]); } return parseRange(val, repeatInterval); } /** * Parse range * * @param {String} val * @param {Number} repeatInterval Repetition interval * @return {Array} * @private */ function parseRange (val, repeatInterval) { var stack = []; var atoms = val.split('-'); if (atoms.length > 1 ) { // Invalid range, return value if (atoms.length < 2 || !atoms[0].length) { return +val; } // Validate range var min = +atoms[0]; var max = +atoms[1]; if (safeIsNaN(min) || safeIsNaN(max) || min < constraints[0] || max > constraints[1]) { throw new Error( 'Constraint error, got range ' + min + '-' + max + ' expected range ' + constraints[0] + '-' + constraints[1] ); } else if (min >= max) { throw new Error('Invalid range: ' + val); } // Create range var repeatIndex = +repeatInterval; if (safeIsNaN(repeatIndex) || repeatIndex <= 0) { throw new Error('Constraint error, cannot repeat at every ' + repeatIndex + ' time.'); } for (var index = min, count = max; index <= count; index++) { if (repeatIndex > 0 && (repeatIndex % repeatInterval) === 0) { repeatIndex = 1; stack.push(index); } else { repeatIndex++; } } return stack; } return +val; } return parseSequence(value); }; CronExpression.prototype._applyTimezoneShift = function(currentDate, method) { var previousHour = currentDate.getHours(); currentDate[method](); var currentHour = currentDate.getHours(); var diff = currentHour - previousHour; if (diff === 2) { // Starting DST if (this._fields.hour.length !== 24) { // Hour is specified this._dstStart = currentHour; } } else if ((diff === 0) && (currentDate.getMinutes() === 0) && (currentDate.getSeconds() === 0)) { // Ending DST if (this._fields.hour.length !== 24) { // Hour is specified this._dstEnd = currentHour; } } }; /** * Find next or previous matching schedule date * * @return {CronDate} * @private */ CronExpression.prototype._findSchedule = function _findSchedule (reverse) { /** * Match field value * * @param {String} value * @param {Array} sequence * @return {Boolean} * @private */ function matchSchedule (value, sequence) { for (var i = 0, c = sequence.length; i < c; i++) { if (sequence[i] >= value) { return sequence[i] === value; } } return sequence[0] === value; } /** * Detect if input range fully matches constraint bounds * @param {Array} range Input range * @param {Array} constraints Input constraints * @returns {Boolean} * @private */ function isWildcardRange (range, constraints) { if (range instanceof Array && !range.length) { return false; } if (constraints.length !== 2) { return false; } return range.length === (constraints[1] - (constraints[0] < 1 ? - 1 : 0)); } // Whether to use backwards directionality when searching reverse = reverse || false; var dateMathVerb = reverse ? 'subtract' : 'add'; var currentDate = new CronDate(this._currentDate, this._tz); var startDate = this._startDate; var endDate = this._endDate; // Find matching schedule var initial_ts = currentDate.getTime(); while (true) { // Validate timespan if (reverse) { if (startDate && (currentDate.getTime() - startDate.getTime() < 0)) { throw new Error('Out of the timespan range'); } } else { if (endDate && (endDate.getTime() - currentDate.getTime()) < 0) { throw new Error('Out of the timespan range'); } } // Day of month and week matching: // // "The day of a command's execution can be specified by two fields -- // day of month, and day of week. If both fields are restricted (ie, // aren't *), the command will be run when either field matches the cur- // rent time. For example, "30 4 1,15 * 5" would cause a command to be // run at 4:30 am on the 1st and 15th of each month, plus every Friday." // // http://unixhelp.ed.ac.uk/CGI/man-cgi?crontab+5 // var dayOfMonthMatch = matchSchedule(currentDate.getDate(), this._fields.dayOfMonth); var dayOfWeekMatch = matchSchedule(currentDate.getDay(), this._fields.dayOfWeek); var isDayOfMonthWildcardMatch = isWildcardRange(this._fields.dayOfMonth, CronExpression.constraints[3]); var isMonthWildcardMatch = isWildcardRange(this._fields.month, CronExpression.constraints[4]); var isDayOfWeekWildcardMatch = isWildcardRange(this._fields.dayOfWeek, CronExpression.constraints[5]); var currentHour = currentDate.getHours(); // Validate days in month if explicit value is given if (!isMonthWildcardMatch) { var currentYear = currentDate.getFullYear(); var currentMonth = currentDate.getMonth() + 1; var previousMonth = currentMonth === 1 ? 11 : currentMonth - 1; var daysInPreviousMonth = CronExpression.daysInMonth[previousMonth - 1]; var daysOfMontRangeMax = this._fields.dayOfMonth[this._fields.dayOfMonth.length - 1]; var _daysInPreviousMonth = daysInPreviousMonth; var _daysOfMontRangeMax = daysOfMontRangeMax; // Handle leap year var isLeap = !((currentYear % 4) || (!(currentYear % 100) && (currentYear % 400))); if (isLeap) { _daysInPreviousMonth = 29; _daysOfMontRangeMax = 29; } if (this._fields.month[0] === previousMonth && _daysInPreviousMonth < _daysOfMontRangeMax) { throw new Error('Invalid explicit day of month definition'); } } // Add or subtract day if select day not match with month (according to calendar) if (!dayOfMonthMatch && !dayOfWeekMatch) { currentDate[dateMathVerb + 'Day'](); continue; } // Add or subtract day if not day of month is set (and no match) and day of week is wildcard if (!isDayOfMonthWildcardMatch && isDayOfWeekWildcardMatch && !dayOfMonthMatch) { currentDate[dateMathVerb + 'Day'](); continue; } // Add or subtract day if not day of week is set (and no match) and day of month is wildcard if (isDayOfMonthWildcardMatch && !isDayOfWeekWildcardMatch && !dayOfWeekMatch) { currentDate[dateMathVerb + 'Day'](); continue; } // Add or subtract day if day of month and week are non-wildcard values and both doesn't match if (!(isDayOfMonthWildcardMatch && isDayOfWeekWildcardMatch) && !dayOfMonthMatch && !dayOfWeekMatch) { currentDate[dateMathVerb + 'Day'](); continue; } // Match month if (!matchSchedule(currentDate.getMonth() + 1, this._fields.month)) { currentDate[dateMathVerb + 'Month'](); continue; } // Match hour if (!matchSchedule(currentHour, this._fields.hour)) { if (this._dstStart !== currentHour) { this._dstStart = null; this._applyTimezoneShift(currentDate, dateMathVerb + 'Hour'); continue; } else if (!matchSchedule(currentHour - 1, this._fields.hour)) { currentDate[dateMathVerb + 'Hour'](); continue; } } else if (this._dstEnd === currentHour) { if (!reverse) { this._dstEnd = null; this._applyTimezoneShift(currentDate, 'addHour'); continue; } } // Match minute if (!matchSchedule(currentDate.getMinutes(), this._fields.minute)) { this._applyTimezoneShift(currentDate, dateMathVerb + 'Minute'); continue; } // Match second if (!matchSchedule(currentDate.getSeconds(), this._fields.second)) { this._applyTimezoneShift(currentDate, dateMathVerb + 'Second'); continue; } // Increase a second in case in the first iteration the currentDate was not // modified if (initial_ts === currentDate.getTime()) { if ((dateMathVerb === 'add') || (currentDate.getMilliseconds() === 0)) { this._applyTimezoneShift(currentDate, dateMathVerb + 'Second'); } else { currentDate.setMilliseconds(0); } continue; } break; } this._currentDate = new CronDate(currentDate, this._tz); this._hasIterated = true; return currentDate; }; /** * Find next suitable date * * @public * @return {CronDate|Object} */ CronExpression.prototype.next = function next () { var schedule = this._findSchedule(); // Try to return ES6 compatible iterator if (this._isIterator) { return { value: schedule, done: !this.hasNext() }; } return schedule; }; /** * Find previous suitable date * * @public * @return {CronDate|Object} */ CronExpression.prototype.prev = function prev () { var schedule = this._findSchedule(true); // Try to return ES6 compatible iterator if (this._isIterator) { return { value: schedule, done: !this.hasPrev() }; } return schedule; }; /** * Check if next suitable date exists * * @public * @return {Boolean} */ CronExpression.prototype.hasNext = function() { var current = this._currentDate; var hasIterated = this._hasIterated; try { this._findSchedule(); return true; } catch (err) { return false; } finally { this._currentDate = current; this._hasIterated = hasIterated; } }; /** * Check if previous suitable date exists * * @public * @return {Boolean} */ CronExpression.prototype.hasPrev = function() { var current = this._currentDate; var hasIterated = this._hasIterated; try { this._findSchedule(true); return true; } catch (err) { return false; } finally { this._currentDate = current; this._hasIterated = hasIterated; } }; /** * Iterate over expression iterator * * @public * @param {Number} steps Numbers of steps to iterate * @param {Function} callback Optional callback * @return {Array} Array of the iterated results */ CronExpression.prototype.iterate = function iterate (steps, callback) { var dates = []; if (steps >= 0) { for (var i = 0, c = steps; i < c; i++) { try { var item = this.next(); dates.push(item); // Fire the callback if (callback) { callback(item, i); } } catch (err) { break; } } } else { for (var i = 0, c = steps; i > c; i--) { try { var item = this.prev(); dates.push(item); // Fire the callback if (callback) { callback(item, i); } } catch (err) { break; } } } return dates; }; /** * Reset expression iterator state * * @public */ CronExpression.prototype.reset = function reset () { this._currentDate = new CronDate(this._options.currentDate); }; /** * Parse input expression (async) * * @public * @param {String} expression Input expression * @param {Object} [options] Parsing options * @param {Function} [callback] */ CronExpression.parse = function parse (expression, options, callback) { var self = this; if (typeof options === 'function') { callback = options; options = {}; } function parse (expression, options) { if (!options) { options = {}; } if (typeof options.currentDate === 'undefined') { options.currentDate = new CronDate(undefined, self._tz); } // Is input expression predefined? if (CronExpression.predefined[expression]) { expression = CronExpression.predefined[expression]; } // Split fields var fields = []; var atoms = (expression + '').trim().split(/\s+/); // Resolve fields var start = (CronExpression.map.length - atoms.length); for (var i = 0, c = CronExpression.map.length; i < c; ++i) { var field = CronExpression.map[i]; // Field name var value = atoms[atoms.length > c ? i : i - start]; // Field value if (i < start || !value) { fields.push(CronExpression._parseField( field, CronExpression.parseDefaults[i], CronExpression.constraints[i]) ); } else { // Use default value fields.push(CronExpression._parseField( field, value, CronExpression.constraints[i]) ); } } return new CronExpression(fields, options); } return parse(expression, options); }; module.exports = CronExpression;