| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171 | var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");Object.defineProperty(exports, "__esModule", {  value: true});exports.clearAllState = clearAllState;exports.commitServerChanges = commitServerChanges;exports.duplicateState = duplicateState;exports.enqueueTask = enqueueTask;exports.estimateAttribute = estimateAttribute;exports.estimateAttributes = estimateAttributes;exports.getObjectCache = getObjectCache;exports.getPendingOps = getPendingOps;exports.getServerData = getServerData;exports.getState = getState;exports.initializeState = initializeState;exports.mergeFirstPendingState = mergeFirstPendingState;exports.popPendingState = popPendingState;exports.pushPendingState = pushPendingState;exports.removeState = removeState;exports.setPendingOp = setPendingOp;exports.setServerData = setServerData;var ObjectStateMutations = _interopRequireWildcard(require("./ObjectStateMutations"));var _TaskQueue = _interopRequireDefault(require("./TaskQueue"));function _getRequireWildcardCache(nodeInterop) {  if (typeof WeakMap !== "function") return null;  var cacheBabelInterop = new WeakMap();  var cacheNodeInterop = new WeakMap();  return (_getRequireWildcardCache = function (nodeInterop) {    return nodeInterop ? cacheNodeInterop : cacheBabelInterop;  })(nodeInterop);}function _interopRequireWildcard(obj, nodeInterop) {  if (!nodeInterop && obj && obj.__esModule) {    return obj;  }  if (obj === null || typeof obj !== "object" && typeof obj !== "function") {    return {      default: obj    };  }  var cache = _getRequireWildcardCache(nodeInterop);  if (cache && cache.has(obj)) {    return cache.get(obj);  }  var newObj = {};  var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor;  for (var key in obj) {    if (key !== "default" && Object.prototype.hasOwnProperty.call(obj, key)) {      var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null;      if (desc && (desc.get || desc.set)) {        Object.defineProperty(newObj, key, desc);      } else {        newObj[key] = obj[key];      }    }  }  newObj.default = obj;  if (cache) {    cache.set(obj, newObj);  }  return newObj;}var objectState = new WeakMap();function getState(obj) {  var classData = objectState.get(obj);  return classData || null;}function initializeState(obj, initial) {  var state = getState(obj);  if (state) {    return state;  }  if (!initial) {    initial = {      serverData: {},      pendingOps: [{}],      objectCache: {},      tasks: new _TaskQueue.default(),      existed: false    };  }  state = initial;  objectState.set(obj, state);  return state;}function removeState(obj) {  var state = getState(obj);  if (state === null) {    return null;  }  objectState.delete(obj);  return state;}function getServerData(obj) {  var state = getState(obj);  if (state) {    return state.serverData;  }  return {};}function setServerData(obj, attributes) {  var serverData = initializeState(obj).serverData;  ObjectStateMutations.setServerData(serverData, attributes);}function getPendingOps(obj) {  var state = getState(obj);  if (state) {    return state.pendingOps;  }  return [{}];}function setPendingOp(obj, attr, op) {  var pendingOps = initializeState(obj).pendingOps;  ObjectStateMutations.setPendingOp(pendingOps, attr, op);}function pushPendingState(obj) {  var pendingOps = initializeState(obj).pendingOps;  ObjectStateMutations.pushPendingState(pendingOps);}function popPendingState(obj) {  var pendingOps = initializeState(obj).pendingOps;  return ObjectStateMutations.popPendingState(pendingOps);}function mergeFirstPendingState(obj) {  var pendingOps = getPendingOps(obj);  ObjectStateMutations.mergeFirstPendingState(pendingOps);}function getObjectCache(obj) {  var state = getState(obj);  if (state) {    return state.objectCache;  }  return {};}function estimateAttribute(obj, attr) {  var serverData = getServerData(obj);  var pendingOps = getPendingOps(obj);  return ObjectStateMutations.estimateAttribute(serverData, pendingOps, obj.className, obj.id, attr);}function estimateAttributes(obj) {  var serverData = getServerData(obj);  var pendingOps = getPendingOps(obj);  return ObjectStateMutations.estimateAttributes(serverData, pendingOps, obj.className, obj.id);}function commitServerChanges(obj, changes) {  var state = initializeState(obj);  ObjectStateMutations.commitServerChanges(state.serverData, state.objectCache, changes);}function enqueueTask(obj, task) {  var state = initializeState(obj);  return state.tasks.enqueue(task);}function duplicateState(source, dest) {  var oldState = initializeState(source);  var newState = initializeState(dest);  for (var key in oldState.serverData) {    newState.serverData[key] = oldState.serverData[key];  }  for (var index = 0; index < oldState.pendingOps.length; index++) {    for (var _key in oldState.pendingOps[index]) {      newState.pendingOps[index][_key] = oldState.pendingOps[index][_key];    }  }  for (var _key2 in oldState.objectCache) {    newState.objectCache[_key2] = oldState.objectCache[_key2];  }  newState.existed = oldState.existed;}function clearAllState() {  objectState = new WeakMap();}
 |