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

"use strict";

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

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

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

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

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

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

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

var _bluebird = _interopRequireDefault(require("bluebird"));

var _isEmpty = _interopRequireDefault(require("lodash/isEmpty"));

var _isObjectLike = _interopRequireDefault(require("lodash/isObjectLike"));

var _actions = _interopRequireDefault(require("../actions"));

var _excluded = ["event", "ctx", "bot"];

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 runAction(_x) {
  return _runAction.apply(this, arguments);
}

function _runAction() {
  _runAction = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee2(_ref) {
    var _this = this;

    var event, ctx, bot, props, actions;
    return _regenerator["default"].wrap(function _callee2$(_context2) {
      while (1) {
        switch (_context2.prev = _context2.next) {
          case 0:
            event = _ref.event, ctx = _ref.ctx, bot = _ref.bot, props = (0, _objectWithoutProperties2["default"])(_ref, _excluded);
            actions = props.action;

            if (actions) {
              _context2.next = 4;
              break;
            }

            return _context2.abrupt("return", null);

          case 4:
            if (!Array.isArray(actions)) actions = [actions];

            if (!(0, _isEmpty["default"])(actions)) {
              _context2.next = 7;
              break;
            }

            return _context2.abrupt("return", null);

          case 7:
            return _context2.abrupt("return", _bluebird["default"].each(actions, /*#__PURE__*/function () {
              var _ref2 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee(action) {
                var type, result, isNotNull;
                return _regenerator["default"].wrap(function _callee$(_context) {
                  while (1) {
                    switch (_context.prev = _context.next) {
                      case 0:
                        type = action.type;
                        result = null;

                        if (!_actions["default"][action]) {
                          _context.next = 6;
                          break;
                        }

                        _context.next = 5;
                        return _actions["default"][action].call(_this, _objectSpread({
                          event: event,
                          ctx: ctx,
                          bot: bot
                        }, action));

                      case 5:
                        result = _context.sent;

                      case 6:
                        if (!_actions["default"][type]) {
                          _context.next = 10;
                          break;
                        }

                        _context.next = 9;
                        return _actions["default"][type].call(_this, _objectSpread({
                          event: event,
                          ctx: ctx,
                          bot: bot
                        }, action));

                      case 9:
                        result = _context.sent;

                      case 10:
                        isNotNull = ['number', 'string', 'boolean'].includes((0, _typeof2["default"])(result)) && !!result || (0, _isObjectLike["default"])(result) && !(0, _isEmpty["default"])(result);

                        if (!(action.then && !(0, _isEmpty["default"])(action.then) && isNotNull)) {
                          _context.next = 14;
                          break;
                        }

                        _context.next = 14;
                        return _this.runAction({
                          event: event,
                          ctx: ctx,
                          bot: bot,
                          action: action.then
                        });

                      case 14:
                        if (!(action["else"] && !(0, _isEmpty["default"])(action["else"]) && !isNotNull)) {
                          _context.next = 17;
                          break;
                        }

                        _context.next = 17;
                        return _this.runAction({
                          event: event,
                          ctx: ctx,
                          bot: bot,
                          action: action["else"]
                        });

                      case 17:
                        _context.next = 19;
                        return _bluebird["default"].delay(10);

                      case 19:
                        return _context.abrupt("return", result);

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

              return function (_x2) {
                return _ref2.apply(this, arguments);
              };
            }()));

          case 8:
          case "end":
            return _context2.stop();
        }
      }
    }, _callee2);
  }));
  return _runAction.apply(this, arguments);
}
//# sourceMappingURL=_runAction.js.map