123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162 |
- "use strict";
- var _WeakMap2 = require("@babel/runtime-corejs3/core-js-stable/weak-map");
- var _Object$defineProperty = require("@babel/runtime-corejs3/core-js-stable/object/define-property");
- var _Object$getOwnPropertyDescriptor = require("@babel/runtime-corejs3/core-js-stable/object/get-own-property-descriptor");
- var _interopRequireDefault = require("@babel/runtime-corejs3/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 _weakMap = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/weak-map"));
- var ObjectStateMutations = _interopRequireWildcard(require("./ObjectStateMutations"));
- var _TaskQueue = _interopRequireDefault(require("./TaskQueue"));
- function _getRequireWildcardCache(e) {
- if ("function" != typeof _WeakMap2) return null;
- var r = new _WeakMap2(),
- t = new _WeakMap2();
- return (_getRequireWildcardCache = function (e) {
- return e ? t : r;
- })(e);
- }
- function _interopRequireWildcard(e, r) {
- if (!r && e && e.__esModule) return e;
- if (null === e || "object" != typeof e && "function" != typeof e) return {
- default: e
- };
- var t = _getRequireWildcardCache(r);
- if (t && t.has(e)) return t.get(e);
- var n = {
- __proto__: null
- };
- for (var u in e) if ("default" !== u && {}.hasOwnProperty.call(e, u)) {
- var i = _Object$defineProperty && _Object$getOwnPropertyDescriptor ? _Object$getOwnPropertyDescriptor(e, u) : null;
- i && (i.get || i.set) ? _Object$defineProperty(n, u, i) : n[u] = e[u];
- }
- return n.default = e, t && t.set(e, n), n;
- }
- let objectState = new _weakMap.default();
- function getState(obj) {
- const classData = objectState.get(obj);
- return classData || null;
- }
- function initializeState(obj, initial) {
- let 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) {
- const state = getState(obj);
- if (state === null) {
- return null;
- }
- objectState.delete(obj);
- return state;
- }
- function getServerData(obj) {
- const state = getState(obj);
- if (state) {
- return state.serverData;
- }
- return {};
- }
- function setServerData(obj, attributes) {
- const serverData = initializeState(obj).serverData;
- ObjectStateMutations.setServerData(serverData, attributes);
- }
- function getPendingOps(obj) {
- const state = getState(obj);
- if (state) {
- return state.pendingOps;
- }
- return [{}];
- }
- function setPendingOp(obj, attr, op) {
- const pendingOps = initializeState(obj).pendingOps;
- ObjectStateMutations.setPendingOp(pendingOps, attr, op);
- }
- function pushPendingState(obj) {
- const pendingOps = initializeState(obj).pendingOps;
- ObjectStateMutations.pushPendingState(pendingOps);
- }
- function popPendingState(obj) {
- const pendingOps = initializeState(obj).pendingOps;
- return ObjectStateMutations.popPendingState(pendingOps);
- }
- function mergeFirstPendingState(obj) {
- const pendingOps = getPendingOps(obj);
- ObjectStateMutations.mergeFirstPendingState(pendingOps);
- }
- function getObjectCache(obj) {
- const state = getState(obj);
- if (state) {
- return state.objectCache;
- }
- return {};
- }
- function estimateAttribute(obj, attr) {
- const serverData = getServerData(obj);
- const pendingOps = getPendingOps(obj);
- return ObjectStateMutations.estimateAttribute(serverData, pendingOps, obj, attr);
- }
- function estimateAttributes(obj) {
- const serverData = getServerData(obj);
- const pendingOps = getPendingOps(obj);
- return ObjectStateMutations.estimateAttributes(serverData, pendingOps, obj);
- }
- function commitServerChanges(obj, changes) {
- const state = initializeState(obj);
- ObjectStateMutations.commitServerChanges(state.serverData, state.objectCache, changes);
- }
- function enqueueTask(obj, task) {
- const state = initializeState(obj);
- return state.tasks.enqueue(task);
- }
- function duplicateState(source, dest) {
- const oldState = initializeState(source);
- const newState = initializeState(dest);
- for (const key in oldState.serverData) {
- newState.serverData[key] = oldState.serverData[key];
- }
- for (let index = 0; index < oldState.pendingOps.length; index++) {
- for (const key in oldState.pendingOps[index]) {
- newState.pendingOps[index][key] = oldState.pendingOps[index][key];
- }
- }
- for (const key in oldState.objectCache) {
- newState.objectCache[key] = oldState.objectCache[key];
- }
- newState.existed = oldState.existed;
- }
- function clearAllState() {
- objectState = new _weakMap.default();
- }
|