Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

Repository URL to install this package:

Details    
@doodle/lib-paywall / build / methods / verifyDuplicate.js
Size: Mime:
"use strict";

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

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

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

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

var _store = require("../state/store");

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

var _paywall = require("../constants/paywall");

var _requests = require("./requests");

var _getStatusFromUserData = _interopRequireDefault(require("../utils/getStatusFromUserData"));

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; }

var _callee3 = function _callee3(_ref) {
  var token, id, trackingEventPrefix, _store$getState, apiHost;

  return _regenerator["default"].async(function _callee3$(_context3) {
    while (1) {
      switch (_context3.prev = _context3.next) {
        case 0:
          token = _ref.token, id = _ref.id, trackingEventPrefix = _ref.trackingEventPrefix;
          _store$getState = _store.store.getState(), apiHost = _store$getState.apiHost;
          return _context3.abrupt("return", new Promise(function (resolve) {
            (0, _requests.getUserDataRequest)({
              token: token,
              apiHost: apiHost
            }).then(function _callee2(res) {
              var data, _getStatusFromUserDat, status;

              return _regenerator["default"].async(function _callee2$(_context2) {
                while (1) {
                  switch (_context2.prev = _context2.next) {
                    case 0:
                      _context2.next = 2;
                      return _regenerator["default"].awrap(res.text());

                    case 2:
                      data = _context2.sent;
                      _getStatusFromUserDat = (0, _getStatusFromUserData["default"])({
                        data: data,
                        token: token,
                        trackingEventPrefix: trackingEventPrefix,
                        apiHost: apiHost
                      }), status = _getStatusFromUserDat.status;

                      if (!status.shouldOpenModal) {
                        (0, _requests.getCalendarRequest)({
                          token: token,
                          id: id,
                          apiHost: apiHost,
                          resolve: resolve
                        }).then(function _callee(calRes) {
                          var calendarResponse, parsedCalendarResponse, slots, filteredSlots, isSlotInThePast;
                          return _regenerator["default"].async(function _callee$(_context) {
                            while (1) {
                              switch (_context.prev = _context.next) {
                                case 0:
                                  _context.next = 2;
                                  return _regenerator["default"].awrap(calRes.text());

                                case 2:
                                  calendarResponse = _context.sent;
                                  parsedCalendarResponse = JSON.parse(calendarResponse);
                                  slots = parsedCalendarResponse.slots;
                                  filteredSlots = slots.filter(function (slot) {
                                    return +new Date(slot.start) > +new Date();
                                  }).map(function (slot) {
                                    return _objectSpread({}, slot, {
                                      attendee: null
                                    });
                                  });
                                  isSlotInThePast = slots.length !== filteredSlots.length;

                                  if (isSlotInThePast) {
                                    new Promise(function (duplicateResolveFunc, duplicateRejectFunc) {
                                      _store.store.dispatch((0, _actions.setData)({
                                        duplicateResolveFunc: duplicateResolveFunc,
                                        duplicateRejectFunc: duplicateRejectFunc,
                                        isWarningModalOpen: true
                                      }));
                                    }).then(function () {
                                      resolve({
                                        status: _paywall.paywallStatus.PASS
                                      });
                                    })["catch"](function () {
                                      resolve({
                                        status: _paywall.paywallStatus.REJECT
                                      });
                                    });
                                  } else {
                                    resolve({
                                      status: _paywall.paywallStatus.PASS
                                    });
                                  }

                                case 8:
                                case "end":
                                  return _context.stop();
                              }
                            }
                          });
                        })["catch"](function (e) {
                          resolve(_objectSpread({}, _paywall.getCalendarError, {
                            message: e.message
                          }));
                        });
                      } else {
                        _store.store.dispatch((0, _actions.setData)({
                          trackingEventPostfix: status.trackingEventPostfix,
                          modalType: status.modalType,
                          isPaywallModalOpen: true,
                          resolve: resolve,
                          process: _paywall.processType.DUPLICATE
                        }));
                      }

                    case 5:
                    case "end":
                      return _context2.stop();
                  }
                }
              });
            })["catch"](function (e) {
              resolve(_objectSpread({}, _paywall.getUserError, {
                message: e.message
              }));
            });
          }));

        case 3:
        case "end":
          return _context3.stop();
      }
    }
  });
};

exports["default"] = _callee3;