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

"use strict";

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

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

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

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

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

var _flatten = _interopRequireDefault(require("lodash/flatten"));

var _isFunction = _interopRequireDefault(require("lodash/isFunction"));

var _some = _interopRequireDefault(require("lodash/some"));

function updateRules(_x) {
  return _updateRules.apply(this, arguments);
}

function _updateRules() {
  _updateRules = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee(_ref) {
    var ctx, bot, BotsUserDataModel, fromId, data, userRules, rules;
    return _regenerator["default"].wrap(function _callee$(_context) {
      while (1) {
        switch (_context.prev = _context.next) {
          case 0:
            ctx = _ref.ctx, bot = _ref.bot;
            _context.next = 3;
            return this.botsModule.module('models.BotsUserDataModel');

          case 3:
            BotsUserDataModel = _context.sent;
            fromId = bot.getUserId(ctx);
            data = {
              telegramUserId: fromId,
              'info.rules': {
                $exists: true
              }
            };
            _context.next = 8;
            return BotsUserDataModel.find(data).select('info.rules').lean();

          case 8:
            userRules = _context.sent;
            rules = (0, _flatten["default"])(userRules.map(function (_ref3) {
              var info = _ref3.info;
              return info.rules;
            }));
            return _context.abrupt("return", [].concat((0, _toConsumableArray2["default"])(this.rules), (0, _toConsumableArray2["default"])(rules)));

          case 11:
          case "end":
            return _context.stop();
        }
      }
    }, _callee, this);
  }));
  return _updateRules.apply(this, arguments);
}

function getActiveRules() {
  return _getActiveRules.apply(this, arguments);
}

function _getActiveRules() {
  _getActiveRules = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee2() {
    var _message$sticker,
        _message$sticker2,
        _this = this;

    var _ref2,
        ctx,
        bot,
        pack,
        message,
        rules,
        checkUserId,
        checkChatType,
        checkChatId,
        checkMessageType,
        checkMessageText,
        checkStickerEmoji,
        checkStickerSetName,
        checkNextRoute,
        checkCriteria,
        activeRules,
        _args2 = arguments;

    return _regenerator["default"].wrap(function _callee2$(_context2) {
      while (1) {
        switch (_context2.prev = _context2.next) {
          case 0:
            _ref2 = _args2.length > 0 && _args2[0] !== undefined ? _args2[0] : {}, ctx = _ref2.ctx, bot = _ref2.bot;
            pack = {};
            message = bot.getMessage(ctx);
            pack.userId = bot.getUserId(ctx);
            pack.chatType = bot.getMessageChatType(ctx);
            pack.chatId = bot.getMessageChatId(ctx);
            pack.messageType = bot.getMessageType(ctx);
            pack.messageText = bot.getMessageText(ctx);
            pack.stickerEmoji = (_message$sticker = message.sticker) === null || _message$sticker === void 0 ? void 0 : _message$sticker.emoji;
            pack.stickerSetName = (_message$sticker2 = message.sticker) === null || _message$sticker2 === void 0 ? void 0 : _message$sticker2.set_name;
            pack.nextRoute = bot.getNextRoute(ctx);
            _context2.next = 13;
            return updateRules.call(this, {
              ctx: ctx,
              bot: bot
            });

          case 13:
            rules = _context2.sent;
            this.log.trace('getActiveRules rules', rules.length); // TODO: подумать как унифицировать, функции абсолютно одинаковые

            checkUserId = function checkUserId(item) {
              if (Array.isArray(item)) return (0, _some["default"])(item, checkUserId);
              if ((0, _isFunction["default"])(item) && !item(pack)) return false;
              return item === pack.userId; // return ['number', 'string'].includes(typeof item) && String(item) === String(pack.userId); // TODO: подумать нужна ли проверка на тип и приведение к строке
            };

            checkChatType = function checkChatType(item) {
              if (Array.isArray(item)) return (0, _some["default"])(item, checkChatType);
              if ((0, _isFunction["default"])(item) && !item(pack)) return false;
              return item === pack.chatType;
            };

            checkChatId = function checkChatId(item) {
              if (Array.isArray(item)) return (0, _some["default"])(item, checkChatId);
              if ((0, _isFunction["default"])(item) && !item(pack)) return false;
              return item === pack.chatId; // return ['number', 'string'].includes(typeof item) && String(item) === String(pack.chatId); // TODO: подумать нужна ли проверка на тип и приведение к строке
            };

            checkMessageType = function checkMessageType(item) {
              if (Array.isArray(item)) return (0, _some["default"])(item, checkMessageType);
              if ((0, _isFunction["default"])(item) && !item(pack)) return false;
              return item === pack.messageType;
            };

            checkMessageText = function checkMessageText(item) {
              if (Array.isArray(item)) return (0, _some["default"])(item, checkMessageText);
              if ((0, _isFunction["default"])(item) && !item(pack)) return false;
              if (item instanceof RegExp) return item.test(pack.messageText);
              return item === pack.messageText;
            };

            checkStickerEmoji = function checkStickerEmoji(item) {
              if (Array.isArray(item)) return (0, _some["default"])(item, checkStickerEmoji);
              if ((0, _isFunction["default"])(item) && !item(pack)) return false;
              if (item instanceof RegExp) return item.test(pack.stickerEmoji);
              return item === pack.stickerEmoji;
            };

            checkStickerSetName = function checkStickerSetName(item) {
              if (Array.isArray(item)) return (0, _some["default"])(item, checkStickerSetName);
              if ((0, _isFunction["default"])(item) && !item(pack)) return false;
              if (item instanceof RegExp) return item.test(pack.stickerSetName);
              return item === pack.stickerSetName;
            };

            checkNextRoute = function checkNextRoute(item) {
              if (Array.isArray(item)) return (0, _some["default"])(item, checkNextRoute);
              if ((0, _isFunction["default"])(item) && !item(pack)) return false;
              if (item instanceof RegExp) return item.test(pack.nextRoute);
              return item === pack.nextRoute;
            };

            checkCriteria = function checkCriteria(item) {
              if (Array.isArray(item)) return (0, _some["default"])(item, checkCriteria);
              if ((0, _isFunction["default"])(item) && !item(pack)) return false;
              var userId = item.userId,
                  chatType = item.chatType,
                  chatId = item.chatId,
                  messageType = item.messageType,
                  messageText = item.messageText,
                  stickerEmoji = item.stickerEmoji,
                  stickerSetName = item.stickerSetName,
                  nextRoute = item.nextRoute;

              if (userId && !checkUserId(userId)) {
                _this.log.trace('!checkUserId');

                return false;
              }

              if (chatType && !checkChatType(chatType)) {
                _this.log.trace('!checkChatType');

                return false;
              }

              if (chatId && !checkChatId(chatId)) {
                _this.log.trace('!checkChatId');

                return false;
              }

              if (messageType && !checkMessageType(messageType)) {
                _this.log.trace('!checkMessageType');

                return false;
              }

              if (messageText && !checkMessageText(messageText)) {
                _this.log.trace('!checkMessageText');

                return false;
              }

              if (stickerEmoji && !checkStickerEmoji(stickerEmoji)) {
                _this.log.trace('!checkStickerEmoji');

                return false;
              }

              if (stickerSetName && !checkStickerSetName(stickerSetName)) {
                _this.log.trace('!checkStickerSetName');

                return false;
              }

              if (nextRoute && !checkNextRoute(nextRoute)) {
                _this.log.trace('!checkNextRoute');

                return false;
              }

              return true;
            };

            activeRules = rules.filter(function (rule) {
              var criteria = rule.criteria,
                  action = rule.action;
              if (!criteria) return false;

              if (!checkCriteria(criteria)) {
                _this.log.trace('!checkCriteria');

                return false;
              }

              if (!action) {
                _this.log.trace('!action');

                return false;
              }

              return true;
            });
            this.log.trace('getActiveRules', pack, '=>', activeRules);
            return _context2.abrupt("return", activeRules);

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