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