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

"use strict";

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

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

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

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

function userImpressionInChat(_x) {
  return _userImpressionInChat.apply(this, arguments);
}

function _userImpressionInChat() {
  _userImpressionInChat = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee(_ref) {
    var telegramUserId, telegramChatId, botsModule, type, _ref$time, time, BotsTelegramImpressionModel, BotsTelegramChatModel, BotsTelegramUserModel, user, chat, data, impression;

    return _regenerator["default"].wrap(function _callee$(_context) {
      while (1) {
        switch (_context.prev = _context.next) {
          case 0:
            telegramUserId = _ref.telegramUserId, telegramChatId = _ref.telegramChatId, botsModule = _ref.botsModule, type = _ref.type, _ref$time = _ref.time, time = _ref$time === void 0 ? new Date().getTime() - 24 * 60 * 60 * 1000 : _ref$time;
            _context.next = 3;
            return botsModule.module('models.BotsTelegramImpressionModel');

          case 3:
            BotsTelegramImpressionModel = _context.sent;
            _context.next = 6;
            return botsModule.module('models.BotsTelegramChatModel');

          case 6:
            BotsTelegramChatModel = _context.sent;
            _context.next = 9;
            return botsModule.module('models.BotsTelegramUserModel');

          case 9:
            BotsTelegramUserModel = _context.sent;
            _context.next = 12;
            return BotsTelegramUserModel.findOne({
              id: telegramUserId
            }).select('_id').lean();

          case 12:
            user = _context.sent;
            _context.next = 15;
            return BotsTelegramChatModel.findOne({
              id: telegramChatId
            }).select('_id').lean();

          case 15:
            chat = _context.sent;

            if (!(!user || !chat)) {
              _context.next = 18;
              break;
            }

            return _context.abrupt("return", false);

          case 18:
            data = {
              userId: user._id,
              chatId: chat._id,
              updatedAt: {
                $gte: new Date(time)
              }
            };
            if (type) data.type = type;
            _context.next = 22;
            return BotsTelegramImpressionModel.findOne(data);

          case 22:
            impression = _context.sent;
            return _context.abrupt("return", !!impression);

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

var _default = userImpressionInChat;
exports["default"] = _default;
//# sourceMappingURL=userImpressionInChat.js.map