@hhjcz/redux-rest/lib/actions/createRestActions.js

'use strict';

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

var _extends2 = require('babel-runtime/helpers/extends');

var _extends3 = _interopRequireDefault(_extends2);

exports.default = createRestActions;

var _humps = require('humps');

var _createResource = require('../resource/createResource');

var _createResource2 = _interopRequireDefault(_createResource);

var _selectors = require('../selectors');

var _queryGenerators = require('../queryGenerators');

var _queryGenerators2 = _interopRequireDefault(_queryGenerators);

var _Filter = require('../models/Filter');

var _Filter2 = _interopRequireDefault(_Filter);

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

function createRestActions(resourceName, config, actionCreators, depsContainer) {
  var getThisState = (0, _selectors.selectResourceTree)(config.getRootTree)(resourceName);
  var getAuthState = (0, _selectors.selectAuthTree)(config.getRootTree);

  var resource = (0, _createResource2.default)(resourceName, config, depsContainer);
  var extraParams = (0, _humps.decamelizeKeys)(config.extraParams);
  var isStaticCollection = config.isStaticCollection || false;

  /**
   *  create ASYNC action creators
   *
   * @param {string} actionName
   * @param {string} resourceMethod Specify method of the resource to be called, when it differs from actionName
   * @param methodExtraParams
   * @returns {function({}=)}
   */
  function createAsyncAction(actionName) {
    var resourceMethod = arguments.length <= 1 || arguments[1] === undefined ? null : arguments[1];
    var methodExtraParams = arguments.length <= 2 || arguments[2] === undefined ? {} : arguments[2];

    if (!resourceMethod) resourceMethod = actionName;

    var subActionCreators = {
      requested: actionCreators[actionName + 'Requested'],
      success: actionCreators[actionName + 'Success'],
      error: actionCreators[actionName + 'Error']
    };
    var queryGenerator = _queryGenerators2.default[actionName] || function () {
      return {};
    };

    /* eslint-disable arrow-body-style */
    return function restAsyncActionCreator() {
      var _ref = arguments.length <= 0 || arguments[0] === undefined ? {} : arguments[0];

      var params = _ref.params;
      var body = _ref.body;


      return depsContainer.dispatch(function restAsyncAction(_ref2) {
        var dispatch = _ref2.dispatch;
        var getState = _ref2.getState;


        var state = getThisState(getState());
        var authState = getAuthState(getState());
        var queryParams = (0, _extends3.default)({}, queryGenerator(state), extraParams, (0, _humps.decamelizeKeys)(params), methodExtraParams); // eslint-disable-line max-len

        var _resource$resourceMet = resource[resourceMethod](queryParams, body, authState ? authState.token : '');

        var executeResourceMethod = _resource$resourceMet.executeResourceMethod;


        dispatch(subActionCreators.requested());

        return executeResourceMethod().then(function (response) {
          if (response.status === 401 || response.status === 403) {
            dispatch(actionCreators.authenticationRequired());
            dispatch(subActionCreators.error({ errorMessage: 'Error: unauthorized' }));
            return response;
          }
          dispatch(subActionCreators.success(response));
          return response;
        }).catch(function (error) {
          console.log(error);
          var errorMessage = '' + error.message;
          dispatch(subActionCreators.error({ errorMessage: errorMessage }));
          depsContainer.errorHandler(errorMessage);
        });
      });
    };
  }

  // fetchIds uses fetchCollection resource with predefined params:
  var fetchIds = createAsyncAction('fetchIds', 'fetchCollection', {
    fields: 'id',
    page: 1,
    per_page: 10000000,
    include: null
  });
  var fetchCollection = createAsyncAction('fetchCollection');
  var fetchCollectionByIds = createAsyncAction('fetchCollectionByIds', 'fetchCollection');
  var fetchOne = createAsyncAction('fetchOne');
  var create = createAsyncAction('create');
  var update = createAsyncAction('update');
  var destroy = createAsyncAction('destroy');

  var updateCollection = function updateCollection() {
    if (isStaticCollection) return fetchIds().then(function () {
      return fetchCollectionByIds();
    });

    return fetchCollection();
  };

  // ***** SYNC action creators ***** */

  var pointCursorTo = function pointCursorTo(cursorAt) {
    return function (_ref3) {
      var dispatch = _ref3.dispatch;

      return dispatch(actionCreators.pointCursorTo({ cursorAt: cursorAt }));
    };
  };

  var fetchOneAt = function fetchOneAt(cursorAt) {
    return function (_ref4) {
      var dispatch = _ref4.dispatch;
      var getState = _ref4.getState;

      dispatch(actionCreators.pointCursorTo({ cursorAt: cursorAt }));

      var subState = getThisState(getState());
      var id = subState.ids.get(cursorAt - 1);
      if (!id) depsContainer.handleError('No valid resource \'' + resourceName + '\' found at position ' + cursorAt);

      return fetchOne({ params: { id: id } });
    };
  };

  var gotoPage = function gotoPage(page) {
    return function (_ref5) {
      var dispatch = _ref5.dispatch;

      dispatch(actionCreators.gotoPage({ page: page }));

      var fetchFn = isStaticCollection ? fetchCollectionByIds : fetchCollection;
      return fetchFn();
    };
  };

  var setPagination = function setPagination(pagination) {
    return function (_ref6) {
      var dispatch = _ref6.dispatch;

      dispatch(actionCreators.setPagination({ pagination: pagination }));

      var fetchFn = isStaticCollection ? fetchCollectionByIds : fetchCollection;
      return fetchFn();
    };
  };

  var setPageSize = function setPageSize(perPage) {
    return function (_ref7) {
      var dispatch = _ref7.dispatch;

      dispatch(actionCreators.setPageSize({ perPage: perPage }));
      return updateCollection();
    };
  };

  var sortChange = function sortChange(sortField) {
    return function (_ref8) {
      var dispatch = _ref8.dispatch;

      dispatch(actionCreators.sortChange({ sortField: sortField }));
      return updateCollection();
    };
  };

  /**
   * @param {Array||Filter} filter
   */
  var filterChange = function filterChange(filter) {
    return function (_ref9) {
      var dispatch = _ref9.dispatch;

      if (filter.constructor !== Array) filter = [filter];
      filter.forEach(function (filter) {
        if (!(filter instanceof _Filter2.default)) filter = new _Filter2.default(filter);
        dispatch(actionCreators.filterChange({ filter: filter }));
      });
      return updateCollection();
    };
  };

  var generalParamChange = function generalParamChange(paramObj) {
    return function (_ref10) {
      var dispatch = _ref10.dispatch;

      dispatch(actionCreators.generalParamChange({ paramObj: paramObj }));
      return updateCollection();
    };
  };

  var clearEntities = function clearEntities() {
    return depsContainer.dispatch(actionCreators.clearEntities());
  };

  return {
    fetchIds: fetchIds,
    fetchCollection: fetchCollection,
    fetchCollectionByIds: fetchCollectionByIds,
    fetchOne: fetchOne,
    create: create,
    update: update,
    destroy: destroy,
    pointCursorTo: pointCursorTo,
    fetchOneAt: fetchOneAt,
    gotoPage: gotoPage,
    setPagination: setPagination,
    setPageSize: setPageSize,
    sortChange: sortChange,
    filterChange: filterChange,
    generalParamChange: generalParamChange,
    clearEntities: clearEntities
  };
} /** Created by hhj on 1/29/16. */