"use strict";
var _interopRequireDefault = require("@babel/runtime-corejs3/helpers/interopRequireDefault");
var _stringify = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/json/stringify"));
var _splice = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/splice"));
var _findIndex = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/find-index"));
var _setInterval2 = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/set-interval"));
var _find = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/find"));
var _regenerator = _interopRequireDefault(require("@babel/runtime-corejs3/regenerator"));
var _toConsumableArray2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/toConsumableArray"));
var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/asyncToGenerator"));
var _CoreManager = _interopRequireDefault(require("./CoreManager"));
var _ParseObject = _interopRequireDefault(require("./ParseObject"));
var _ParseQuery = _interopRequireDefault(require("./ParseQuery"));
var _Storage = _interopRequireDefault(require("./Storage"));
/**
* https://github.com/francimedia/parse-js-local-storage
*
* @flow
*/
/*:: import type { SaveOptions } from './ParseObject';*/
/*:: import type { RequestOptions } from './RESTController';*/
/*:: type QueueObject = {
queueId: string,
action: string,
object: ParseObject,
serverOptions: SaveOptions | RequestOptions,
id: string,
className: string,
hash: string,
createdAt: Date,
};*/
/*:: type Queue = Array<QueueObject>;*/
var QUEUE_KEY = 'Parse/Eventually/Queue';
var queueCache = [];
var dirtyCache = true;
var polling = undefined;
/**
* Provides utility functions to queue objects that will be
* saved to the server at a later date.
*
* @class Parse.EventuallyQueue
* @static
*/
var EventuallyQueue = {
/**
* Add object to queue with save operation.
*
* @function save
* @name Parse.EventuallyQueue.save
* @param {ParseObject} object Parse.Object to be saved eventually
* @param {object} [serverOptions] See {@link https://parseplatform.org/Parse-SDK-JS/api/master/Parse.Object.html#save Parse.Object.save} options.
* @returns {Promise} A promise that is fulfilled if object is added to queue.
* @static
* @see Parse.Object#saveEventually
*/
save: function (object /*: ParseObject*/) /*: Promise*/{
var serverOptions /*: SaveOptions*/ = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
return this.enqueue('save', object, serverOptions);
},
/**
* Add object to queue with save operation.
*
* @function destroy
* @name Parse.EventuallyQueue.destroy
* @param {ParseObject} object Parse.Object to be destroyed eventually
* @param {object} [serverOptions] See {@link https://parseplatform.org/Parse-SDK-JS/api/master/Parse.Object.html#destroy Parse.Object.destroy} options
* @returns {Promise} A promise that is fulfilled if object is added to queue.
* @static
* @see Parse.Object#destroyEventually
*/
destroy: function (object /*: ParseObject*/) /*: Promise*/{
var serverOptions /*: RequestOptions*/ = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {};
return this.enqueue('destroy', object, serverOptions);
},
/**
* Generate unique identifier to avoid duplicates and maintain previous state.
*
* @param {string} action save / destroy
* @param {object} object Parse.Object to be queued
* @returns {string}
* @static
* @ignore
*/
generateQueueId: function (action /*: string*/, object /*: ParseObject*/) /*: string*/{
object._getId();
var className = object.className,
id = object.id,
_localId = object._localId;
var uniqueId = object.get('hash') || _localId;
return [action, className, id, uniqueId].join('_');
},
/**
* Build queue object and add to queue.
*
* @param {string} action save / destroy
* @param {object} object Parse.Object to be queued
* @param {object} [serverOptions]
* @returns {Promise} A promise that is fulfilled if object is added to queue.
* @static
* @ignore
*/
enqueue: function (action /*: string*/, object /*: ParseObject*/, serverOptions /*: SaveOptions | RequestOptions*/) /*: Promise*/{
var _this = this;
return (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee() {
var queueData, queueId, index, prop;
return _regenerator.default.wrap(function (_context) {
while (1) switch (_context.prev = _context.next) {
case 0:
_context.next = 2;
return _this.getQueue();
case 2:
queueData = _context.sent;
queueId = _this.generateQueueId(action, object);
index = _this.queueItemExists(queueData, queueId);
if (index > -1) {
// Add cached values to new object if they don't exist
for (prop in queueData[index].object) {
if (typeof object.get(prop) === 'undefined') {
object.set(prop, queueData[index].object[prop]);
}
}
} else {
index = queueData.length;
}
queueData[index] = {
queueId: queueId,
action: action,
object: object.toJSON(),
serverOptions: serverOptions,
id: object.id,
className: object.className,
hash: object.get('hash'),
createdAt: new Date()
};
return _context.abrupt("return", _this.setQueue(queueData));
case 8:
case "end":
return _context.stop();
}
}, _callee);
}))();
},
store: function (data) {
return _Storage.default.setItemAsync(QUEUE_KEY, (0, _stringify.default)(data));
},
load: function () {
return _Storage.default.getItemAsync(QUEUE_KEY);
},
/**
* Sets the in-memory queue from local storage and returns.
*
* @function getQueue
* @name Parse.EventuallyQueue.getQueue
* @returns {Promise<Array>}
* @static
*/
getQueue: function () /*: Promise<Array>*/{
var _this2 = this;
return (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee2() {
return _regenerator.default.wrap(function (_context2) {
while (1) switch (_context2.prev = _context2.next) {
case 0:
if (!dirtyCache) {
_context2.next = 10;
break;
}
_context2.t0 = JSON;
_context2.next = 4;
return _this2.load();
case 4:
_context2.t1 = _context2.sent;
if (_context2.t1) {
_context2.next = 7;
break;
}
_context2.t1 = '[]';
case 7:
_context2.t2 = _context2.t1;
queueCache = _context2.t0.parse.call(_context2.t0, _context2.t2);
dirtyCache = false;
case 10:
return _context2.abrupt("return", queueCache);
case 11:
case "end":
return _context2.stop();
}
}, _callee2);
}))();
},
/**
* Saves the queue to local storage
*
* @param {Queue} queue Queue containing Parse.Object data.
* @returns {Promise} A promise that is fulfilled when queue is stored.
* @static
* @ignore
*/
setQueue: function (queue /*: Queue*/) /*: Promise<void>*/{
queueCache = queue;
return this.store(queueCache);
},
/**
* Removes Parse.Object data from queue.
*
* @param {string} queueId Unique identifier for Parse.Object data.
* @returns {Promise} A promise that is fulfilled when queue is stored.
* @static
* @ignore
*/
remove: function (queueId /*: string*/) /*: Promise<void>*/{
var _this3 = this;
return (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee3() {
var queueData, index;
return _regenerator.default.wrap(function (_context3) {
while (1) switch (_context3.prev = _context3.next) {
case 0:
_context3.next = 2;
return _this3.getQueue();
case 2:
queueData = _context3.sent;
index = _this3.queueItemExists(queueData, queueId);
if (!(index > -1)) {
_context3.next = 8;
break;
}
(0, _splice.default)(queueData).call(queueData, index, 1);
_context3.next = 8;
return _this3.setQueue(queueData);
case 8:
case "end":
return _context3.stop();
}
}, _callee3);
}))();
},
/**
* Removes all objects from queue.
*
* @function clear
* @name Parse.EventuallyQueue.clear
* @returns {Promise} A promise that is fulfilled when queue is cleared.
* @static
*/
clear: function () /*: Promise*/{
queueCache = [];
return this.store([]);
},
/**
* Return the index of a queueId in the queue. Returns -1 if not found.
*
* @param {Queue} queue Queue containing Parse.Object data.
* @param {string} queueId Unique identifier for Parse.Object data.
* @returns {number}
* @static
* @ignore
*/
queueItemExists: function (queue /*: Queue*/, queueId /*: string*/) /*: number*/{
return (0, _findIndex.default)(queue).call(queue, function (data) {
return data.queueId === queueId;
});
},
/**
* Return the number of objects in the queue.
*
* @function length
* @name Parse.EventuallyQueue.length
* @returns {number}
* @static
*/
length: function () /*: number*/{
var _this4 = this;
return (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee4() {
var queueData;
return _regenerator.default.wrap(function (_context4) {
while (1) switch (_context4.prev = _context4.next) {
case 0:
_context4.next = 2;
return _this4.getQueue();
case 2:
queueData = _context4.sent;
return _context4.abrupt("return", queueData.length);
case 4:
case "end":
return _context4.stop();
}
}, _callee4);
}))();
},
/**
* Sends the queue to the server.
*
* @function sendQueue
* @name Parse.EventuallyQueue.sendQueue
* @returns {Promise<boolean>} Returns true if queue was sent successfully.
* @static
*/
sendQueue: function () /*: Promise<boolean>*/{
var _this5 = this;
return (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee5() {
var queue, queueData, i, queueObject, id, hash, className, ObjectType;
return _regenerator.default.wrap(function (_context5) {
while (1) switch (_context5.prev = _context5.next) {
case 0:
_context5.next = 2;
return _this5.getQueue();
case 2:
queue = _context5.sent;
queueData = (0, _toConsumableArray2.default)(queue);
if (!(queueData.length === 0)) {
_context5.next = 6;
break;
}
return _context5.abrupt("return", false);
case 6:
i = 0;
case 7:
if (!(i < queueData.length)) {
_context5.next = 26;
break;
}
queueObject = queueData[i];
id = queueObject.id, hash = queueObject.hash, className = queueObject.className;
ObjectType = _ParseObject.default.extend(className);
if (!id) {
_context5.next = 16;
break;
}
_context5.next = 14;
return _this5.process.byId(ObjectType, queueObject);
case 14:
_context5.next = 23;
break;
case 16:
if (!hash) {
_context5.next = 21;
break;
}
_context5.next = 19;
return _this5.process.byHash(ObjectType, queueObject);
case 19:
_context5.next = 23;
break;
case 21:
_context5.next = 23;
return _this5.process.create(ObjectType, queueObject);
case 23:
i += 1;
_context5.next = 7;
break;
case 26:
return _context5.abrupt("return", true);
case 27:
case "end":
return _context5.stop();
}
}, _callee5);
}))();
},
/**
* Build queue object and add to queue.
*
* @param {ParseObject} object Parse.Object to be processed
* @param {QueueObject} queueObject Parse.Object data from the queue
* @returns {Promise} A promise that is fulfilled when operation is performed.
* @static
* @ignore
*/
sendQueueCallback: function (object /*: ParseObject*/, queueObject /*: QueueObject*/) /*: Promise<void>*/{
var _this6 = this;
return (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee6() {
return _regenerator.default.wrap(function (_context6) {
while (1) switch (_context6.prev = _context6.next) {
case 0:
if (object) {
_context6.next = 2;
break;
}
return _context6.abrupt("return", _this6.remove(queueObject.queueId));
case 2:
_context6.t0 = queueObject.action;
_context6.next = _context6.t0 === 'save' ? 5 : _context6.t0 === 'destroy' ? 20 : 33;
break;
case 5:
if (!(typeof object.updatedAt !== 'undefined' && object.updatedAt > new Date(queueObject.object.createdAt))) {
_context6.next = 7;
break;
}
return _context6.abrupt("return", _this6.remove(queueObject.queueId));
case 7:
_context6.prev = 7;
_context6.next = 10;
return object.save(queueObject.object, queueObject.serverOptions);
case 10:
_context6.next = 12;
return _this6.remove(queueObject.queueId);
case 12:
_context6.next = 19;
break;
case 14:
_context6.prev = 14;
_context6.t1 = _context6["catch"](7);
if (!(_context6.t1.message !== 'XMLHttpRequest failed: "Unable to connect to the Parse API"')) {
_context6.next = 19;
break;
}
_context6.next = 19;
return _this6.remove(queueObject.queueId);
case 19:
return _context6.abrupt("break", 33);
case 20:
_context6.prev = 20;
_context6.next = 23;
return object.destroy(queueObject.serverOptions);
case 23:
_context6.next = 25;
return _this6.remove(queueObject.queueId);
case 25:
_context6.next = 32;
break;
case 27:
_context6.prev = 27;
_context6.t2 = _context6["catch"](20);
if (!(_context6.t2.message !== 'XMLHttpRequest failed: "Unable to connect to the Parse API"')) {
_context6.next = 32;
break;
}
_context6.next = 32;
return _this6.remove(queueObject.queueId);
case 32:
return _context6.abrupt("break", 33);
case 33:
case "end":
return _context6.stop();
}
}, _callee6, null, [[7, 14], [20, 27]]);
}))();
},
/**
* Start polling server for network connection.
* Will send queue if connection is established.
*
* @function poll
* @name Parse.EventuallyQueue.poll
* @param [ms] Milliseconds to ping the server. Default 2000ms
* @static
*/
poll: function () {
var _this7 = this;
var ms /*: number*/ = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : 2000;
if (polling) {
return;
}
polling = (0, _setInterval2.default)(function () {
var RESTController = _CoreManager.default.getRESTController();
RESTController.request('GET', 'health').then(function (_ref) {
var status = _ref.status;
if (status === 'ok') {
_this7.stopPoll();
return _this7.sendQueue();
}
}).catch(function (e) {
return e;
});
}, ms);
},
/**
* Turns off polling.
*
* @function stopPoll
* @name Parse.EventuallyQueue.stopPoll
* @static
*/
stopPoll: function () {
clearInterval(polling);
polling = undefined;
},
/**
* Return true if pinging the server.
*
* @function isPolling
* @name Parse.EventuallyQueue.isPolling
* @returns {boolean}
* @static
*/
isPolling: function () /*: boolean*/{
return !!polling;
},
_setPolling: function (flag /*: boolean*/) {
polling = flag;
},
process: {
create: function (ObjectType, queueObject) {
var object = new ObjectType();
return EventuallyQueue.sendQueueCallback(object, queueObject);
},
byId: function (ObjectType, queueObject) {
return (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee7() {
var sessionToken, query, results;
return _regenerator.default.wrap(function (_context7) {
while (1) switch (_context7.prev = _context7.next) {
case 0:
sessionToken = queueObject.serverOptions.sessionToken;
query = new _ParseQuery.default(ObjectType);
query.equalTo('objectId', queueObject.id);
_context7.next = 5;
return (0, _find.default)(query).call(query, {
sessionToken: sessionToken
});
case 5:
results = _context7.sent;
return _context7.abrupt("return", EventuallyQueue.sendQueueCallback(results[0], queueObject));
case 7:
case "end":
return _context7.stop();
}
}, _callee7);
}))();
},
byHash: function (ObjectType, queueObject) {
return (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee8() {
var sessionToken, query, results;
return _regenerator.default.wrap(function (_context8) {
while (1) switch (_context8.prev = _context8.next) {
case 0:
sessionToken = queueObject.serverOptions.sessionToken;
query = new _ParseQuery.default(ObjectType);
query.equalTo('hash', queueObject.hash);
_context8.next = 5;
return (0, _find.default)(query).call(query, {
sessionToken: sessionToken
});
case 5:
results = _context8.sent;
if (!(results.length > 0)) {
_context8.next = 8;
break;
}
return _context8.abrupt("return", EventuallyQueue.sendQueueCallback(results[0], queueObject));
case 8:
return _context8.abrupt("return", EventuallyQueue.process.create(ObjectType, queueObject));
case 9:
case "end":
return _context8.stop();
}
}, _callee8);
}))();
}
}
};
module.exports = EventuallyQueue;