parse - npm Package Compare versions

Comparing version 5.1.0-alpha.3 to 5.1.0-alpha.4

lib/browser/CoreManager.js

@@ -190,3 +190,3 @@ "use strict";
   ENCRYPTED_KEY: null,
-  VERSION: 'js' + "5.1.0-alpha.3",
+  VERSION: 'js' + "5.1.0-alpha.4",
   APPLICATION_ID: null,
@@ -193,0 +193,0 @@ JAVASCRIPT_KEY: null,

lib/browser/LiveQueryClient.js

@@ -16,2 +16,3 @@ "use strict";
 var _map = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/map"));
+var _concat = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/concat"));
 var _keys = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/keys"));
@@ -83,6 +84,6 @@ var _stringify = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/json/stringify"));
 function _unsupportedIterableToArray(o, minLen) {
-  var _context6;
+  var _context7;
   if (!o) return;
   if (typeof o === "string") return _arrayLikeToArray(o, minLen);
-  var n = _sliceInstanceProperty(_context6 = Object.prototype.toString.call(o)).call(_context6, 8, -1);
+  var n = _sliceInstanceProperty(_context7 = Object.prototype.toString.call(o)).call(_context7, 8, -1);
   if (n === "Object" && o.constructor) n = o.constructor.name;
@@ -204,2 +205,3 @@ if (n === "Map" || n === "Set") return _Array$from(o);
   function LiveQueryClient(_ref) {
+    var _this = this;
     var applicationId = _ref.applicationId,
@@ -245,4 +247,12 @@ serverURL = _ref.serverURL,
     this.emitter = new EventEmitter();
-    this.on = this.emitter.on;
-    this.emit = this.emitter.emit;
+    this.on = function (eventName, listener) {
+      return _this.emitter.on(eventName, listener);
+    };
+    this.emit = function (eventName) {
+      var _this$emitter, _context;
+      for (var _len = arguments.length, args = new Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
+        args[_key - 1] = arguments[_key];
+      }
+      return (_this$emitter = _this.emitter).emit.apply(_this$emitter, (0, _concat.default)(_context = [eventName]).call(_context, args));
+    };
     // adding listener so process does not crash
@@ -277,3 +287,3 @@ // best practice is for developer to register their own listener
         _queryJSON$watch,
-        _this = this;
+        _this2 = this;
       if (!query) {
@@ -304,3 +314,3 @@ return;
       this.connectPromise.then(function () {
-        _this.socket.send((0, _stringify.default)(subscribeRequest));
+        _this2.socket.send((0, _stringify.default)(subscribeRequest));
       }).catch(function (error) {
@@ -321,3 +331,3 @@ subscription.subscribePromise.reject(error);
     value: function (subscription /*: Object*/) /*: ?Promise*/{
-      var _this2 = this;
+      var _this3 = this;
       if (!subscription) {
@@ -331,3 +341,3 @@ return;
       return this.connectPromise.then(function () {
-        return _this2.socket.send((0, _stringify.default)(unsubscribeRequest));
+        return _this3.socket.send((0, _stringify.default)(unsubscribeRequest));
       }).then(function () {
@@ -346,3 +356,3 @@ return subscription.unsubscribePromise;
     value: function () {
-      var _this3 = this;
+      var _this4 = this;
       var WebSocketImplementation = _CoreManager.default.getWebSocketController();
@@ -361,13 +371,13 @@ if (!WebSocketImplementation) {
       this.socket.onopen = function () {
-        _this3._handleWebSocketOpen();
+        _this4._handleWebSocketOpen();
       };
       this.socket.onmessage = function (event) {
-        _this3._handleWebSocketMessage(event);
+        _this4._handleWebSocketMessage(event);
       };
       this.socket.onclose = function (event) {
-        _this3.socket.closingPromise.resolve(event);
-        _this3._handleWebSocketClose();
+        _this4.socket.closingPromise.resolve(event);
+        _this4._handleWebSocketClose();
       };
       this.socket.onerror = function (error) {
-        _this3._handleWebSocketError(error);
+        _this4._handleWebSocketError(error);
       };
@@ -378,5 +388,5 @@ }
     value: function () {
-      var _context,
-        _this4 = this;
-      (0, _forEach.default)(_context = this.subscriptions).call(_context, function (subscription, requestId) {
+      var _context2,
+        _this5 = this;
+      (0, _forEach.default)(_context2 = this.subscriptions).call(_context2, function (subscription, requestId) {
         var query = subscription.query;
@@ -400,4 +410,4 @@ var queryJSON = query.toJSON();
         }
-        _this4.connectPromise.then(function () {
-          _this4.socket.send((0, _stringify.default)(subscribeRequest));
+        _this5.connectPromise.then(function () {
+          _this5.socket.send((0, _stringify.default)(subscribeRequest));
         });
@@ -416,3 +426,3 @@ });
     value: function () /*: ?Promise*/{
-      var _this$socket, _this$socket2, _context2;
+      var _this$socket, _this$socket2, _context3;
       if (this.state === CLIENT_STATE.INITIALIZED || this.state === CLIENT_STATE.DISCONNECTED) {
@@ -424,3 +434,3 @@ return;
       // Notify each subscription about the close
-      var _iterator = _createForOfIteratorHelper((0, _values.default)(_context2 = this.subscriptions).call(_context2)),
+      var _iterator = _createForOfIteratorHelper((0, _values.default)(_context3 = this.subscriptions).call(_context3)),
         _step;
@@ -572,3 +582,3 @@ try {
     value: function () {
-      var _context3;
+      var _context4;
       if (this.state === CLIENT_STATE.DISCONNECTED) {
@@ -580,3 +590,3 @@ return;
       // Notify each subscription about the close
-      var _iterator2 = _createForOfIteratorHelper((0, _values.default)(_context3 = this.subscriptions).call(_context3)),
+      var _iterator2 = _createForOfIteratorHelper((0, _values.default)(_context4 = this.subscriptions).call(_context4)),
         _step2;
@@ -598,5 +608,5 @@ try {
     value: function (error /*: any*/) {
-      var _context4;
+      var _context5;
       this.emit(CLIENT_EMMITER_TYPES.ERROR, error);
-      var _iterator3 = _createForOfIteratorHelper((0, _values.default)(_context4 = this.subscriptions).call(_context4)),
+      var _iterator3 = _createForOfIteratorHelper((0, _values.default)(_context5 = this.subscriptions).call(_context5)),
         _step3;
@@ -618,4 +628,4 @@ try {
     value: function () {
-      var _context5,
-        _this5 = this;
+      var _context6,
+        _this6 = this;
       // if closed or currently reconnecting we stop attempting to reconnect
@@ -636,7 +646,7 @@ if (this.state === CLIENT_STATE.DISCONNECTED) {
       }
-      this.reconnectHandle = (0, _setTimeout2.default)((0, _bind.default)(_context5 = function () {
-        _this5.attempts++;
-        _this5.connectPromise = (0, _promiseUtils.resolvingPromise)();
-        _this5.open();
-      }).call(_context5, this), time);
+      this.reconnectHandle = (0, _setTimeout2.default)((0, _bind.default)(_context6 = function () {
+        _this6.attempts++;
+        _this6.connectPromise = (0, _promiseUtils.resolvingPromise)();
+        _this6.open();
+      }).call(_context6, this), time);
     }
@@ -643,0 +653,0 @@ }]);

lib/browser/LiveQuerySubscription.js

@@ -9,2 +9,3 @@ "use strict";
 exports.default = void 0;
+var _concat = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/concat"));
 var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/classCallCheck"));
@@ -103,2 +104,3 @@ var _createClass2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/createClass"));
   function Subscription(id, query, sessionToken) {
+    var _this = this;
     (0, _classCallCheck2.default)(this, Subscription);
@@ -113,4 +115,12 @@ this.id = id;
     this.emitter = new EventEmitter();
-    this.on = this.emitter.on;
-    this.emit = this.emitter.emit;
+    this.on = function (eventName, listener) {
+      return _this.emitter.on(eventName, listener);
+    };
+    this.emit = function (eventName) {
+      var _this$emitter, _context;
+      for (var _len = arguments.length, args = new Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
+        args[_key - 1] = arguments[_key];
+      }
+      return (_this$emitter = _this.emitter).emit.apply(_this$emitter, (0, _concat.default)(_context = [eventName]).call(_context, args));
+    };
     // adding listener so process does not crash
@@ -129,6 +139,6 @@ // best practice is for developer to register their own listener
     value: function () /*: Promise*/{
-      var _this = this;
+      var _this2 = this;
       return _CoreManager.default.getLiveQueryController().getDefaultLiveQueryClient().then(function (liveQueryClient) {
-        _this.emit('close');
-        return liveQueryClient.unsubscribe(_this);
+        _this2.emit('close');
+        return liveQueryClient.unsubscribe(_this2);
       });
@@ -135,0 +145,0 @@ }

lib/browser/ParseLiveQuery.js

@@ -9,5 +9,6 @@ "use strict";
 exports.default = void 0;
+var _regenerator = _interopRequireDefault(require("@babel/runtime-corejs3/regenerator"));
+var _concat = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/concat"));
 var _promise = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/promise"));
 var _indexOf = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/index-of"));
-var _regenerator = _interopRequireDefault(require("@babel/runtime-corejs3/regenerator"));
 var _slicedToArray2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/slicedToArray"));
@@ -56,8 +57,16 @@ var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/asyncToGenerator"));
   function LiveQuery() {
+    var _this = this;
     (0, _classCallCheck2.default)(this, LiveQuery);
     var EventEmitter = _CoreManager.default.getEventEmitter();
     this.emitter = new EventEmitter();
-    this.on = this.emitter.on;
-    this.emit = this.emitter.emit;
-
+    this.on = function (eventName, listener) {
+      return _this.emitter.on(eventName, listener);
+    };
+    this.emit = function (eventName) {
+      var _this$emitter, _context;
+      for (var _len = arguments.length, args = new Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
+        args[_key - 1] = arguments[_key];
+      }
+      return (_this$emitter = _this.emitter).emit.apply(_this$emitter, (0, _concat.default)(_context = [eventName]).call(_context, args));
+    };
     // adding listener so process does not crash
@@ -77,13 +86,13 @@ // best practice is for developer to register their own listener
         var liveQueryClient;
-        return _regenerator.default.wrap(function (_context) {
-          while (1) switch (_context.prev = _context.next) {
+        return _regenerator.default.wrap(function (_context2) {
+          while (1) switch (_context2.prev = _context2.next) {
             case 0:
-              _context.next = 2;
+              _context2.next = 2;
               return getLiveQueryClient();
             case 2:
-              liveQueryClient = _context.sent;
+              liveQueryClient = _context2.sent;
               liveQueryClient.open();
             case 4:
             case "end":
-              return _context.stop();
+              return _context2.stop();
           }
@@ -109,13 +118,13 @@ }, _callee);
         var liveQueryClient;
-        return _regenerator.default.wrap(function (_context2) {
-          while (1) switch (_context2.prev = _context2.next) {
+        return _regenerator.default.wrap(function (_context3) {
+          while (1) switch (_context3.prev = _context3.next) {
             case 0:
-              _context2.next = 2;
+              _context3.next = 2;
               return getLiveQueryClient();
             case 2:
-              liveQueryClient = _context2.sent;
+              liveQueryClient = _context3.sent;
               liveQueryClient.close();
             case 4:
             case "end":
-              return _context2.stop();
+              return _context3.stop();
           }
@@ -142,15 +151,15 @@ }, _callee2);
       var _yield$Promise$all, _yield$Promise$all2, currentUser, installationId, sessionToken, liveQueryServerURL, serverURL, protocol, host, applicationId, javascriptKey, masterKey, LiveQuery;
-      return _regenerator.default.wrap(function (_context3) {
-        while (1) switch (_context3.prev = _context3.next) {
+      return _regenerator.default.wrap(function (_context4) {
+        while (1) switch (_context4.prev = _context4.next) {
           case 0:
             if (!defaultLiveQueryClient) {
-              _context3.next = 2;
+              _context4.next = 2;
               break;
             }
-            return _context3.abrupt("return", defaultLiveQueryClient);
+            return _context4.abrupt("return", defaultLiveQueryClient);
           case 2:
-            _context3.next = 4;
+            _context4.next = 4;
             return _promise.default.all([_CoreManager.default.getUserController().currentUserAsync(), _CoreManager.default.getInstallationController().currentInstallationId()]);
           case 4:
-            _yield$Promise$all = _context3.sent;
+            _yield$Promise$all = _context4.sent;
             _yield$Promise$all2 = (0, _slicedToArray2.default)(_yield$Promise$all, 2);
@@ -162,3 +171,3 @@ currentUser = _yield$Promise$all2[0];
             if (!(liveQueryServerURL && (0, _indexOf.default)(liveQueryServerURL).call(liveQueryServerURL, 'ws') !== 0)) {
-              _context3.next = 12;
+              _context4.next = 12;
               break;
@@ -197,6 +206,6 @@ }
             });
-            return _context3.abrupt("return", defaultLiveQueryClient);
+            return _context4.abrupt("return", defaultLiveQueryClient);
           case 22:
           case "end":
-            return _context3.stop();
+            return _context4.stop();
         }
@@ -203,0 +212,0 @@ }, _callee3);

lib/node/CoreManager.js

@@ -186,3 +186,3 @@ "use strict";
   ENCRYPTED_KEY: null,
-  VERSION: 'js' + "5.1.0-alpha.3",
+  VERSION: 'js' + "5.1.0-alpha.4",
   APPLICATION_ID: null,
@@ -189,0 +189,0 @@ JAVASCRIPT_KEY: null,

lib/node/LiveQueryClient.js

@@ -164,4 +164,4 @@ "use strict";
     this.emitter = new EventEmitter();
-    this.on = this.emitter.on;
-    this.emit = this.emitter.emit;
+    this.on = (eventName, listener) => this.emitter.on(eventName, listener);
+    this.emit = (eventName, ...args) => this.emitter.emit(eventName, ...args);
     // adding listener so process does not crash
@@ -168,0 +168,0 @@ // best practice is for developer to register their own listener

lib/node/LiveQuerySubscription.js

@@ -111,4 +111,4 @@ "use strict";
     this.emitter = new EventEmitter();
-    this.on = this.emitter.on;
-    this.emit = this.emitter.emit;
+    this.on = (eventName, listener) => this.emitter.on(eventName, listener);
+    this.emit = (eventName, ...args) => this.emitter.emit(eventName, ...args);
     // adding listener so process does not crash
@@ -115,0 +115,0 @@ // best practice is for developer to register their own listener

lib/node/ParseLiveQuery.js

@@ -53,5 +53,4 @@ "use strict";
     this.emitter = new EventEmitter();
-    this.on = this.emitter.on;
-    this.emit = this.emitter.emit;
-
+    this.on = (eventName, listener) => this.emitter.on(eventName, listener);
+    this.emit = (eventName, ...args) => this.emitter.emit(eventName, ...args);
     // adding listener so process does not crash
@@ -58,0 +57,0 @@ // best practice is for developer to register their own listener

lib/react-native/CoreManager.js

@@ -15,3 +15,3 @@ Object.defineProperty(exports, "__esModule", {
   ENCRYPTED_KEY: null,
-  VERSION: 'js' + "5.1.0-alpha.3",
+  VERSION: 'js' + "5.1.0-alpha.4",
   APPLICATION_ID: null,
@@ -18,0 +18,0 @@ JAVASCRIPT_KEY: null,

lib/react-native/LiveQueryClient.js

@@ -58,2 +58,3 @@ var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
   function LiveQueryClient(_ref) {
+    var _this = this;
     var applicationId = _ref.applicationId,
@@ -85,4 +86,12 @@ serverURL = _ref.serverURL,
     this.emitter = new EventEmitter();
-    this.on = this.emitter.on;
-    this.emit = this.emitter.emit;
+    this.on = function (eventName, listener) {
+      return _this.emitter.on(eventName, listener);
+    };
+    this.emit = function (eventName) {
+      var _this$emitter;
+      for (var _len = arguments.length, args = new Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
+        args[_key - 1] = arguments[_key];
+      }
+      return (_this$emitter = _this.emitter).emit.apply(_this$emitter, [eventName].concat(args));
+    };
     this.on('error', function () {});
@@ -100,3 +109,3 @@ }
         _queryJSON$watch,
-        _this = this;
+        _this2 = this;
       if (!query) {
@@ -127,3 +136,3 @@ return;
       this.connectPromise.then(function () {
-        _this.socket.send(JSON.stringify(subscribeRequest));
+        _this2.socket.send(JSON.stringify(subscribeRequest));
       }).catch(function (error) {
@@ -137,3 +146,3 @@ subscription.subscribePromise.reject(error);
     value: function (subscription) {
-      var _this2 = this;
+      var _this3 = this;
       if (!subscription) {
@@ -147,3 +156,3 @@ return;
       return this.connectPromise.then(function () {
-        return _this2.socket.send(JSON.stringify(unsubscribeRequest));
+        return _this3.socket.send(JSON.stringify(unsubscribeRequest));
       }).then(function () {
@@ -156,3 +165,3 @@ return subscription.unsubscribePromise;
     value: function () {
-      var _this3 = this;
+      var _this4 = this;
       var WebSocketImplementation = _CoreManager.default.getWebSocketController();
@@ -169,13 +178,13 @@ if (!WebSocketImplementation) {
       this.socket.onopen = function () {
-        _this3._handleWebSocketOpen();
+        _this4._handleWebSocketOpen();
       };
       this.socket.onmessage = function (event) {
-        _this3._handleWebSocketMessage(event);
+        _this4._handleWebSocketMessage(event);
       };
       this.socket.onclose = function (event) {
-        _this3.socket.closingPromise.resolve(event);
-        _this3._handleWebSocketClose();
+        _this4.socket.closingPromise.resolve(event);
+        _this4._handleWebSocketClose();
       };
       this.socket.onerror = function (error) {
-        _this3._handleWebSocketError(error);
+        _this4._handleWebSocketError(error);
       };
@@ -186,3 +195,3 @@ }
     value: function () {
-      var _this4 = this;
+      var _this5 = this;
       this.subscriptions.forEach(function (subscription, requestId) {
@@ -207,4 +216,4 @@ var query = subscription.query;
         }
-        _this4.connectPromise.then(function () {
-          _this4.socket.send(JSON.stringify(subscribeRequest));
+        _this5.connectPromise.then(function () {
+          _this5.socket.send(JSON.stringify(subscribeRequest));
         });
@@ -378,3 +387,3 @@ });
     value: function () {
-      var _this5 = this;
+      var _this6 = this;
       if (this.state === CLIENT_STATE.DISCONNECTED) {
@@ -389,5 +398,5 @@ return;
       this.reconnectHandle = setTimeout(function () {
-        _this5.attempts++;
-        _this5.connectPromise = (0, _promiseUtils.resolvingPromise)();
-        _this5.open();
+        _this6.attempts++;
+        _this6.connectPromise = (0, _promiseUtils.resolvingPromise)();
+        _this6.open();
       }.bind(this), time);
@@ -394,0 +403,0 @@ }

lib/react-native/LiveQuerySubscription.js

@@ -12,2 +12,3 @@ var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
   function Subscription(id, query, sessionToken) {
+    var _this = this;
     (0, _classCallCheck2.default)(this, Subscription);
@@ -22,4 +23,12 @@ this.id = id;
     this.emitter = new EventEmitter();
-    this.on = this.emitter.on;
-    this.emit = this.emitter.emit;
+    this.on = function (eventName, listener) {
+      return _this.emitter.on(eventName, listener);
+    };
+    this.emit = function (eventName) {
+      var _this$emitter;
+      for (var _len = arguments.length, args = new Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
+        args[_key - 1] = arguments[_key];
+      }
+      return (_this$emitter = _this.emitter).emit.apply(_this$emitter, [eventName].concat(args));
+    };
     this.on('error', function () {});
@@ -30,6 +39,6 @@ }
     value: function () {
-      var _this = this;
+      var _this2 = this;
       return _CoreManager.default.getLiveQueryController().getDefaultLiveQueryClient().then(function (liveQueryClient) {
-        _this.emit('close');
-        return liveQueryClient.unsubscribe(_this);
+        _this2.emit('close');
+        return liveQueryClient.unsubscribe(_this2);
       });
@@ -36,0 +45,0 @@ }

lib/react-native/ParseLiveQuery.js

@@ -17,7 +17,16 @@ var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
   function LiveQuery() {
+    var _this = this;
     (0, _classCallCheck2.default)(this, LiveQuery);
     var EventEmitter = _CoreManager.default.getEventEmitter();
     this.emitter = new EventEmitter();
-    this.on = this.emitter.on;
-    this.emit = this.emitter.emit;
+    this.on = function (eventName, listener) {
+      return _this.emitter.on(eventName, listener);
+    };
+    this.emit = function (eventName) {
+      var _this$emitter;
+      for (var _len = arguments.length, args = new Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
+        args[_key - 1] = arguments[_key];
+      }
+      return (_this$emitter = _this.emitter).emit.apply(_this$emitter, [eventName].concat(args));
+    };
     this.on('error', function () {});
@@ -24,0 +33,0 @@ }

lib/weapp/CoreManager.js

@@ -190,3 +190,3 @@ "use strict";
   ENCRYPTED_KEY: null,
-  VERSION: 'js' + "5.1.0-alpha.3",
+  VERSION: 'js' + "5.1.0-alpha.4",
   APPLICATION_ID: null,
@@ -193,0 +193,0 @@ JAVASCRIPT_KEY: null,

lib/weapp/LiveQueryClient.js

@@ -16,2 +16,3 @@ "use strict";
 var _map = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/map"));
+var _concat = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/concat"));
 var _keys = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/keys"));
@@ -83,6 +84,6 @@ var _stringify = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/json/stringify"));
 function _unsupportedIterableToArray(o, minLen) {
-  var _context6;
+  var _context7;
   if (!o) return;
   if (typeof o === "string") return _arrayLikeToArray(o, minLen);
-  var n = _sliceInstanceProperty(_context6 = Object.prototype.toString.call(o)).call(_context6, 8, -1);
+  var n = _sliceInstanceProperty(_context7 = Object.prototype.toString.call(o)).call(_context7, 8, -1);
   if (n === "Object" && o.constructor) n = o.constructor.name;
@@ -204,2 +205,3 @@ if (n === "Map" || n === "Set") return _Array$from(o);
   function LiveQueryClient(_ref) {
+    var _this = this;
     var applicationId = _ref.applicationId,
@@ -245,4 +247,12 @@ serverURL = _ref.serverURL,
     this.emitter = new EventEmitter();
-    this.on = this.emitter.on;
-    this.emit = this.emitter.emit;
+    this.on = function (eventName, listener) {
+      return _this.emitter.on(eventName, listener);
+    };
+    this.emit = function (eventName) {
+      var _this$emitter, _context;
+      for (var _len = arguments.length, args = new Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
+        args[_key - 1] = arguments[_key];
+      }
+      return (_this$emitter = _this.emitter).emit.apply(_this$emitter, (0, _concat.default)(_context = [eventName]).call(_context, args));
+    };
     // adding listener so process does not crash
@@ -277,3 +287,3 @@ // best practice is for developer to register their own listener
         _queryJSON$watch,
-        _this = this;
+        _this2 = this;
       if (!query) {
@@ -304,3 +314,3 @@ return;
       this.connectPromise.then(function () {
-        _this.socket.send((0, _stringify.default)(subscribeRequest));
+        _this2.socket.send((0, _stringify.default)(subscribeRequest));
       }).catch(function (error) {
@@ -321,3 +331,3 @@ subscription.subscribePromise.reject(error);
     value: function (subscription /*: Object*/) /*: ?Promise*/{
-      var _this2 = this;
+      var _this3 = this;
       if (!subscription) {
@@ -331,3 +341,3 @@ return;
       return this.connectPromise.then(function () {
-        return _this2.socket.send((0, _stringify.default)(unsubscribeRequest));
+        return _this3.socket.send((0, _stringify.default)(unsubscribeRequest));
       }).then(function () {
@@ -346,3 +356,3 @@ return subscription.unsubscribePromise;
     value: function () {
-      var _this3 = this;
+      var _this4 = this;
       var WebSocketImplementation = _CoreManager.default.getWebSocketController();
@@ -361,13 +371,13 @@ if (!WebSocketImplementation) {
       this.socket.onopen = function () {
-        _this3._handleWebSocketOpen();
+        _this4._handleWebSocketOpen();
       };
       this.socket.onmessage = function (event) {
-        _this3._handleWebSocketMessage(event);
+        _this4._handleWebSocketMessage(event);
       };
       this.socket.onclose = function (event) {
-        _this3.socket.closingPromise.resolve(event);
-        _this3._handleWebSocketClose();
+        _this4.socket.closingPromise.resolve(event);
+        _this4._handleWebSocketClose();
       };
       this.socket.onerror = function (error) {
-        _this3._handleWebSocketError(error);
+        _this4._handleWebSocketError(error);
       };
@@ -378,5 +388,5 @@ }
     value: function () {
-      var _context,
-        _this4 = this;
-      (0, _forEach.default)(_context = this.subscriptions).call(_context, function (subscription, requestId) {
+      var _context2,
+        _this5 = this;
+      (0, _forEach.default)(_context2 = this.subscriptions).call(_context2, function (subscription, requestId) {
         var query = subscription.query;
@@ -400,4 +410,4 @@ var queryJSON = query.toJSON();
         }
-        _this4.connectPromise.then(function () {
-          _this4.socket.send((0, _stringify.default)(subscribeRequest));
+        _this5.connectPromise.then(function () {
+          _this5.socket.send((0, _stringify.default)(subscribeRequest));
         });
@@ -416,3 +426,3 @@ });
     value: function () /*: ?Promise*/{
-      var _this$socket, _this$socket2, _context2;
+      var _this$socket, _this$socket2, _context3;
       if (this.state === CLIENT_STATE.INITIALIZED || this.state === CLIENT_STATE.DISCONNECTED) {
@@ -424,3 +434,3 @@ return;
       // Notify each subscription about the close
-      var _iterator = _createForOfIteratorHelper((0, _values.default)(_context2 = this.subscriptions).call(_context2)),
+      var _iterator = _createForOfIteratorHelper((0, _values.default)(_context3 = this.subscriptions).call(_context3)),
         _step;
@@ -572,3 +582,3 @@ try {
     value: function () {
-      var _context3;
+      var _context4;
       if (this.state === CLIENT_STATE.DISCONNECTED) {
@@ -580,3 +590,3 @@ return;
       // Notify each subscription about the close
-      var _iterator2 = _createForOfIteratorHelper((0, _values.default)(_context3 = this.subscriptions).call(_context3)),
+      var _iterator2 = _createForOfIteratorHelper((0, _values.default)(_context4 = this.subscriptions).call(_context4)),
         _step2;
@@ -598,5 +608,5 @@ try {
     value: function (error /*: any*/) {
-      var _context4;
+      var _context5;
       this.emit(CLIENT_EMMITER_TYPES.ERROR, error);
-      var _iterator3 = _createForOfIteratorHelper((0, _values.default)(_context4 = this.subscriptions).call(_context4)),
+      var _iterator3 = _createForOfIteratorHelper((0, _values.default)(_context5 = this.subscriptions).call(_context5)),
         _step3;
@@ -618,4 +628,4 @@ try {
     value: function () {
-      var _context5,
-        _this5 = this;
+      var _context6,
+        _this6 = this;
       // if closed or currently reconnecting we stop attempting to reconnect
@@ -636,7 +646,7 @@ if (this.state === CLIENT_STATE.DISCONNECTED) {
       }
-      this.reconnectHandle = (0, _setTimeout2.default)((0, _bind.default)(_context5 = function () {
-        _this5.attempts++;
-        _this5.connectPromise = (0, _promiseUtils.resolvingPromise)();
-        _this5.open();
-      }).call(_context5, this), time);
+      this.reconnectHandle = (0, _setTimeout2.default)((0, _bind.default)(_context6 = function () {
+        _this6.attempts++;
+        _this6.connectPromise = (0, _promiseUtils.resolvingPromise)();
+        _this6.open();
+      }).call(_context6, this), time);
     }
@@ -643,0 +653,0 @@ }]);

lib/weapp/LiveQuerySubscription.js

@@ -9,2 +9,3 @@ "use strict";
 exports.default = void 0;
+var _concat = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/concat"));
 var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/classCallCheck"));
@@ -103,2 +104,3 @@ var _createClass2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/createClass"));
   function Subscription(id, query, sessionToken) {
+    var _this = this;
     (0, _classCallCheck2.default)(this, Subscription);
@@ -113,4 +115,12 @@ this.id = id;
     this.emitter = new EventEmitter();
-    this.on = this.emitter.on;
-    this.emit = this.emitter.emit;
+    this.on = function (eventName, listener) {
+      return _this.emitter.on(eventName, listener);
+    };
+    this.emit = function (eventName) {
+      var _this$emitter, _context;
+      for (var _len = arguments.length, args = new Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
+        args[_key - 1] = arguments[_key];
+      }
+      return (_this$emitter = _this.emitter).emit.apply(_this$emitter, (0, _concat.default)(_context = [eventName]).call(_context, args));
+    };
     // adding listener so process does not crash
@@ -129,6 +139,6 @@ // best practice is for developer to register their own listener
     value: function () /*: Promise*/{
-      var _this = this;
+      var _this2 = this;
       return _CoreManager.default.getLiveQueryController().getDefaultLiveQueryClient().then(function (liveQueryClient) {
-        _this.emit('close');
-        return liveQueryClient.unsubscribe(_this);
+        _this2.emit('close');
+        return liveQueryClient.unsubscribe(_this2);
       });
@@ -135,0 +145,0 @@ }

lib/weapp/ParseLiveQuery.js

@@ -9,5 +9,6 @@ "use strict";
 exports.default = void 0;
+var _regenerator = _interopRequireDefault(require("@babel/runtime-corejs3/regenerator"));
+var _concat = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/concat"));
 var _promise = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/promise"));
 var _indexOf = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/index-of"));
-var _regenerator = _interopRequireDefault(require("@babel/runtime-corejs3/regenerator"));
 var _slicedToArray2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/slicedToArray"));
@@ -56,8 +57,16 @@ var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/asyncToGenerator"));
   function LiveQuery() {
+    var _this = this;
     (0, _classCallCheck2.default)(this, LiveQuery);
     var EventEmitter = _CoreManager.default.getEventEmitter();
     this.emitter = new EventEmitter();
-    this.on = this.emitter.on;
-    this.emit = this.emitter.emit;
-
+    this.on = function (eventName, listener) {
+      return _this.emitter.on(eventName, listener);
+    };
+    this.emit = function (eventName) {
+      var _this$emitter, _context;
+      for (var _len = arguments.length, args = new Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) {
+        args[_key - 1] = arguments[_key];
+      }
+      return (_this$emitter = _this.emitter).emit.apply(_this$emitter, (0, _concat.default)(_context = [eventName]).call(_context, args));
+    };
     // adding listener so process does not crash
@@ -77,13 +86,13 @@ // best practice is for developer to register their own listener
         var liveQueryClient;
-        return _regenerator.default.wrap(function (_context) {
-          while (1) switch (_context.prev = _context.next) {
+        return _regenerator.default.wrap(function (_context2) {
+          while (1) switch (_context2.prev = _context2.next) {
             case 0:
-              _context.next = 2;
+              _context2.next = 2;
               return getLiveQueryClient();
             case 2:
-              liveQueryClient = _context.sent;
+              liveQueryClient = _context2.sent;
               liveQueryClient.open();
             case 4:
             case "end":
-              return _context.stop();
+              return _context2.stop();
           }
@@ -109,13 +118,13 @@ }, _callee);
         var liveQueryClient;
-        return _regenerator.default.wrap(function (_context2) {
-          while (1) switch (_context2.prev = _context2.next) {
+        return _regenerator.default.wrap(function (_context3) {
+          while (1) switch (_context3.prev = _context3.next) {
             case 0:
-              _context2.next = 2;
+              _context3.next = 2;
               return getLiveQueryClient();
             case 2:
-              liveQueryClient = _context2.sent;
+              liveQueryClient = _context3.sent;
               liveQueryClient.close();
             case 4:
             case "end":
-              return _context2.stop();
+              return _context3.stop();
           }
@@ -142,15 +151,15 @@ }, _callee2);
       var _yield$Promise$all, _yield$Promise$all2, currentUser, installationId, sessionToken, liveQueryServerURL, serverURL, protocol, host, applicationId, javascriptKey, masterKey, LiveQuery;
-      return _regenerator.default.wrap(function (_context3) {
-        while (1) switch (_context3.prev = _context3.next) {
+      return _regenerator.default.wrap(function (_context4) {
+        while (1) switch (_context4.prev = _context4.next) {
           case 0:
             if (!defaultLiveQueryClient) {
-              _context3.next = 2;
+              _context4.next = 2;
               break;
             }
-            return _context3.abrupt("return", defaultLiveQueryClient);
+            return _context4.abrupt("return", defaultLiveQueryClient);
           case 2:
-            _context3.next = 4;
+            _context4.next = 4;
             return _promise.default.all([_CoreManager.default.getUserController().currentUserAsync(), _CoreManager.default.getInstallationController().currentInstallationId()]);
           case 4:
-            _yield$Promise$all = _context3.sent;
+            _yield$Promise$all = _context4.sent;
             _yield$Promise$all2 = (0, _slicedToArray2.default)(_yield$Promise$all, 2);
@@ -162,3 +171,3 @@ currentUser = _yield$Promise$all2[0];
             if (!(liveQueryServerURL && (0, _indexOf.default)(liveQueryServerURL).call(liveQueryServerURL, 'ws') !== 0)) {
-              _context3.next = 12;
+              _context4.next = 12;
               break;
@@ -197,6 +206,6 @@ }
             });
-            return _context3.abrupt("return", defaultLiveQueryClient);
+            return _context4.abrupt("return", defaultLiveQueryClient);
           case 22:
           case "end":
-            return _context3.stop();
+            return _context4.stop();
         }
@@ -203,0 +212,0 @@ }, _callee3);

package.json

 {
   "name": "parse",
-  "version": "5.1.0-alpha.3",
+  "version": "5.1.0-alpha.4",
   "description": "Parse JavaScript SDK",
@@ -5,0 +5,0 @@ "homepage": "https://parseplatform.org",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Unidentified License

License

(Experimental) Something that seems like a license was found, but its contents could not be matched with a known license.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Unidentified License

License

(Experimental) Something that seems like a license was found, but its contents could not be matched with a known license.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

5712914

increased by0.18%

Lines of code

121848

increased by0.12%

No dependency changes