"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.onMessage = onMessage;
exports.onActivateOptimize = onActivateOptimize;
exports.watchPostMessage = watchPostMessage;
exports.onUserLoadedOrFailed = onUserLoadedOrFailed;
exports.watchActivateOptimize = watchActivateOptimize;
exports.watchUserLoaded = watchUserLoaded;
exports.watchUserLoadedFailed = watchUserLoadedFailed;
exports["default"] = abSaga;

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

var _effects = require("redux-saga/effects");

var _reduxSaga = require("redux-saga");

var _tagmanager = require("@doodle/tagmanager");

var _abActions = require("../actions/abActions");

function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { "default": obj }; }

var _marked =
/*#__PURE__*/
_regenerator["default"].mark(onMessage),
    _marked2 =
/*#__PURE__*/
_regenerator["default"].mark(onActivateOptimize),
    _marked3 =
/*#__PURE__*/
_regenerator["default"].mark(watchPostMessage),
    _marked4 =
/*#__PURE__*/
_regenerator["default"].mark(onUserLoadedOrFailed),
    _marked5 =
/*#__PURE__*/
_regenerator["default"].mark(watchActivateOptimize),
    _marked6 =
/*#__PURE__*/
_regenerator["default"].mark(watchUserLoaded),
    _marked7 =
/*#__PURE__*/
_regenerator["default"].mark(watchUserLoadedFailed),
    _marked8 =
/*#__PURE__*/
_regenerator["default"].mark(abSaga);

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(source, true).forEach(function (key) { _defineProperty(target, key, source[key]); }); } else if (Object.getOwnPropertyDescriptors) { Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)); } else { ownKeys(source).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } } return target; }

function _defineProperty(obj, key, value) { if (key in obj) { Object.defineProperty(obj, key, { value: value, enumerable: true, configurable: true, writable: true }); } else { obj[key] = value; } return obj; }

function onMessage(event) {
  var data, experiment;
  return _regenerator["default"].wrap(function onMessage$(_context) {
    while (1) {
      switch (_context.prev = _context.next) {
        case 0:
          data = event.data;

          if (!data.experiment) {
            _context.next = 5;
            break;
          }

          experiment = _objectSpread({}, data.experiment);
          _context.next = 5;
          return (0, _effects.put)((0, _abActions.chooseExperiment)(experiment));

        case 5:
        case "end":
          return _context.stop();
      }
    }
  }, _marked);
}

function onActivateOptimize(options, action) {
  var waitForUser, _ref, loading, error, lang;

  return _regenerator["default"].wrap(function onActivateOptimize$(_context2) {
    while (1) {
      switch (_context2.prev = _context2.next) {
        case 0:
          waitForUser = action.waitForUser;
          _context2.next = 3;
          return (0, _effects.select)(function (state) {
            return state.user;
          });

        case 3:
          _ref = _context2.sent;
          loading = _ref.loading;
          error = _ref.error;
          lang = document.documentElement.lang;

          if (!(waitForUser && (loading || error === null))) {
            _context2.next = 10;
            break;
          }

          _context2.next = 10;
          return (0, _effects.take)(_abActions.ActionTypes.WAITED_FOR_USER);

        case 10:
          _context2.next = 12;
          return (0, _effects.put)((0, _tagmanager.pushDataLayer)({
            language: lang,
            event: 'optimize.activate'
          }));

        case 12:
        case "end":
          return _context2.stop();
      }
    }
  }, _marked2);
}

function watchPostMessage() {
  var postMessageChannel;
  return _regenerator["default"].wrap(function watchPostMessage$(_context3) {
    while (1) {
      switch (_context3.prev = _context3.next) {
        case 0:
          postMessageChannel = (0, _reduxSaga.eventChannel)(function (emitter) {
            window.addEventListener('message', emitter);
            return function () {
              window.removeEventListener('message', emitter);
            };
          });
          _context3.next = 3;
          return (0, _effects.takeEvery)(postMessageChannel, onMessage);

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

function onUserLoadedOrFailed() {
  return _regenerator["default"].wrap(function onUserLoadedOrFailed$(_context4) {
    while (1) {
      switch (_context4.prev = _context4.next) {
        case 0:
          _context4.next = 2;
          return (0, _effects.put)((0, _abActions.waitedForUser)());

        case 2:
        case "end":
          return _context4.stop();
      }
    }
  }, _marked4);
}

function watchActivateOptimize(options) {
  return _regenerator["default"].wrap(function watchActivateOptimize$(_context5) {
    while (1) {
      switch (_context5.prev = _context5.next) {
        case 0:
          _context5.next = 2;
          return (0, _effects.takeLatest)(_abActions.ActionTypes.OPTIMIZE_ACTIVATE, onActivateOptimize, options);

        case 2:
        case "end":
          return _context5.stop();
      }
    }
  }, _marked5);
}

function watchUserLoaded(options) {
  return _regenerator["default"].wrap(function watchUserLoaded$(_context6) {
    while (1) {
      switch (_context6.prev = _context6.next) {
        case 0:
          _context6.next = 2;
          return (0, _effects.takeLatest)('@doodle/user/USER_LOADED', onUserLoadedOrFailed, options);

        case 2:
        case "end":
          return _context6.stop();
      }
    }
  }, _marked6);
}

function watchUserLoadedFailed(options) {
  return _regenerator["default"].wrap(function watchUserLoadedFailed$(_context7) {
    while (1) {
      switch (_context7.prev = _context7.next) {
        case 0:
          _context7.next = 2;
          return (0, _effects.takeLatest)('@doodle/user/USER_LOADED_FAILED', onUserLoadedOrFailed, options);

        case 2:
        case "end":
          return _context7.stop();
      }
    }
  }, _marked7);
}

function abSaga() {
  var options,
      _args8 = arguments;
  return _regenerator["default"].wrap(function abSaga$(_context8) {
    while (1) {
      switch (_context8.prev = _context8.next) {
        case 0:
          options = _args8.length > 0 && _args8[0] !== undefined ? _args8[0] : {};
          _context8.next = 3;
          return (0, _effects.all)([(0, _effects.call)(watchPostMessage, options), (0, _effects.call)(watchActivateOptimize, options), (0, _effects.call)(watchUserLoadedFailed), (0, _effects.call)(watchUserLoaded)]);

        case 3:
        case "end":
          return _context8.stop();
      }
    }
  }, _marked8);
}