"use strict"; var _Reflect$construct = require("@babel/runtime-corejs3/core-js-stable/reflect/construct"); var _sliceInstanceProperty = require("@babel/runtime-corejs3/core-js-stable/instance/slice"); var _Array$from = require("@babel/runtime-corejs3/core-js-stable/array/from"); var _Symbol = require("@babel/runtime-corejs3/core-js-stable/symbol"); var _getIteratorMethod = require("@babel/runtime-corejs3/core-js/get-iterator-method"); var _Array$isArray = require("@babel/runtime-corejs3/core-js-stable/array/is-array"); var _Object$defineProperty = require("@babel/runtime-corejs3/core-js-stable/object/define-property"); var _interopRequireDefault = require("@babel/runtime-corejs3/helpers/interopRequireDefault"); _Object$defineProperty(exports, "__esModule", { value: true }); exports.default = void 0; var _indexOf = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/index-of")); var _map = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/map")); var _keys = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/keys")); var _stringify = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/json/stringify")); var _forEach = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/for-each")); var _values = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/values")); var _setTimeout2 = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/set-timeout")); var _bind = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/bind")); var _typeof2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/typeof")); var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/classCallCheck")); var _createClass2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/createClass")); var _assertThisInitialized2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/assertThisInitialized")); var _inherits2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/inherits")); var _possibleConstructorReturn2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/possibleConstructorReturn")); var _getPrototypeOf2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/getPrototypeOf")); var _defineProperty2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/defineProperty")); var _CoreManager = _interopRequireDefault(require("./CoreManager")); var _EventEmitter2 = _interopRequireDefault(require("./EventEmitter")); var _ParseObject = _interopRequireDefault(require("./ParseObject")); var _LiveQuerySubscription = _interopRequireDefault(require("./LiveQuerySubscription")); var _promiseUtils = require("./promiseUtils"); var _ParseError = _interopRequireDefault(require("./ParseError")); function _createForOfIteratorHelper(o, allowArrayLike) { var it = typeof _Symbol !== "undefined" && _getIteratorMethod(o) || o["@@iterator"]; if (!it) { if (_Array$isArray(o) || (it = _unsupportedIterableToArray(o)) || allowArrayLike && o && typeof o.length === "number") { if (it) o = it; var i = 0; var F = function () {}; return { s: F, n: function () { if (i >= o.length) return { done: true }; return { done: false, value: o[i++] }; }, e: function (_e) { throw _e; }, f: F }; } throw new TypeError("Invalid attempt to iterate non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method."); } var normalCompletion = true, didErr = false, err; return { s: function () { it = it.call(o); }, n: function () { var step = it.next(); normalCompletion = step.done; return step; }, e: function (_e2) { didErr = true; err = _e2; }, f: function () { try { if (!normalCompletion && it.return != null) it.return(); } finally { if (didErr) throw err; } } }; } function _unsupportedIterableToArray(o, minLen) { var _context6; if (!o) return; if (typeof o === "string") return _arrayLikeToArray(o, minLen); var n = _sliceInstanceProperty(_context6 = Object.prototype.toString.call(o)).call(_context6, 8, -1); if (n === "Object" && o.constructor) n = o.constructor.name; if (n === "Map" || n === "Set") return _Array$from(o); if (n === "Arguments" || /^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n)) return _arrayLikeToArray(o, minLen); } function _arrayLikeToArray(arr, len) { if (len == null || len > arr.length) len = arr.length; for (var i = 0, arr2 = new Array(len); i < len; i++) arr2[i] = arr[i]; return arr2; } function _createSuper(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct(); return function () { var Super = (0, _getPrototypeOf2.default)(Derived), result; if (hasNativeReflectConstruct) { var NewTarget = (0, _getPrototypeOf2.default)(this).constructor; result = _Reflect$construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return (0, _possibleConstructorReturn2.default)(this, result); }; } function _isNativeReflectConstruct() { if (typeof Reflect === "undefined" || !_Reflect$construct) return false; if (_Reflect$construct.sham) return false; if (typeof Proxy === "function") return true; try { Boolean.prototype.valueOf.call(_Reflect$construct(Boolean, [], function () {})); return true; } catch (e) { return false; } } /* global WebSocket */ // The LiveQuery client inner state var CLIENT_STATE = { INITIALIZED: 'initialized', CONNECTING: 'connecting', CONNECTED: 'connected', CLOSED: 'closed', RECONNECTING: 'reconnecting', DISCONNECTED: 'disconnected' }; // The event type the LiveQuery client should sent to server var OP_TYPES = { CONNECT: 'connect', SUBSCRIBE: 'subscribe', UNSUBSCRIBE: 'unsubscribe', ERROR: 'error' }; // The event we get back from LiveQuery server var OP_EVENTS = { CONNECTED: 'connected', SUBSCRIBED: 'subscribed', UNSUBSCRIBED: 'unsubscribed', ERROR: 'error', CREATE: 'create', UPDATE: 'update', ENTER: 'enter', LEAVE: 'leave', DELETE: 'delete' }; // The event the LiveQuery client should emit var CLIENT_EMMITER_TYPES = { CLOSE: 'close', ERROR: 'error', OPEN: 'open' }; // The event the LiveQuery subscription should emit var SUBSCRIPTION_EMMITER_TYPES = { OPEN: 'open', CLOSE: 'close', ERROR: 'error', CREATE: 'create', UPDATE: 'update', ENTER: 'enter', LEAVE: 'leave', DELETE: 'delete' }; var generateInterval = function (k) { return Math.random() * Math.min(30, Math.pow(2, k) - 1) * 1000; }; /** * Creates a new LiveQueryClient. * Extends events.EventEmitter * cloud functions. * * A wrapper of a standard WebSocket client. We add several useful methods to * help you connect/disconnect to LiveQueryServer, subscribe/unsubscribe a ParseQuery easily. * * javascriptKey and masterKey are used for verifying the LiveQueryClient when it tries * to connect to the LiveQuery server * * We expose three events to help you monitor the status of the LiveQueryClient. * *
* let Parse = require('parse/node');
* let LiveQueryClient = Parse.LiveQueryClient;
* let client = new LiveQueryClient({
* applicationId: '',
* serverURL: '',
* javascriptKey: '',
* masterKey: ''
* });
*
*
* Open - When we establish the WebSocket connection to the LiveQuery server, you'll get this event.
*
* client.on('open', () => {
*
* });
*
* Close - When we lose the WebSocket connection to the LiveQuery server, you'll get this event.
*
* client.on('close', () => {
*
* });
*
* Error - When some network error or LiveQuery server error happens, you'll get this event.
*
* client.on('error', (error) => {
*
* });
*
* @alias Parse.LiveQueryClient
*/
var LiveQueryClient = /*#__PURE__*/function (_EventEmitter) {
(0, _inherits2.default)(LiveQueryClient, _EventEmitter);
var _super = _createSuper(LiveQueryClient);
/**
* @param {object} options
* @param {string} options.applicationId - applicationId of your Parse app
* @param {string} options.serverURL - the URL of your LiveQuery server
* @param {string} options.javascriptKey (optional)
* @param {string} options.masterKey (optional) Your Parse Master Key. (Node.js only!)
* @param {string} options.sessionToken (optional)
* @param {string} options.installationId (optional)
*/
function LiveQueryClient(_ref) {
var _this;
var applicationId = _ref.applicationId,
serverURL = _ref.serverURL,
javascriptKey = _ref.javascriptKey,
masterKey = _ref.masterKey,
sessionToken = _ref.sessionToken,
installationId = _ref.installationId;
(0, _classCallCheck2.default)(this, LiveQueryClient);
_this = _super.call(this);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "attempts", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "id", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "requestId", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "applicationId", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "serverURL", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "javascriptKey", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "masterKey", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "sessionToken", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "installationId", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "additionalProperties", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "connectPromise", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "subscriptions", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "socket", void 0);
(0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "state", void 0);
if (!serverURL || (0, _indexOf.default)(serverURL).call(serverURL, 'ws') !== 0) {
throw new Error('You need to set a proper Parse LiveQuery server url before using LiveQueryClient');
}
_this.reconnectHandle = null;
_this.attempts = 1;
_this.id = 0;
_this.requestId = 1;
_this.serverURL = serverURL;
_this.applicationId = applicationId;
_this.javascriptKey = javascriptKey || undefined;
_this.masterKey = masterKey || undefined;
_this.sessionToken = sessionToken || undefined;
_this.installationId = installationId || undefined;
_this.additionalProperties = true;
_this.connectPromise = (0, _promiseUtils.resolvingPromise)();
_this.subscriptions = new _map.default();
_this.state = CLIENT_STATE.INITIALIZED;
// adding listener so process does not crash
// best practice is for developer to register their own listener
_this.on('error', function () {});
return _this;
}
(0, _createClass2.default)(LiveQueryClient, [{
key: "shouldOpen",
value: function () /*: any*/{
return this.state === CLIENT_STATE.INITIALIZED || this.state === CLIENT_STATE.DISCONNECTED;
}
/**
* Subscribes to a ParseQuery
*
* If you provide the sessionToken, when the LiveQuery server gets ParseObject's
* updates from parse server, it'll try to check whether the sessionToken fulfills
* the ParseObject's ACL. The LiveQuery server will only send updates to clients whose
* sessionToken is fit for the ParseObject's ACL. You can check the LiveQuery protocol
* here for more details. The subscription you get is the same subscription you get
* from our Standard API.
*
* @param {object} query - the ParseQuery you want to subscribe to
* @param {string} sessionToken (optional)
* @returns {LiveQuerySubscription | undefined}
*/
}, {
key: "subscribe",
value: function (query /*: Object*/, sessionToken /*: ?string*/) /*: LiveQuerySubscription*/{
var _queryJSON$keys,
_queryJSON$watch,
_this2 = this;
if (!query) {
return;
}
var className = query.className;
var queryJSON = query.toJSON();
var where = queryJSON.where;
var fields = (_queryJSON$keys = (0, _keys.default)(queryJSON)) === null || _queryJSON$keys === void 0 ? void 0 : _queryJSON$keys.split(',');
var watch = (_queryJSON$watch = queryJSON.watch) === null || _queryJSON$watch === void 0 ? void 0 : _queryJSON$watch.split(',');
var subscribeRequest = {
op: OP_TYPES.SUBSCRIBE,
requestId: this.requestId,
query: {
className: className,
where: where,
fields: fields,
watch: watch
}
};
if (sessionToken) {
subscribeRequest.sessionToken = sessionToken;
}
var subscription = new _LiveQuerySubscription.default(this.requestId, query, sessionToken);
this.subscriptions.set(this.requestId, subscription);
this.requestId += 1;
this.connectPromise.then(function () {
_this2.socket.send((0, _stringify.default)(subscribeRequest));
}).catch(function (error) {
subscription.subscribePromise.reject(error);
});
return subscription;
}
/**
* After calling unsubscribe you'll stop receiving events from the subscription object.
*
* @param {object} subscription - subscription you would like to unsubscribe from.
* @returns {Promise | undefined}
*/
}, {
key: "unsubscribe",
value: function (subscription /*: Object*/) /*: ?Promise*/{
var _this3 = this;
if (!subscription) {
return;
}
var unsubscribeRequest = {
op: OP_TYPES.UNSUBSCRIBE,
requestId: subscription.id
};
return this.connectPromise.then(function () {
return _this3.socket.send((0, _stringify.default)(unsubscribeRequest));
}).then(function () {
return subscription.unsubscribePromise;
});
}
/**
* After open is called, the LiveQueryClient will try to send a connect request
* to the LiveQuery server.
*
*/
}, {
key: "open",
value: function () {
var _this4 = this;
var WebSocketImplementation = _CoreManager.default.getWebSocketController();
if (!WebSocketImplementation) {
this.emit(CLIENT_EMMITER_TYPES.ERROR, 'Can not find WebSocket implementation');
return;
}
if (this.state !== CLIENT_STATE.RECONNECTING) {
this.state = CLIENT_STATE.CONNECTING;
}
this.socket = new WebSocketImplementation(this.serverURL);
this.socket.closingPromise = (0, _promiseUtils.resolvingPromise)();
// Bind WebSocket callbacks
this.socket.onopen = function () {
_this4._handleWebSocketOpen();
};
this.socket.onmessage = function (event) {
_this4._handleWebSocketMessage(event);
};
this.socket.onclose = function (event) {
_this4.socket.closingPromise.resolve(event);
_this4._handleWebSocketClose();
};
this.socket.onerror = function (error) {
_this4._handleWebSocketError(error);
};
}
}, {
key: "resubscribe",
value: function () {
var _context,
_this5 = this;
(0, _forEach.default)(_context = this.subscriptions).call(_context, function (subscription, requestId) {
var query = subscription.query;
var queryJSON = query.toJSON();
var where = queryJSON.where;
var fields = (0, _keys.default)(queryJSON) ? (0, _keys.default)(queryJSON).split(',') : undefined;
var className = query.className;
var sessionToken = subscription.sessionToken;
var subscribeRequest = {
op: OP_TYPES.SUBSCRIBE,
requestId: requestId,
query: {
className: className,
where: where,
fields: fields
}
};
if (sessionToken) {
subscribeRequest.sessionToken = sessionToken;
}
_this5.connectPromise.then(function () {
_this5.socket.send((0, _stringify.default)(subscribeRequest));
});
});
}
/**
* This method will close the WebSocket connection to this LiveQueryClient,
* cancel the auto reconnect and unsubscribe all subscriptions based on it.
*
* @returns {Promise | undefined} CloseEvent {@link https://developer.mozilla.org/en-US/docs/Web/API/WebSocket/close_event}
*/
}, {
key: "close",
value: function () /*: ?Promise*/{
var _this$socket, _this$socket2, _context2;
if (this.state === CLIENT_STATE.INITIALIZED || this.state === CLIENT_STATE.DISCONNECTED) {
return;
}
this.state = CLIENT_STATE.DISCONNECTED;
(_this$socket = this.socket) === null || _this$socket === void 0 ? void 0 : _this$socket.close();
// Notify each subscription about the close
var _iterator = _createForOfIteratorHelper((0, _values.default)(_context2 = this.subscriptions).call(_context2)),
_step;
try {
for (_iterator.s(); !(_step = _iterator.n()).done;) {
var subscription = _step.value;
subscription.subscribed = false;
subscription.emit(SUBSCRIPTION_EMMITER_TYPES.CLOSE);
}
} catch (err) {
_iterator.e(err);
} finally {
_iterator.f();
}
this._handleReset();
this.emit(CLIENT_EMMITER_TYPES.CLOSE);
return (_this$socket2 = this.socket) === null || _this$socket2 === void 0 ? void 0 : _this$socket2.closingPromise;
}
// ensure we start with valid state if connect is called again after close
}, {
key: "_handleReset",
value: function () {
this.attempts = 1;
this.id = 0;
this.requestId = 1;
this.connectPromise = (0, _promiseUtils.resolvingPromise)();
this.subscriptions = new _map.default();
}
}, {
key: "_handleWebSocketOpen",
value: function () {
this.attempts = 1;
var connectRequest = {
op: OP_TYPES.CONNECT,
applicationId: this.applicationId,
javascriptKey: this.javascriptKey,
masterKey: this.masterKey,
sessionToken: this.sessionToken
};
if (this.additionalProperties) {
connectRequest.installationId = this.installationId;
}
this.socket.send((0, _stringify.default)(connectRequest));
}
}, {
key: "_handleWebSocketMessage",
value: function (event /*: any*/) {
var data = event.data;
if (typeof data === 'string') {
data = JSON.parse(data);
}
var subscription = null;
if (data.requestId) {
subscription = this.subscriptions.get(data.requestId);
}
var response = {
clientId: data.clientId,
installationId: data.installationId
};
switch (data.op) {
case OP_EVENTS.CONNECTED:
if (this.state === CLIENT_STATE.RECONNECTING) {
this.resubscribe();
}
this.emit(CLIENT_EMMITER_TYPES.OPEN);
this.id = data.clientId;
this.connectPromise.resolve();
this.state = CLIENT_STATE.CONNECTED;
break;
case OP_EVENTS.SUBSCRIBED:
if (subscription) {
subscription.subscribed = true;
subscription.subscribePromise.resolve();
(0, _setTimeout2.default)(function () {
return subscription.emit(SUBSCRIPTION_EMMITER_TYPES.OPEN, response);
}, 200);
}
break;
case OP_EVENTS.ERROR:
{
var parseError = new _ParseError.default(data.code, data.error);
if (!this.id) {
this.connectPromise.reject(parseError);
this.state = CLIENT_STATE.DISCONNECTED;
}
if (data.requestId) {
if (subscription) {
subscription.subscribePromise.reject(parseError);
(0, _setTimeout2.default)(function () {
return subscription.emit(SUBSCRIPTION_EMMITER_TYPES.ERROR, data.error);
}, 200);
}
} else {
this.emit(CLIENT_EMMITER_TYPES.ERROR, data.error);
}
if (data.error === 'Additional properties not allowed') {
this.additionalProperties = false;
}
if (data.reconnect) {
this._handleReconnect();
}
break;
}
case OP_EVENTS.UNSUBSCRIBED:
{
if (subscription) {
this.subscriptions.delete(data.requestId);
subscription.subscribed = false;
subscription.unsubscribePromise.resolve();
}
break;
}
default:
{
// create, update, enter, leave, delete cases
if (!subscription) {
break;
}
var override = false;
if (data.original) {
override = true;
delete data.original.__type;
// Check for removed fields
for (var field in data.original) {
if (!(field in data.object)) {
data.object[field] = undefined;
}
}
data.original = _ParseObject.default.fromJSON(data.original, false);
}
delete data.object.__type;
var parseObject = _ParseObject.default.fromJSON(data.object, !(subscription.query && subscription.query._select) ? override : false);
if (data.original) {
subscription.emit(data.op, parseObject, data.original, response);
} else {
subscription.emit(data.op, parseObject, response);
}
var localDatastore = _CoreManager.default.getLocalDatastore();
if (override && localDatastore.isEnabled) {
localDatastore._updateObjectIfPinned(parseObject).then(function () {});
}
}
}
}
}, {
key: "_handleWebSocketClose",
value: function () {
var _context3;
if (this.state === CLIENT_STATE.DISCONNECTED) {
return;
}
this.state = CLIENT_STATE.CLOSED;
this.emit(CLIENT_EMMITER_TYPES.CLOSE);
// Notify each subscription about the close
var _iterator2 = _createForOfIteratorHelper((0, _values.default)(_context3 = this.subscriptions).call(_context3)),
_step2;
try {
for (_iterator2.s(); !(_step2 = _iterator2.n()).done;) {
var subscription = _step2.value;
subscription.emit(SUBSCRIPTION_EMMITER_TYPES.CLOSE);
}
} catch (err) {
_iterator2.e(err);
} finally {
_iterator2.f();
}
this._handleReconnect();
}
}, {
key: "_handleWebSocketError",
value: function (error /*: any*/) {
var _context4;
this.emit(CLIENT_EMMITER_TYPES.ERROR, error);
var _iterator3 = _createForOfIteratorHelper((0, _values.default)(_context4 = this.subscriptions).call(_context4)),
_step3;
try {
for (_iterator3.s(); !(_step3 = _iterator3.n()).done;) {
var subscription = _step3.value;
subscription.emit(SUBSCRIPTION_EMMITER_TYPES.ERROR, error);
}
} catch (err) {
_iterator3.e(err);
} finally {
_iterator3.f();
}
this._handleReconnect();
}
}, {
key: "_handleReconnect",
value: function () {
var _context5,
_this6 = this;
// if closed or currently reconnecting we stop attempting to reconnect
if (this.state === CLIENT_STATE.DISCONNECTED) {
return;
}
this.state = CLIENT_STATE.RECONNECTING;
var time = generateInterval(this.attempts);
// handle case when both close/error occur at frequent rates we ensure we do not reconnect unnecessarily.
// we're unable to distinguish different between close/error when we're unable to reconnect therefore
// we try to reconnect in both cases
// server side ws and browser WebSocket behave differently in when close/error get triggered
if (this.reconnectHandle) {
clearTimeout(this.reconnectHandle);
}
this.reconnectHandle = (0, _setTimeout2.default)((0, _bind.default)(_context5 = function () {
_this6.attempts++;
_this6.connectPromise = (0, _promiseUtils.resolvingPromise)();
_this6.open();
}).call(_context5, this), time);
}
}]);
return LiveQueryClient;
}(_EventEmitter2.default);
_CoreManager.default.setWebSocketController(require('./Socket.weapp'));
var _default = LiveQueryClient;
exports.default = _default;