UniqueInstanceStateController.js 5.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171
  1. var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
  2. Object.defineProperty(exports, "__esModule", {
  3. value: true
  4. });
  5. exports.clearAllState = clearAllState;
  6. exports.commitServerChanges = commitServerChanges;
  7. exports.duplicateState = duplicateState;
  8. exports.enqueueTask = enqueueTask;
  9. exports.estimateAttribute = estimateAttribute;
  10. exports.estimateAttributes = estimateAttributes;
  11. exports.getObjectCache = getObjectCache;
  12. exports.getPendingOps = getPendingOps;
  13. exports.getServerData = getServerData;
  14. exports.getState = getState;
  15. exports.initializeState = initializeState;
  16. exports.mergeFirstPendingState = mergeFirstPendingState;
  17. exports.popPendingState = popPendingState;
  18. exports.pushPendingState = pushPendingState;
  19. exports.removeState = removeState;
  20. exports.setPendingOp = setPendingOp;
  21. exports.setServerData = setServerData;
  22. var ObjectStateMutations = _interopRequireWildcard(require("./ObjectStateMutations"));
  23. var _TaskQueue = _interopRequireDefault(require("./TaskQueue"));
  24. function _getRequireWildcardCache(nodeInterop) {
  25. if (typeof WeakMap !== "function") return null;
  26. var cacheBabelInterop = new WeakMap();
  27. var cacheNodeInterop = new WeakMap();
  28. return (_getRequireWildcardCache = function (nodeInterop) {
  29. return nodeInterop ? cacheNodeInterop : cacheBabelInterop;
  30. })(nodeInterop);
  31. }
  32. function _interopRequireWildcard(obj, nodeInterop) {
  33. if (!nodeInterop && obj && obj.__esModule) {
  34. return obj;
  35. }
  36. if (obj === null || typeof obj !== "object" && typeof obj !== "function") {
  37. return {
  38. default: obj
  39. };
  40. }
  41. var cache = _getRequireWildcardCache(nodeInterop);
  42. if (cache && cache.has(obj)) {
  43. return cache.get(obj);
  44. }
  45. var newObj = {};
  46. var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor;
  47. for (var key in obj) {
  48. if (key !== "default" && Object.prototype.hasOwnProperty.call(obj, key)) {
  49. var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null;
  50. if (desc && (desc.get || desc.set)) {
  51. Object.defineProperty(newObj, key, desc);
  52. } else {
  53. newObj[key] = obj[key];
  54. }
  55. }
  56. }
  57. newObj.default = obj;
  58. if (cache) {
  59. cache.set(obj, newObj);
  60. }
  61. return newObj;
  62. }
  63. var objectState = new WeakMap();
  64. function getState(obj) {
  65. var classData = objectState.get(obj);
  66. return classData || null;
  67. }
  68. function initializeState(obj, initial) {
  69. var state = getState(obj);
  70. if (state) {
  71. return state;
  72. }
  73. if (!initial) {
  74. initial = {
  75. serverData: {},
  76. pendingOps: [{}],
  77. objectCache: {},
  78. tasks: new _TaskQueue.default(),
  79. existed: false
  80. };
  81. }
  82. state = initial;
  83. objectState.set(obj, state);
  84. return state;
  85. }
  86. function removeState(obj) {
  87. var state = getState(obj);
  88. if (state === null) {
  89. return null;
  90. }
  91. objectState.delete(obj);
  92. return state;
  93. }
  94. function getServerData(obj) {
  95. var state = getState(obj);
  96. if (state) {
  97. return state.serverData;
  98. }
  99. return {};
  100. }
  101. function setServerData(obj, attributes) {
  102. var serverData = initializeState(obj).serverData;
  103. ObjectStateMutations.setServerData(serverData, attributes);
  104. }
  105. function getPendingOps(obj) {
  106. var state = getState(obj);
  107. if (state) {
  108. return state.pendingOps;
  109. }
  110. return [{}];
  111. }
  112. function setPendingOp(obj, attr, op) {
  113. var pendingOps = initializeState(obj).pendingOps;
  114. ObjectStateMutations.setPendingOp(pendingOps, attr, op);
  115. }
  116. function pushPendingState(obj) {
  117. var pendingOps = initializeState(obj).pendingOps;
  118. ObjectStateMutations.pushPendingState(pendingOps);
  119. }
  120. function popPendingState(obj) {
  121. var pendingOps = initializeState(obj).pendingOps;
  122. return ObjectStateMutations.popPendingState(pendingOps);
  123. }
  124. function mergeFirstPendingState(obj) {
  125. var pendingOps = getPendingOps(obj);
  126. ObjectStateMutations.mergeFirstPendingState(pendingOps);
  127. }
  128. function getObjectCache(obj) {
  129. var state = getState(obj);
  130. if (state) {
  131. return state.objectCache;
  132. }
  133. return {};
  134. }
  135. function estimateAttribute(obj, attr) {
  136. var serverData = getServerData(obj);
  137. var pendingOps = getPendingOps(obj);
  138. return ObjectStateMutations.estimateAttribute(serverData, pendingOps, obj.className, obj.id, attr);
  139. }
  140. function estimateAttributes(obj) {
  141. var serverData = getServerData(obj);
  142. var pendingOps = getPendingOps(obj);
  143. return ObjectStateMutations.estimateAttributes(serverData, pendingOps, obj.className, obj.id);
  144. }
  145. function commitServerChanges(obj, changes) {
  146. var state = initializeState(obj);
  147. ObjectStateMutations.commitServerChanges(state.serverData, state.objectCache, changes);
  148. }
  149. function enqueueTask(obj, task) {
  150. var state = initializeState(obj);
  151. return state.tasks.enqueue(task);
  152. }
  153. function duplicateState(source, dest) {
  154. var oldState = initializeState(source);
  155. var newState = initializeState(dest);
  156. for (var key in oldState.serverData) {
  157. newState.serverData[key] = oldState.serverData[key];
  158. }
  159. for (var index = 0; index < oldState.pendingOps.length; index++) {
  160. for (var _key in oldState.pendingOps[index]) {
  161. newState.pendingOps[index][_key] = oldState.pendingOps[index][_key];
  162. }
  163. }
  164. for (var _key2 in oldState.objectCache) {
  165. newState.objectCache[_key2] = oldState.objectCache[_key2];
  166. }
  167. newState.existed = oldState.existed;
  168. }
  169. function clearAllState() {
  170. objectState = new WeakMap();
  171. }