@shoutem/redux-io/enableRio.js

'use strict';

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

var _lodash = require('lodash');

var _lodash2 = _interopRequireDefault(_lodash);

var _reduxBatchedActions = require('redux-batched-actions');

var _rio = require('./rio');

var _rio2 = _interopRequireDefault(_rio);

var _status = require('./status');

var _ReduxApiStateDenormalizer = require('./denormalizer/ReduxApiStateDenormalizer');

var _ReduxApiStateDenormalizer2 = _interopRequireDefault(_ReduxApiStateDenormalizer);

var _storage = require('./reducers/storage');

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

function _toConsumableArray(arr) { if (Array.isArray(arr)) { for (var i = 0, arr2 = Array(arr.length); i < arr.length; i++) { arr2[i] = arr[i]; } return arr2; } else { return Array.from(arr); } }

function discoverSchemaPaths(obj) {
  var currentPath = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : [];
  var discoveredPaths = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : {};

  var status = (0, _status.getStatus)(obj);
  if (status && status.type === _storage.STORAGE_TYPE) {
    // TODO: add validation if schema path are repeating to throw warning
    // eslint-disable-next-line no-param-reassign
    discoveredPaths[status.schema] = currentPath;
    return discoveredPaths;
  }

  _lodash2.default.forOwn(obj, function (propValue, prop) {
    if (_lodash2.default.isPlainObject(propValue)) {
      discoverSchemaPaths(propValue, [].concat(_toConsumableArray(currentPath), [prop]), discoveredPaths);
    }
  });

  return discoveredPaths;
}

function enableRio(reducer) {
  var initialState = reducer(undefined, { type: 'unknown' });
  var paths = discoverSchemaPaths(initialState);

  _rio2.default.setSchemaPaths(paths);
  _rio2.default.setDenormalizer(new _ReduxApiStateDenormalizer2.default());

  return (0, _reduxBatchedActions.enableBatching)(reducer);
}