'use strict';

Object.defineProperty(exports, "__esModule", {
  value: true
});

var _regenerator = require('babel-runtime/regenerator');

var _regenerator2 = _interopRequireDefault(_regenerator);

var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; };

exports.onMessage = onMessage;
exports.onActivateOptimize = onActivateOptimize;
exports.watchPostMessage = watchPostMessage;
exports.watchActivateOptimize = watchActivateOptimize;
exports.default = abSaga;

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__*/_regenerator2.default.mark(onMessage),
    _marked2 = /*#__PURE__*/_regenerator2.default.mark(onActivateOptimize),
    _marked3 = /*#__PURE__*/_regenerator2.default.mark(watchPostMessage),
    _marked4 = /*#__PURE__*/_regenerator2.default.mark(watchActivateOptimize),
    _marked5 = /*#__PURE__*/_regenerator2.default.mark(abSaga);

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

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

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

        case 5:
          _context.next = 16;
          break;

        case 7:
          if (!data.optimize) {
            _context.next = 16;
            break;
          }

          if (!data.optimize.pending) {
            _context.next = 13;
            break;
          }

          _context.next = 11;
          return (0, _effects.put)((0, _abActions.setOptimizeStatus)(_abActions.ActionTypes.OPTIMIZE_STATUS_PENDING));

        case 11:
          _context.next = 16;
          break;

        case 13:
          if (!data.optimize.loaded) {
            _context.next = 16;
            break;
          }

          _context.next = 16;
          return (0, _effects.put)((0, _abActions.setOptimizeStatus)(_abActions.ActionTypes.OPTIMIZE_STATUS_LOADED));

        case 16:
        case 'end':
          return _context.stop();
      }
    }
  }, _marked, this);
}

function onActivateOptimize() {
  return _regenerator2.default.wrap(function onActivateOptimize$(_context2) {
    while (1) {
      switch (_context2.prev = _context2.next) {
        case 0:
          _context2.next = 2;
          return (0, _effects.put)((0, _tagmanager.pushDataLayer)({
            event: 'optimize.activate'
          }));

        case 2:
        case 'end':
          return _context2.stop();
      }
    }
  }, _marked2, this);
}

function watchPostMessage() {
  var postMessageChannel;
  return _regenerator2.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, this);
}

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

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

function abSaga() {
  var options = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};
  return _regenerator2.default.wrap(function abSaga$(_context5) {
    while (1) {
      switch (_context5.prev = _context5.next) {
        case 0:
          if (!(window.doodleABTest && window.doodleABTest.pending)) {
            _context5.next = 3;
            break;
          }

          _context5.next = 3;
          return (0, _effects.put)((0, _abActions.setOptimizeStatus)(_abActions.ActionTypes.OPTIMIZE_STATUS_PENDING));

        case 3:
          if (!(window.doodleABTest && window.doodleABTest.loaded)) {
            _context5.next = 6;
            break;
          }

          _context5.next = 6;
          return (0, _effects.put)((0, _abActions.setOptimizeStatus)(_abActions.ActionTypes.OPTIMIZE_STATUS_LOADED));

        case 6:
          _context5.next = 8;
          return (0, _effects.all)([(0, _effects.call)(watchPostMessage, options), (0, _effects.call)(watchActivateOptimize, options)]);

        case 8:
        case 'end':
          return _context5.stop();
      }
    }
  }, _marked5, this);
}