@xen-orchestra/cron/dist/index.js

"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.createSchedule = void 0;

var _momentTimezone = _interopRequireDefault(require("moment-timezone"));

var _next = _interopRequireDefault(require("./next"));

var _parse = _interopRequireDefault(require("./parse"));

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }

const MAX_DELAY = Math.pow(2, 31) - 1;

class Job {
  constructor(schedule, fn) {
    let scheduledDate;

    const wrapper = () => {
      const now = Date.now();

      if (scheduledDate > now) {
        this._timeout = setTimeout(wrapper, scheduledDate - now);
        return;
      }

      this._isRunning = true;
      let result;

      try {
        result = fn();
      } catch (_) {}

      let then;

      if (result != null && typeof (then = result.then) === 'function') {
        then.call(result, scheduleNext, scheduleNext);
      } else {
        scheduleNext();
      }
    };

    const scheduleNext = () => {
      this._isRunning = false;

      if (this._isEnabled) {
        const now = schedule._createDate();

        scheduledDate = +(0, _next.default)(schedule._schedule, now);
        const delay = scheduledDate - now;
        this._timeout = delay < MAX_DELAY ? setTimeout(wrapper, delay) : setTimeout(scheduleNext, MAX_DELAY);
      }
    };

    this._isEnabled = false;
    this._isRunning = false;
    this._scheduleNext = scheduleNext;
    this._timeout = undefined;
  }

  start() {
    this.stop();
    this._isEnabled = true;

    if (!this._isRunning) {
      this._scheduleNext();
    }
  }

  stop() {
    this._isEnabled = false;
    clearTimeout(this._timeout);
  }

}

class Schedule {
  constructor(pattern, zone = 'utc') {
    this._schedule = (0, _parse.default)(pattern);
    this._createDate = zone.toLowerCase() === 'utc' ? _momentTimezone.default.utc : zone === 'local' ? _momentTimezone.default : () => _momentTimezone.default.tz(zone);
  }

  createJob(fn) {
    return new Job(this, fn);
  }

  next(n) {
    const dates = new Array(n);
    const schedule = this._schedule;

    let date = this._createDate();

    for (let i = 0; i < n; ++i) {
      dates[i] = (date = (0, _next.default)(schedule, date)).toDate();
    }

    return dates;
  }

  startJob(fn) {
    const job = this.createJob(fn);
    job.start();
    return job.stop.bind(job);
  }

}

const createSchedule = (...args) => new Schedule(...args);

exports.createSchedule = createSchedule;
//# sourceMappingURL=index.js.map