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

"use strict";

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

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

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

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

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

var _get = _interopRequireDefault(require("lodash/get"));

var _sortBy = _interopRequireDefault(require("lodash/sortBy"));

var defaultGetMediaGroupId = function defaultGetMediaGroupId(ctx) {
  // return ctx.message.media_group_id || null;
  var a = 123;
  return [(0, _get["default"])(ctx, 'message.from.id'), (0, _get["default"])(ctx, 'message.chat.id'), (0, _get["default"])(ctx, 'message.date')].filter(Boolean).join('_');
};

exports.defaultGetMediaGroupId = defaultGetMediaGroupId;
var groups = {};

var groupMessages = function groupMessages(callback) {
  var _ref = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {},
      _ref$groupKey = _ref.groupKey,
      groupKey = _ref$groupKey === void 0 ? defaultGetMediaGroupId : _ref$groupKey,
      _ref$delay = _ref.delay,
      delay = _ref$delay === void 0 ? 1000 : _ref$delay;

  return /*#__PURE__*/function () {
    var _ref2 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee(ctx) {
      var mediaGroupId, delayMs, group;
      return _regenerator["default"].wrap(function _callee$(_context) {
        while (1) {
          switch (_context.prev = _context.next) {
            case 0:
              mediaGroupId = groupKey(ctx); // console.log('[QWE] 11', ctx.message.message_id, mediaGroupId);

              if (mediaGroupId) {
                _context.next = 4;
                break;
              }

              callback(ctx);
              return _context.abrupt("return");

            case 4:
              if (!groups[mediaGroupId]) groups[mediaGroupId] = [];
              groups[mediaGroupId].push(ctx); // console.log('[QWE] 22', ctx.message.message_id, mediaGroupId, groups[mediaGroupId].length);

              delayMs = (1 + Math.random()) * delay; // console.log('[QWE] 333', ctx.message.message_id, mediaGroupId, groups[mediaGroupId].length, 'delay', delay);

              _context.next = 9;
              return _bluebird["default"].delay(delayMs);

            case 9:
              group = (0, _sortBy["default"])(groups[mediaGroupId], 'update.message.message_id'); // console.log('[QWE] 33', ctx.message.message_id, mediaGroupId, groups[mediaGroupId].length);

              if (group.length) {
                _context.next = 12;
                break;
              }

              return _context.abrupt("return");

            case 12:
              if (!(group.length === 1)) {
                _context.next = 15;
                break;
              }

              callback(ctx);
              return _context.abrupt("return");

            case 15:
              ctx.group = group;
              callback(ctx);
              groups[mediaGroupId] = []; // console.log('[QWE] 444', ctx.message.message_id, mediaGroupId, groups[mediaGroupId].length);

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

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

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