123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146 |
- var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.commitServerChanges = commitServerChanges;
- exports.defaultState = defaultState;
- exports.estimateAttribute = estimateAttribute;
- exports.estimateAttributes = estimateAttributes;
- exports.mergeFirstPendingState = mergeFirstPendingState;
- exports.popPendingState = popPendingState;
- exports.pushPendingState = pushPendingState;
- exports.setPendingOp = setPendingOp;
- exports.setServerData = setServerData;
- var _encode = _interopRequireDefault(require("./encode"));
- var _ParseFile = _interopRequireDefault(require("./ParseFile"));
- var _ParseObject = _interopRequireDefault(require("./ParseObject"));
- var _ParseRelation = _interopRequireDefault(require("./ParseRelation"));
- var _TaskQueue = _interopRequireDefault(require("./TaskQueue"));
- var _ParseOp = require("./ParseOp");
- function defaultState() {
- return {
- serverData: {},
- pendingOps: [{}],
- objectCache: {},
- tasks: new _TaskQueue.default(),
- existed: false
- };
- }
- function setServerData(serverData, attributes) {
- for (var _attr in attributes) {
- if (typeof attributes[_attr] !== 'undefined') {
- serverData[_attr] = attributes[_attr];
- } else {
- delete serverData[_attr];
- }
- }
- }
- function setPendingOp(pendingOps, attr, op) {
- var last = pendingOps.length - 1;
- if (op) {
- pendingOps[last][attr] = op;
- } else {
- delete pendingOps[last][attr];
- }
- }
- function pushPendingState(pendingOps) {
- pendingOps.push({});
- }
- function popPendingState(pendingOps) {
- var first = pendingOps.shift();
- if (!pendingOps.length) {
- pendingOps[0] = {};
- }
- return first;
- }
- function mergeFirstPendingState(pendingOps) {
- var first = popPendingState(pendingOps);
- var next = pendingOps[0];
- for (var _attr2 in first) {
- if (next[_attr2] && first[_attr2]) {
- var merged = next[_attr2].mergeWith(first[_attr2]);
- if (merged) {
- next[_attr2] = merged;
- }
- } else {
- next[_attr2] = first[_attr2];
- }
- }
- }
- function estimateAttribute(serverData, pendingOps, className, id, attr) {
- var value = serverData[attr];
- for (var i = 0; i < pendingOps.length; i++) {
- if (pendingOps[i][attr]) {
- if (pendingOps[i][attr] instanceof _ParseOp.RelationOp) {
- if (id) {
- value = pendingOps[i][attr].applyTo(value, {
- className: className,
- id: id
- }, attr);
- }
- } else {
- value = pendingOps[i][attr].applyTo(value);
- }
- }
- }
- return value;
- }
- function estimateAttributes(serverData, pendingOps, className, id) {
- var data = {};
- for (var attr in serverData) {
- data[attr] = serverData[attr];
- }
- for (var i = 0; i < pendingOps.length; i++) {
- for (attr in pendingOps[i]) {
- if (pendingOps[i][attr] instanceof _ParseOp.RelationOp) {
- if (id) {
- data[attr] = pendingOps[i][attr].applyTo(data[attr], {
- className: className,
- id: id
- }, attr);
- }
- } else {
- if (attr.includes('.')) {
- var fields = attr.split('.');
- var first = fields[0];
- var last = fields[fields.length - 1];
- data[first] = Object.assign({}, serverData[first]);
- var object = Object.assign({}, data);
- for (var _i = 0; _i < fields.length - 1; _i++) {
- var key = fields[_i];
- if (!(key in object)) {
- object[key] = {};
- }
- object = object[key];
- }
- object[last] = pendingOps[i][attr].applyTo(object[last]);
- } else {
- data[attr] = pendingOps[i][attr].applyTo(data[attr]);
- }
- }
- }
- }
- return data;
- }
- function nestedSet(obj, key, value) {
- var path = key.split('.');
- for (var i = 0; i < path.length - 1; i++) {
- if (!(path[i] in obj)) obj[path[i]] = {};
- obj = obj[path[i]];
- }
- if (typeof value === 'undefined') {
- delete obj[path[path.length - 1]];
- } else {
- obj[path[path.length - 1]] = value;
- }
- }
- function commitServerChanges(serverData, objectCache, changes) {
- for (var _attr3 in changes) {
- var val = changes[_attr3];
- nestedSet(serverData, _attr3, val);
- if (val && typeof val === 'object' && !(val instanceof _ParseObject.default) && !(val instanceof _ParseFile.default) && !(val instanceof _ParseRelation.default)) {
- var json = (0, _encode.default)(val, false, true);
- objectCache[_attr3] = JSON.stringify(json);
- }
- }
- }
|