@startupjs/react-sharedb/lib/util.js

'use strict';

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

var _stringify = require('babel-runtime/core-js/json/stringify');

var _stringify2 = _interopRequireDefault(_stringify);

var _typeof2 = require('babel-runtime/helpers/typeof');

var _typeof3 = _interopRequireDefault(_typeof2);

exports.observablePath = observablePath;
exports.initLocalCollection = initLocalCollection;
exports.clone = clone;

var _model = require('@startupjs/model');

var _model2 = _interopRequireDefault(_model);

var _observerUtil = require('@nx-js/observer-util');

var _get = require('lodash/get');

var _get2 = _interopRequireDefault(_get);

var _semaphore = require('./semaphore');

var _semaphore2 = _interopRequireDefault(_semaphore);

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

function observablePath(path) {
  var segments = _model2.default._splitPath(path);
  var originalSegments = _model2.default._dereference(segments, true);
  var parentSegments = originalSegments.slice(0, -1);
  var leafSegment = originalSegments[originalSegments.length - 1];
  var result = (0, _get2.default)(_model2.default.data, originalSegments);
  if ((typeof result === 'undefined' ? 'undefined' : (0, _typeof3.default)(result)) === 'object' && result !== null && !(0, _observerUtil.isObservable)(result)) {
    (0, _get2.default)(_model2.default.data, parentSegments)[leafSegment] = (0, _observerUtil.observable)(result);
  }
}

function initLocalCollection(collection) {
  _semaphore2.default.ignoreCollectionObservableWarning = true;
  _semaphore2.default.allowComponentSetter = true;
  _model2.default.set(collection + '.__OBSERVABLE', true);
  _semaphore2.default.allowComponentSetter = false;
  _semaphore2.default.ignoreCollectionObservableWarning = false;
  _model2.default.data[collection] = (0, _observerUtil.observable)(_model2.default.data[collection]);
}

function clone(data) {
  var stringified = (0, _stringify2.default)(data);
  if (!stringified) return undefined;
  return JSON.parse(stringified);
}