| 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();
 
- }
 
 
  |