@lskjs/bots-plugin-portal/utils/runCron.js

"use strict";

var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports["default"] = runCron;

var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));

var _defineProperty2 = _interopRequireDefault(require("@babel/runtime/helpers/defineProperty"));

var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));

var _err = _interopRequireDefault(require("@lskjs/err"));

var _nodeCron = _interopRequireDefault(require("node-cron"));

function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) { symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); } keys.push.apply(keys, symbols); } return keys; }

function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; if (i % 2) { ownKeys(Object(source), true).forEach(function (key) { (0, _defineProperty2["default"])(target, key, source[key]); }); } else if (Object.getOwnPropertyDescriptors) { Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)); } else { ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } } return target; }

function runCron(_ref) {
  var _this = this;

  var bot = _ref.bot;
  var initedCrons = [];
  if (!this.rules) return [];
  this.rules.forEach(function (rule) {
    if (!rule.cron) return;
    var action = rule.action;
    var times = Array.isArray(rule.cron) ? rule.cron : [rule.cron];
    times.forEach(function (time) {
      if (!_nodeCron["default"].validate(time)) throw new _err["default"]('CRON_NOT_VALID', {
        data: {
          time: time
        }
      });
      initedCrons.push({
        time: time,
        rule: rule,
        schedule: _nodeCron["default"].schedule(time, /*#__PURE__*/(0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee() {
          var actionModule;
          return _regenerator["default"].wrap(function _callee$(_context) {
            while (1) {
              switch (_context.prev = _context.next) {
                case 0:
                  _this.log.trace("CRON action on '".concat(time, "'"), rule);

                  _context.next = 3;
                  return _this.module('action');

                case 3:
                  actionModule = _context.sent;
                  actionModule.runAction(action, _objectSpread({
                    bot: bot
                  }, rule));

                case 5:
                case "end":
                  return _context.stop();
              }
            }
          }, _callee);
        })))
      });
    });
  });

  if (initedCrons.length) {
    this.log.debug('runCron', initedCrons.map(function (cron) {
      return cron.time;
    }));
  }

  return initedCrons;
}
//# sourceMappingURL=runCron.js.map