sockstream - npm Package Compare versions

Comparing version 1.3.2 to 1.3.3

dist/sockstream.js

@@ -11,2 +11,4 @@ 'use strict';
 
+function _toConsumableArray(arr) { if (Array.isArray(arr)) { for (var i = 0, arr2 = Array(arr.length); i < arr.length; i++) { arr2[i] = arr[i]; } return arr2; } else { return Array.from(arr); } }
+
 function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }
@@ -34,2 +36,9 @@
 
+    var clientName = 'sockstream.js';
+    var clientVersion = '1.3.3';
+    var defaultKeepAlive = 800;
+    var defaultDebugLevel = 0;
+    var defaultPort = 8082;
+    var defaultProto = 'wss://';
+    var defaultHost = '127.0.0.1';
     this.callbackRegister = {
@@ -44,2 +53,4 @@ ping: function ping(message) {
     };
+    this.maxKeepAliveAttempt = 20;
+    this.keepAliveAttempt = 0;
     this.disconnect = [];
@@ -49,13 +60,11 @@ this.connections = {};
       client: {
-        name: 'sockstream.js',
-        version: 1.2,
-        debugLevel: 0,
-        keepAlive: 800
+        name: clientName,
+        version: clientVersion,
+        debugLevel: defaultDebugLevel,
+        keepAlive: defaultKeepAlive
       },
       server: {
-        name: 'sockets/php-stream-socket-server',
-        version: 1.3,
-        hostname: 'localhost',
-        port: 8082,
-        proto: 'wss://'
+        hostname: defaultHost,
+        port: defaultPort,
+        proto: defaultProto
       }
@@ -66,7 +75,7 @@ };
         this._config.client = Object.assign({
-          debugLevel: 0,
-          keepAlive: 800
+          debugLevel: defaultDebugLevel,
+          keepAlive: defaultKeepAlive
         }, host.client, {
-          name: 'sockstream.js',
-          version: 0.1
+          name: clientName,
+          version: clientVersion
         });
@@ -76,9 +85,6 @@ }
         this._config.server = Object.assign({
-          hostname: 'localhost',
-          port: 8082,
-          proto: 'wss://'
-        }, host.server, {
-          name: 'sockets/php-stream-socket-server',
-          version: 1.3
-        });
+          hostname: defaultHost,
+          port: defaultPort,
+          proto: defaultProto
+        }, host.server);
       }
@@ -88,4 +94,4 @@ } else {
         client: {
-          name: 'sockstream.js',
-          version: 0.1,
+          name: clientName,
+          version: clientVersion,
           debugLevel: debugLevel,
@@ -95,4 +101,2 @@ keepAlive: keepAlive
         server: {
-          name: 'sockets/php-stream-socket-server',
-          version: 1.3,
           hostname: host,
@@ -119,2 +123,4 @@ port: port,
     }(function (message) {
+      var _console2;
+
       var type = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : 'log';
@@ -129,3 +135,3 @@
       };
-      this._config.client.debugLevel >= (levelMap[type] || 0) && console[type](message);
+      this._config.client.debugLevel >= (levelMap[type] || 0) && (_console2 = console)[type].apply(_console2, _toConsumableArray(message));
     })
@@ -209,6 +215,11 @@
       this.lastConnectionId = connectionId;
-      this.connections[connectionId] = new WebSocket('' + this._config.server.proto + this._config.server.hostname + ':' + this._config.server.port);
+      try {
+        this.connections[connectionId] = new WebSocket('' + this._config.server.proto + this._config.server.hostname + ':' + this._config.server.port);
+      } catch (e) {
+        return;
+      }
       if (this.connections[connectionId].readyState === this.connections[connectionId].CONNECTING) {
         this.connections[connectionId].onopen = function () {
           _this2.console('connected', 'info');
+          _this2.keepAliveAttempt = 0;
           setTimeout(function () {
@@ -219,3 +230,3 @@ _this2.send('connecting', cb);
         this.connections[connectionId].onerror = function (e) {
-          _this2.console(['WebSocket error', e], 'error');
+          _this2.console(e, 'error');
         };
@@ -228,7 +239,9 @@ this.connections[connectionId].onmessage = function (e) {
             } else if (typeof _this2.callbackRegister[parsed['@meta']._id] === 'function') {
-              _this2.callbackRegister[parsed['@meta']._id].call(_this2._config, parsed.message || null);
+              _this2.callbackRegister[parsed['@meta']._id].call(_this2._config, parsed.message);
               delete _this2.callbackRegister[parsed['@meta']._id];
             }
+            _this2.console(['[RCVD]', parsed.message], 'debug');
+          } else {
+            _this2.console(['[RCVD]', e.data], 'debug');
           }
-          _this2.console(['[RCVD]', parsed], 'debug');
         };
@@ -238,6 +251,15 @@ this.connections[connectionId].onclose = function (e) {
           if (_this2.disconnect.indexOf(connectionId) === -1 && typeof _this2._config.client.keepAlive === 'number' && _this2._config.client.keepAlive > 0) {
+            if (++_this2.keepAliveAttempt > _this2.maxKeepAliveAttempt) {
+              return;
+            }
+            var timeout = _this2._config.client.keepAlive;
+            if (_this2.keepAliveAttempt > 5) {
+              timeout = timeout + timeout / 2;
+            } else if (_this2.keepAliveAttempt > 10) {
+              timeout = timeout * 2;
+            }
             setTimeout(function () {
               _this2.console('Attempting to reestablish WebSocket', 'info');
               _this2.open();
-            }, _this2._config.client.keepAlive);
+            }, timeout);
           }
@@ -250,2 +272,13 @@ delete _this2.connections[connectionId];
     }
+
+    /**
+     * @param number int
+     */
+
+  }, {
+    key: 'setMaxKeepAliveAttempt',
+    value: function setMaxKeepAliveAttempt(number) {
+      this.maxKeepAliveAttempt = typeof number === 'number' ? number : this.maxKeepAliveAttempt;
+      return this;
+    }
   }], [{
@@ -280,3 +313,2 @@ key: 'generateUUID',
 
-exports.default = StreamSock;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbInNvY2tzdHJlYW0uanMiXSwibmFtZXMiOlsiU3RyZWFtU29jayIsImhvc3QiLCJwb3J0Iiwic2VjdXJlIiwia2VlcEFsaXZlIiwiZGVidWdMZXZlbCIsImNhbGxiYWNrUmVnaXN0ZXIiLCJwaW5nIiwic2VuZCIsImNvbnNvbGUiLCJtZXNzYWdlIiwic3lzdGVtIiwiZGlzY29ubmVjdCIsImNvbm5lY3Rpb25zIiwiX2NvbmZpZyIsImNsaWVudCIsIm5hbWUiLCJ2ZXJzaW9uIiwic2VydmVyIiwiaG9zdG5hbWUiLCJwcm90byIsIk9iamVjdCIsImFzc2lnbiIsInR5cGUiLCJsZXZlbE1hcCIsInNldHRpbmciLCJkZWJ1ZyIsImNvbm5lY3Rpb25JZCIsImlkIiwibGFzdENvbm5lY3Rpb25JZCIsInB1c2giLCJjbG9zZSIsImNiIiwicmVhZHlTdGF0ZSIsIk9QRU4iLCJfaWQiLCJnZW5lcmF0ZVVVSUQiLCJKU09OIiwic3RyaW5naWZ5IiwiV2ViU29ja2V0IiwiQ09OTkVDVElORyIsIm9ub3BlbiIsInNldFRpbWVvdXQiLCJvbmVycm9yIiwiZSIsIm9ubWVzc2FnZSIsInBhcnNlZCIsInBhcnNlTWVzc2FnZSIsImRhdGEiLCJfdHlwZSIsImNhbGwiLCJfc3lzdGVtIiwib25jbG9zZSIsImluZGV4T2YiLCJvcGVuIiwiZCIsIkRhdGUiLCJnZXRUaW1lIiwid2luZG93IiwicGVyZm9ybWFuY2UiLCJub3ciLCJyZXBsYWNlIiwiYyIsInIiLCJNYXRoIiwicmFuZG9tIiwiZmxvb3IiLCJ0b1N0cmluZyIsInBhcnNlIl0sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7Ozs7SUFBcUJBLFU7QUFDbkI7Ozs7Ozs7QUFPQSx3QkFBNkY7QUFBQSxRQUFqRkMsSUFBaUYsdUVBQTFFLFdBQTBFO0FBQUEsUUFBN0RDLElBQTZELHVFQUF0RCxJQUFzRDtBQUFBLFFBQWhEQyxNQUFnRCx1RUFBdkMsSUFBdUM7O0FBQUE7O0FBQUEsUUFBakNDLFNBQWlDLHVFQUFyQixHQUFxQjtBQUFBLFFBQWhCQyxVQUFnQix1RUFBSCxDQUFHOztBQUFBOztBQUMzRixTQUFLQyxnQkFBTCxHQUF3QjtBQUN0QkMsWUFBTSx1QkFBVztBQUNmLGNBQUtDLElBQUwsQ0FBVSxNQUFWO0FBQ0EsY0FBS0MsT0FBTCxDQUFhLENBQUMsUUFBRCxFQUFXQyxPQUFYLENBQWI7QUFDRCxPQUpxQjtBQUt0QkMsY0FBUSx5QkFBVztBQUNqQixjQUFLRixPQUFMLENBQWEsQ0FBQyxVQUFELEVBQWFDLE9BQWIsQ0FBYjtBQUNEO0FBUHFCLEtBQXhCO0FBU0EsU0FBS0UsVUFBTCxHQUFrQixFQUFsQjtBQUNBLFNBQUtDLFdBQUwsR0FBbUIsRUFBbkI7QUFDQSxTQUFLQyxPQUFMLEdBQWU7QUFDYkMsY0FBUTtBQUNOQyxjQUFNLGVBREE7QUFFTkMsaUJBQVMsR0FGSDtBQUdOWixvQkFBWSxDQUhOO0FBSU5ELG1CQUFXO0FBSkwsT0FESztBQU9iYyxjQUFRO0FBQ05GLGNBQU0sa0NBREE7QUFFTkMsaUJBQVMsR0FGSDtBQUdORSxrQkFBVSxXQUhKO0FBSU5qQixjQUFNLElBSkE7QUFLTmtCLGVBQU87QUFMRDtBQVBLLEtBQWY7QUFlQSxRQUFJLFFBQU9uQixJQUFQLHlDQUFPQSxJQUFQLE9BQWdCLFFBQXBCLEVBQThCO0FBQzVCLFVBQUksUUFBT0EsS0FBS2MsTUFBWixNQUF1QixRQUEzQixFQUFxQztBQUNuQyxhQUFLRCxPQUFMLENBQWFDLE1BQWIsR0FBc0JNLE9BQU9DLE1BQVAsQ0FBYztBQUNsQ2pCLHNCQUFZLENBRHNCO0FBRWxDRCxxQkFBVztBQUZ1QixTQUFkLEVBR25CSCxLQUFLYyxNQUhjLEVBR047QUFDZEMsZ0JBQU0sZUFEUTtBQUVkQyxtQkFBUztBQUZLLFNBSE0sQ0FBdEI7QUFPRDtBQUNELFVBQUksUUFBT2hCLEtBQUtpQixNQUFaLE1BQXVCLFFBQTNCLEVBQXFDO0FBQ25DLGFBQUtKLE9BQUwsQ0FBYUksTUFBYixHQUFzQkcsT0FBT0MsTUFBUCxDQUFjO0FBQ2xDSCxvQkFBVSxXQUR3QjtBQUVsQ2pCLGdCQUFNLElBRjRCO0FBR2xDa0IsaUJBQU87QUFIMkIsU0FBZCxFQUluQm5CLEtBQUtpQixNQUpjLEVBSU47QUFDZEYsZ0JBQU0sa0NBRFE7QUFFZEMsbUJBQVM7QUFGSyxTQUpNLENBQXRCO0FBUUQ7QUFDRixLQXBCRCxNQW9CTztBQUNMLFdBQUtILE9BQUwsR0FBZTtBQUNiQyxnQkFBUTtBQUNOQyxnQkFBTSxlQURBO0FBRU5DLG1CQUFTLEdBRkg7QUFHTlosc0JBQVlBLFVBSE47QUFJTkQscUJBQVdBO0FBSkwsU0FESztBQU9iYyxnQkFBUTtBQUNORixnQkFBTSxrQ0FEQTtBQUVOQyxtQkFBUyxHQUZIO0FBR05FLG9CQUFVbEIsSUFISjtBQUlOQyxnQkFBTUEsSUFKQTtBQUtOa0IsaUJBQU8sQ0FBQyxDQUFDakIsTUFBRixHQUFXLFFBQVgsR0FBc0I7QUFMdkI7QUFQSyxPQUFmO0FBZUQ7QUFDRjs7Ozs7Ozs7Ozs7Ozs7Z0JBRU9PLE8sRUFBdUI7QUFBQSxVQUFkYSxJQUFjLHVFQUFQLEtBQU87O0FBQzdCLFVBQUlDLFdBQVc7QUFDYixlQUFPLENBRE07QUFFYixpQkFBUyxDQUZJO0FBR2IsZ0JBQVEsQ0FISztBQUliLGdCQUFRLENBSks7QUFLYixpQkFBUztBQUxJLE9BQWY7QUFPQSxXQUFLVixPQUFMLENBQWFDLE1BQWIsQ0FBb0JWLFVBQXBCLEtBQW1DbUIsU0FBU0QsSUFBVCxLQUFnQixDQUFuRCxLQUF5RGQsUUFBUWMsSUFBUixFQUFjYixPQUFkLENBQXpEO0FBQ0QsSzs7QUFFRDs7Ozs7Ozs7MEJBS01lLE8sRUFBUztBQUNiLFVBQUksT0FBT0EsT0FBUCxLQUFtQixXQUF2QixFQUFvQztBQUNsQyxhQUFLWCxPQUFMLENBQWFDLE1BQWIsQ0FBb0JXLEtBQXBCLEdBQTRCLENBQUMsQ0FBQ0QsT0FBOUI7QUFDRDtBQUNELGFBQU8sS0FBS1gsT0FBTCxDQUFhQyxNQUFiLENBQW9CVyxLQUEzQjtBQUNEOzs7NEJBd0IwQjtBQUFBLFVBQXJCQyxZQUFxQix1RUFBTixJQUFNOztBQUN6QixVQUFJQyxLQUFLRCxnQkFBZ0IsS0FBS0UsZ0JBQTlCO0FBQ0EsVUFBSSxPQUFPLEtBQUtoQixXQUFMLENBQWlCZSxFQUFqQixDQUFQLEtBQWdDLFdBQXBDLEVBQWlEO0FBQy9DLGFBQUtoQixVQUFMLENBQWdCa0IsSUFBaEIsQ0FBcUJGLEVBQXJCO0FBQ0EsYUFBS2YsV0FBTCxDQUFpQmUsRUFBakIsRUFBcUJHLEtBQXJCO0FBQ0Q7QUFDRCxhQUFPLElBQVA7QUFDRDs7QUFFRDs7Ozs7Ozs7eUJBS0tyQixPLEVBQVNzQixFLEVBQUk7QUFDaEIsVUFBSUwsZUFBZSxLQUFLRSxnQkFBeEI7QUFDQSxVQUFJLE9BQU9HLEVBQVAsS0FBYyxVQUFkLElBQTRCLE9BQU8sS0FBS25CLFdBQUwsQ0FBaUJtQixFQUFqQixDQUFQLEtBQWdDLFdBQWhFLEVBQThFO0FBQzVFLGFBQUtILGdCQUFMLEdBQXdCRixlQUFlSyxFQUF2QztBQUNEO0FBQ0QsVUFBSSxPQUFPLEtBQUtuQixXQUFMLENBQWlCYyxZQUFqQixDQUFQLEtBQTBDLFdBQTlDLEVBQTREO0FBQzFELGVBQU8sS0FBUDtBQUNEOztBQUVELFVBQUksS0FBS2QsV0FBTCxDQUFpQmMsWUFBakIsRUFBK0JNLFVBQS9CLEtBQThDLEtBQUtwQixXQUFMLENBQWlCYyxZQUFqQixFQUErQk8sSUFBakYsRUFBdUY7QUFDckYsWUFBSUMsTUFBTW5DLFdBQVdvQyxZQUFYLEVBQVY7QUFDQSxZQUFJLE9BQU9KLEVBQVAsS0FBYyxVQUFsQixFQUE4QjtBQUM1QixlQUFLMUIsZ0JBQUwsQ0FBc0I2QixHQUF0QixJQUE2QkgsRUFBN0I7QUFDRDtBQUNELGFBQUtuQixXQUFMLENBQWlCYyxZQUFqQixFQUErQm5CLElBQS9CLENBQW9DNkIsS0FBS0MsU0FBTCxDQUFlO0FBQ2pELG1CQUFTakIsT0FBT0MsTUFBUCxDQUFjO0FBQ3JCLG1CQUFPYTtBQURjLFdBQWQsRUFFTixLQUFLckIsT0FGQyxDQUR3QztBQUlqRCxxQkFBV0o7QUFKc0MsU0FBZixDQUFwQztBQU1BLGVBQU8sSUFBUDtBQUNELE9BWkQsTUFZTztBQUNMLGFBQUtELE9BQUwsQ0FBYSxvQkFBYixFQUFtQyxNQUFuQztBQUNEO0FBQ0QsYUFBTyxLQUFQO0FBQ0Q7O0FBRUQ7Ozs7Ozs7O3lCQUtLdUIsRSxFQUFJO0FBQUE7O0FBQ1AsV0FBS3ZCLE9BQUwsQ0FBYSxDQUFDLGNBQUQsT0FBbUIsS0FBS0ssT0FBTCxDQUFhSSxNQUFiLENBQW9CRSxLQUF2QyxHQUErQyxLQUFLTixPQUFMLENBQWFJLE1BQWIsQ0FBb0JDLFFBQW5FLFNBQStFLEtBQUtMLE9BQUwsQ0FBYUksTUFBYixDQUFvQmhCLElBQW5HLENBQWIsRUFBeUgsTUFBekg7QUFDQSxVQUFJeUIsZUFBZTNCLFdBQVdvQyxZQUFYLEVBQW5CO0FBQ0EsV0FBS1AsZ0JBQUwsR0FBd0JGLFlBQXhCO0FBQ0EsV0FBS2QsV0FBTCxDQUFpQmMsWUFBakIsSUFBaUMsSUFBSVksU0FBSixNQUFpQixLQUFLekIsT0FBTCxDQUFhSSxNQUFiLENBQW9CRSxLQUFyQyxHQUE2QyxLQUFLTixPQUFMLENBQWFJLE1BQWIsQ0FBb0JDLFFBQWpFLFNBQTZFLEtBQUtMLE9BQUwsQ0FBYUksTUFBYixDQUFvQmhCLElBQWpHLENBQWpDO0FBQ0EsVUFBSSxLQUFLVyxXQUFMLENBQWlCYyxZQUFqQixFQUErQk0sVUFBL0IsS0FBOEMsS0FBS3BCLFdBQUwsQ0FBaUJjLFlBQWpCLEVBQStCYSxVQUFqRixFQUE2RjtBQUMzRixhQUFLM0IsV0FBTCxDQUFpQmMsWUFBakIsRUFBK0JjLE1BQS9CLEdBQXdDLFlBQU07QUFDNUMsaUJBQUtoQyxPQUFMLENBQWEsV0FBYixFQUEwQixNQUExQjtBQUNBaUMscUJBQVcsWUFBTTtBQUNmLG1CQUFLbEMsSUFBTCxDQUFVLFlBQVYsRUFBd0J3QixFQUF4QjtBQUNELFdBRkQsRUFFRyxFQUZIO0FBR0QsU0FMRDtBQU1BLGFBQUtuQixXQUFMLENBQWlCYyxZQUFqQixFQUErQmdCLE9BQS9CLEdBQXlDLGFBQUs7QUFDNUMsaUJBQUtsQyxPQUFMLENBQWEsQ0FBQyxpQkFBRCxFQUFvQm1DLENBQXBCLENBQWIsRUFBcUMsT0FBckM7QUFDRCxTQUZEO0FBR0EsYUFBSy9CLFdBQUwsQ0FBaUJjLFlBQWpCLEVBQStCa0IsU0FBL0IsR0FBMkMsYUFBSztBQUM5QyxjQUFJQyxTQUFTOUMsV0FBVytDLFlBQVgsQ0FBd0JILEVBQUVJLElBQTFCLENBQWI7QUFDQSxjQUFJRixVQUFVLE9BQU9BLE9BQU8sT0FBUCxDQUFQLEtBQTJCLFdBQXpDLEVBQXNEO0FBQ3BELGdCQUFJLE9BQU8sT0FBS3hDLGdCQUFMLENBQXNCd0MsT0FBTyxPQUFQLEVBQWdCRyxLQUF0QyxDQUFQLEtBQXdELFVBQTVELEVBQXdFO0FBQ3RFLHFCQUFLM0MsZ0JBQUwsQ0FBc0J3QyxPQUFPLE9BQVAsRUFBZ0JHLEtBQXRDLEVBQTZDQyxJQUE3QyxDQUFrRCxPQUFLcEMsT0FBdkQsRUFBZ0VnQyxPQUFPLE9BQVAsRUFBZ0JLLE9BQWhGO0FBQ0QsYUFGRCxNQUVPLElBQUksT0FBTyxPQUFLN0MsZ0JBQUwsQ0FBc0J3QyxPQUFPLE9BQVAsRUFBZ0JYLEdBQXRDLENBQVAsS0FBc0QsVUFBMUQsRUFBc0U7QUFDM0UscUJBQUs3QixnQkFBTCxDQUFzQndDLE9BQU8sT0FBUCxFQUFnQlgsR0FBdEMsRUFBMkNlLElBQTNDLENBQWdELE9BQUtwQyxPQUFyRCxFQUE4RGdDLE9BQU9wQyxPQUFQLElBQWtCLElBQWhGO0FBQ0EscUJBQU8sT0FBS0osZ0JBQUwsQ0FBc0J3QyxPQUFPLE9BQVAsRUFBZ0JYLEdBQXRDLENBQVA7QUFDRDtBQUNGO0FBQ0QsaUJBQUsxQixPQUFMLENBQWEsQ0FBQyxRQUFELEVBQVdxQyxNQUFYLENBQWIsRUFBaUMsT0FBakM7QUFDRCxTQVhEO0FBWUEsYUFBS2pDLFdBQUwsQ0FBaUJjLFlBQWpCLEVBQStCeUIsT0FBL0IsR0FBeUMsYUFBSztBQUM1QyxpQkFBSzNDLE9BQUwsQ0FBYSxDQUFDLGtCQUFELEVBQXFCbUMsQ0FBckIsQ0FBYixFQUFzQyxNQUF0QztBQUNBLGNBQUksT0FBS2hDLFVBQUwsQ0FBZ0J5QyxPQUFoQixDQUF3QjFCLFlBQXhCLE1BQTBDLENBQUMsQ0FBM0MsSUFBZ0QsT0FBTyxPQUFLYixPQUFMLENBQWFDLE1BQWIsQ0FBb0JYLFNBQTNCLEtBQXlDLFFBQXpGLElBQXFHLE9BQUtVLE9BQUwsQ0FBYUMsTUFBYixDQUFvQlgsU0FBcEIsR0FBZ0MsQ0FBekksRUFBNEk7QUFDMUlzQyx1QkFBVyxZQUFNO0FBQ2YscUJBQUtqQyxPQUFMLENBQWEscUNBQWIsRUFBb0QsTUFBcEQ7QUFDQSxxQkFBSzZDLElBQUw7QUFDRCxhQUhELEVBR0csT0FBS3hDLE9BQUwsQ0FBYUMsTUFBYixDQUFvQlgsU0FIdkI7QUFJRDtBQUNELGlCQUFPLE9BQUtTLFdBQUwsQ0FBaUJjLFlBQWpCLENBQVA7QUFDRCxTQVREO0FBVUQ7O0FBRUQsYUFBT0EsWUFBUDtBQUNEOzs7bUNBNUdxQjtBQUNwQixVQUFJNEIsSUFBSSxJQUFJQyxJQUFKLEdBQVdDLE9BQVgsRUFBUjtBQUNBLFVBQUlDLE9BQU9DLFdBQVAsSUFBc0IsT0FBT0QsT0FBT0MsV0FBUCxDQUFtQkMsR0FBMUIsS0FBa0MsVUFBNUQsRUFBd0U7QUFDdEVMLGFBQUtJLFlBQVlDLEdBQVosRUFBTDtBQUNEO0FBQ0QsYUFBTyx1Q0FBdUNDLE9BQXZDLENBQStDLE9BQS9DLEVBQXdELFVBQVVDLENBQVYsRUFBYTtBQUMxRSxZQUFJQyxJQUFJLENBQUNSLElBQUlTLEtBQUtDLE1BQUwsS0FBZ0IsRUFBckIsSUFBMkIsRUFBM0IsR0FBZ0MsQ0FBeEM7QUFDQVYsWUFBSVMsS0FBS0UsS0FBTCxDQUFXWCxJQUFJLEVBQWYsQ0FBSjtBQUNBLGVBQU8sQ0FBQ08sS0FBSyxHQUFMLEdBQVdDLENBQVgsR0FBZ0JBLElBQUksR0FBSixHQUFVLEdBQTNCLEVBQWlDSSxRQUFqQyxDQUEwQyxFQUExQyxDQUFQO0FBQ0QsT0FKTSxDQUFQO0FBS0Q7OztpQ0FFbUJ6RCxPLEVBQVM7QUFDM0IsVUFBSSxPQUFPQSxPQUFQLEtBQW1CLFdBQXZCLEVBQW9DO0FBQ2xDLGVBQU8sSUFBUDtBQUNELE9BRkQsTUFFTyxJQUFJLE9BQU9BLE9BQVAsS0FBbUIsUUFBdkIsRUFBaUM7QUFDdEMsZUFBTzJCLEtBQUsrQixLQUFMLENBQVcxRCxPQUFYLENBQVA7QUFDRCxPQUZNLE1BRUE7QUFDTCxlQUFPQSxPQUFQO0FBQ0Q7QUFDRjs7Ozs7O2tCQXJIa0JWLFUiLCJmaWxlIjoic29ja3N0cmVhbS5qcyIsInNvdXJjZXNDb250ZW50IjpbImV4cG9ydCBkZWZhdWx0IGNsYXNzIFN0cmVhbVNvY2sge1xuICAvKipcbiAgICogQHBhcmFtIHtzdHJpbmd8T2JqZWN0fSBob3N0IEVpdGhlciBkZWZpbmUgdGhlIGhvc3QgbmFtZSAoYW5kIGZ1cnRoZXIgb3B0aW9uYWwgYXR0cmlidXRlcyksIE9SIHBhc3MgaW4gYSBjb25maWd1cmF0aW9uIG9iamVjdFxuICAgKiBAcGFyYW0gcG9ydFxuICAgKiBAcGFyYW0gc2VjdXJlXG4gICAqIEBwYXJhbSBrZWVwQWxpdmVcbiAgICogQHBhcmFtIGRlYnVnTGV2ZWxcbiAgICovXG4gIGNvbnN0cnVjdG9yKGhvc3QgPSAnbG9jYWxob3N0JywgcG9ydCA9IDgwODIsIHNlY3VyZSA9IHRydWUsIGtlZXBBbGl2ZSA9IDgwMCwgZGVidWdMZXZlbCA9IDApIHtcbiAgICB0aGlzLmNhbGxiYWNrUmVnaXN0ZXIgPSB7XG4gICAgICBwaW5nOiBtZXNzYWdlID0+IHtcbiAgICAgICAgdGhpcy5zZW5kKCdwb25nJylcbiAgICAgICAgdGhpcy5jb25zb2xlKFsnW1BJTkddJywgbWVzc2FnZV0pXG4gICAgICB9LFxuICAgICAgc3lzdGVtOiBtZXNzYWdlID0+IHtcbiAgICAgICAgdGhpcy5jb25zb2xlKFsnW1NZU1RFTV0nLCBtZXNzYWdlXSlcbiAgICAgIH1cbiAgICB9XG4gICAgdGhpcy5kaXNjb25uZWN0ID0gW107XG4gICAgdGhpcy5jb25uZWN0aW9ucyA9IHt9O1xuICAgIHRoaXMuX2NvbmZpZyA9IHtcbiAgICAgIGNsaWVudDoge1xuICAgICAgICBuYW1lOiAnc29ja3N0cmVhbS5qcycsXG4gICAgICAgIHZlcnNpb246IDEuMixcbiAgICAgICAgZGVidWdMZXZlbDogMCxcbiAgICAgICAga2VlcEFsaXZlOiA4MDBcbiAgICAgIH0sXG4gICAgICBzZXJ2ZXI6IHtcbiAgICAgICAgbmFtZTogJ3NvY2tldHMvcGhwLXN0cmVhbS1zb2NrZXQtc2VydmVyJyxcbiAgICAgICAgdmVyc2lvbjogMS4zLFxuICAgICAgICBob3N0bmFtZTogJ2xvY2FsaG9zdCcsXG4gICAgICAgIHBvcnQ6IDgwODIsXG4gICAgICAgIHByb3RvOiAnd3NzOi8vJ1xuICAgICAgfVxuICAgIH1cbiAgICBpZiAodHlwZW9mIGhvc3QgPT09ICdvYmplY3QnKSB7XG4gICAgICBpZiAodHlwZW9mIGhvc3QuY2xpZW50ID09PSAnb2JqZWN0Jykge1xuICAgICAgICB0aGlzLl9jb25maWcuY2xpZW50ID0gT2JqZWN0LmFzc2lnbih7XG4gICAgICAgICAgZGVidWdMZXZlbDogMCxcbiAgICAgICAgICBrZWVwQWxpdmU6IDgwMFxuICAgICAgICB9LCBob3N0LmNsaWVudCwge1xuICAgICAgICAgIG5hbWU6ICdzb2Nrc3RyZWFtLmpzJyxcbiAgICAgICAgICB2ZXJzaW9uOiAwLjFcbiAgICAgICAgfSlcbiAgICAgIH1cbiAgICAgIGlmICh0eXBlb2YgaG9zdC5zZXJ2ZXIgPT09ICdvYmplY3QnKSB7XG4gICAgICAgIHRoaXMuX2NvbmZpZy5zZXJ2ZXIgPSBPYmplY3QuYXNzaWduKHtcbiAgICAgICAgICBob3N0bmFtZTogJ2xvY2FsaG9zdCcsXG4gICAgICAgICAgcG9ydDogODA4MixcbiAgICAgICAgICBwcm90bzogJ3dzczovLydcbiAgICAgICAgfSwgaG9zdC5zZXJ2ZXIsIHtcbiAgICAgICAgICBuYW1lOiAnc29ja2V0cy9waHAtc3RyZWFtLXNvY2tldC1zZXJ2ZXInLFxuICAgICAgICAgIHZlcnNpb246IDEuM1xuICAgICAgICB9KVxuICAgICAgfVxuICAgIH0gZWxzZSB7XG4gICAgICB0aGlzLl9jb25maWcgPSB7XG4gICAgICAgIGNsaWVudDoge1xuICAgICAgICAgIG5hbWU6ICdzb2Nrc3RyZWFtLmpzJyxcbiAgICAgICAgICB2ZXJzaW9uOiAwLjEsXG4gICAgICAgICAgZGVidWdMZXZlbDogZGVidWdMZXZlbCxcbiAgICAgICAgICBrZWVwQWxpdmU6IGtlZXBBbGl2ZVxuICAgICAgICB9LFxuICAgICAgICBzZXJ2ZXI6IHtcbiAgICAgICAgICBuYW1lOiAnc29ja2V0cy9waHAtc3RyZWFtLXNvY2tldC1zZXJ2ZXInLFxuICAgICAgICAgIHZlcnNpb246IDEuMyxcbiAgICAgICAgICBob3N0bmFtZTogaG9zdCxcbiAgICAgICAgICBwb3J0OiBwb3J0LFxuICAgICAgICAgIHByb3RvOiAhIXNlY3VyZSA/ICd3c3M6Ly8nIDogJ3dzOi8vJ1xuICAgICAgICB9XG4gICAgICB9XG4gICAgfVxuICB9XG5cbiAgY29uc29sZShtZXNzYWdlLCB0eXBlID0gJ2xvZycpIHtcbiAgICBsZXQgbGV2ZWxNYXAgPSB7XG4gICAgICAnbG9nJzogNCxcbiAgICAgICdkZWJ1Zyc6IDMsXG4gICAgICAnaW5mbyc6IDIsXG4gICAgICAnd2Fybic6IDEsXG4gICAgICAnZXJyb3InOiAwXG4gICAgfVxuICAgIHRoaXMuX2NvbmZpZy5jbGllbnQuZGVidWdMZXZlbCA+PSAobGV2ZWxNYXBbdHlwZV18fDApICYmIGNvbnNvbGVbdHlwZV0obWVzc2FnZSlcbiAgfVxuXG4gIC8qKlxuICAgKiBFaXRoZXIgcmV0cmlldmVzIG9yIHNldHMgdGhlIGRlYnVnIGNvbmZpZyB2YWx1ZVxuICAgKiBAcGFyYW0gc2V0dGluZ1xuICAgKiBAcmV0dXJucyB7Ym9vbGVhbn1cbiAgICovXG4gIGRlYnVnKHNldHRpbmcpIHtcbiAgICBpZiAodHlwZW9mIHNldHRpbmcgIT09ICd1bmRlZmluZWQnKSB7XG4gICAgICB0aGlzLl9jb25maWcuY2xpZW50LmRlYnVnID0gISFzZXR0aW5nXG4gICAgfVxuICAgIHJldHVybiB0aGlzLl9jb25maWcuY2xpZW50LmRlYnVnXG4gIH1cblxuICBzdGF0aWMgZ2VuZXJhdGVVVUlEKCkge1xuICAgIGxldCBkID0gbmV3IERhdGUoKS5nZXRUaW1lKCk7XG4gICAgaWYgKHdpbmRvdy5wZXJmb3JtYW5jZSAmJiB0eXBlb2Ygd2luZG93LnBlcmZvcm1hbmNlLm5vdyA9PT0gJ2Z1bmN0aW9uJykge1xuICAgICAgZCArPSBwZXJmb3JtYW5jZS5ub3coKTtcbiAgICB9XG4gICAgcmV0dXJuICd4eHh4eHh4eC14eHh4LTR4eHgteXh4eC14eHh4eHh4eHh4eHgnLnJlcGxhY2UoL1t4eV0vZywgZnVuY3Rpb24gKGMpIHtcbiAgICAgIGxldCByID0gKGQgKyBNYXRoLnJhbmRvbSgpICogMTYpICUgMTYgfCAwO1xuICAgICAgZCA9IE1hdGguZmxvb3IoZCAvIDE2KTtcbiAgICAgIHJldHVybiAoYyA9PSAneCcgPyByIDogKHIgJiAweDMgfCAweDgpKS50b1N0cmluZygxNik7XG4gICAgfSlcbiAgfVxuXG4gIHN0YXRpYyBwYXJzZU1lc3NhZ2UobWVzc2FnZSkge1xuICAgIGlmICh0eXBlb2YgbWVzc2FnZSA9PT0gJ3VuZGVmaW5lZCcpIHtcbiAgICAgIHJldHVybiBudWxsXG4gICAgfSBlbHNlIGlmICh0eXBlb2YgbWVzc2FnZSA9PT0gJ3N0cmluZycpIHtcbiAgICAgIHJldHVybiBKU09OLnBhcnNlKG1lc3NhZ2UpXG4gICAgfSBlbHNlIHtcbiAgICAgIHJldHVybiBtZXNzYWdlO1xuICAgIH1cbiAgfVxuXG4gIGNsb3NlKGNvbm5lY3Rpb25JZCA9IG51bGwpIHtcbiAgICBsZXQgaWQgPSBjb25uZWN0aW9uSWQgfHwgdGhpcy5sYXN0Q29ubmVjdGlvbklkO1xuICAgIGlmICh0eXBlb2YgdGhpcy5jb25uZWN0aW9uc1tpZF0gIT09ICd1bmRlZmluZWQnKSB7XG4gICAgICB0aGlzLmRpc2Nvbm5lY3QucHVzaChpZClcbiAgICAgIHRoaXMuY29ubmVjdGlvbnNbaWRdLmNsb3NlKClcbiAgICB9XG4gICAgcmV0dXJuIHRydWU7XG4gIH1cblxuICAvKipcbiAgICogQHBhcmFtIHtzdHJpbmd9IG1lc3NhZ2VcbiAgICogQHBhcmFtIHtzdHJpbmd8ZnVuY3Rpb259IGNiIGVpdGhlciBkZWZpbmUgYSBjbG9zdXJlIG9yIHBhc3MgaW4gYSBjb25uZWN0aW9uSWRcbiAgICogQHJldHVybnMge2Jvb2xlYW59XG4gICAqL1xuICBzZW5kKG1lc3NhZ2UsIGNiKSB7XG4gICAgbGV0IGNvbm5lY3Rpb25JZCA9IHRoaXMubGFzdENvbm5lY3Rpb25JZFxuICAgIGlmICh0eXBlb2YgY2IgIT09ICdmdW5jdGlvbicgJiYgdHlwZW9mIHRoaXMuY29ubmVjdGlvbnNbY2JdICE9PSAndW5kZWZpbmVkJyApIHtcbiAgICAgIHRoaXMubGFzdENvbm5lY3Rpb25JZCA9IGNvbm5lY3Rpb25JZCA9IGNiXG4gICAgfVxuICAgIGlmICh0eXBlb2YgdGhpcy5jb25uZWN0aW9uc1tjb25uZWN0aW9uSWRdID09PSAndW5kZWZpbmVkJyApIHtcbiAgICAgIHJldHVybiBmYWxzZTtcbiAgICB9XG5cbiAgICBpZiAodGhpcy5jb25uZWN0aW9uc1tjb25uZWN0aW9uSWRdLnJlYWR5U3RhdGUgPT09IHRoaXMuY29ubmVjdGlvbnNbY29ubmVjdGlvbklkXS5PUEVOKSB7XG4gICAgICBsZXQgX2lkID0gU3RyZWFtU29jay5nZW5lcmF0ZVVVSUQoKVxuICAgICAgaWYgKHR5cGVvZiBjYiA9PT0gJ2Z1bmN0aW9uJykge1xuICAgICAgICB0aGlzLmNhbGxiYWNrUmVnaXN0ZXJbX2lkXSA9IGNiXG4gICAgICB9XG4gICAgICB0aGlzLmNvbm5lY3Rpb25zW2Nvbm5lY3Rpb25JZF0uc2VuZChKU09OLnN0cmluZ2lmeSh7XG4gICAgICAgICdAbWV0YSc6IE9iamVjdC5hc3NpZ24oe1xuICAgICAgICAgICdfaWQnOiBfaWRcbiAgICAgICAgfSwgdGhpcy5fY29uZmlnKSxcbiAgICAgICAgJ21lc3NhZ2UnOiBtZXNzYWdlXG4gICAgICB9KSlcbiAgICAgIHJldHVybiB0cnVlXG4gICAgfSBlbHNlIHtcbiAgICAgIHRoaXMuY29uc29sZSgnV2ViU29ja2V0IG5vdCBvcGVuJywgJ3dhcm4nKVxuICAgIH1cbiAgICByZXR1cm4gZmFsc2VcbiAgfVxuXG4gIC8qKlxuICAgKiBPcGVucyBhIG5ldyBXZWJTb2NrZXQgY29ubmVjdGlvbiwgaXQgZG9lcyBub3Qgb3Zlci13cml0ZSBleGlzdGluZyBvcGVuIGNvbm5lY3Rpb25zXG4gICAqIEBwYXJhbSB7ZnVuY3Rpb259IGNiXG4gICAqIEByZXR1cm5zIHtzdHJpbmd9IGNvbm5lY3Rpb25JZFxuICAgKi9cbiAgb3BlbihjYikge1xuICAgIHRoaXMuY29uc29sZShbJ1tDT05ORUNUSU5HXScsYCR7dGhpcy5fY29uZmlnLnNlcnZlci5wcm90b30ke3RoaXMuX2NvbmZpZy5zZXJ2ZXIuaG9zdG5hbWV9OiR7dGhpcy5fY29uZmlnLnNlcnZlci5wb3J0fWBdLCAnaW5mbycpXG4gICAgbGV0IGNvbm5lY3Rpb25JZCA9IFN0cmVhbVNvY2suZ2VuZXJhdGVVVUlEKClcbiAgICB0aGlzLmxhc3RDb25uZWN0aW9uSWQgPSBjb25uZWN0aW9uSWRcbiAgICB0aGlzLmNvbm5lY3Rpb25zW2Nvbm5lY3Rpb25JZF0gPSBuZXcgV2ViU29ja2V0KGAke3RoaXMuX2NvbmZpZy5zZXJ2ZXIucHJvdG99JHt0aGlzLl9jb25maWcuc2VydmVyLmhvc3RuYW1lfToke3RoaXMuX2NvbmZpZy5zZXJ2ZXIucG9ydH1gKVxuICAgIGlmICh0aGlzLmNvbm5lY3Rpb25zW2Nvbm5lY3Rpb25JZF0ucmVhZHlTdGF0ZSA9PT0gdGhpcy5jb25uZWN0aW9uc1tjb25uZWN0aW9uSWRdLkNPTk5FQ1RJTkcpIHtcbiAgICAgIHRoaXMuY29ubmVjdGlvbnNbY29ubmVjdGlvbklkXS5vbm9wZW4gPSAoKSA9PiB7XG4gICAgICAgIHRoaXMuY29uc29sZSgnY29ubmVjdGVkJywgJ2luZm8nKVxuICAgICAgICBzZXRUaW1lb3V0KCgpID0+IHtcbiAgICAgICAgICB0aGlzLnNlbmQoJ2Nvbm5lY3RpbmcnLCBjYilcbiAgICAgICAgfSwgMjApXG4gICAgICB9XG4gICAgICB0aGlzLmNvbm5lY3Rpb25zW2Nvbm5lY3Rpb25JZF0ub25lcnJvciA9IGUgPT4ge1xuICAgICAgICB0aGlzLmNvbnNvbGUoWydXZWJTb2NrZXQgZXJyb3InLCBlXSwgJ2Vycm9yJylcbiAgICAgIH1cbiAgICAgIHRoaXMuY29ubmVjdGlvbnNbY29ubmVjdGlvbklkXS5vbm1lc3NhZ2UgPSBlID0+IHtcbiAgICAgICAgbGV0IHBhcnNlZCA9IFN0cmVhbVNvY2sucGFyc2VNZXNzYWdlKGUuZGF0YSk7XG4gICAgICAgIGlmIChwYXJzZWQgJiYgdHlwZW9mIHBhcnNlZFsnQG1ldGEnXSAhPT0gJ3VuZGVmaW5lZCcpIHtcbiAgICAgICAgICBpZiAodHlwZW9mIHRoaXMuY2FsbGJhY2tSZWdpc3RlcltwYXJzZWRbJ0BtZXRhJ10uX3R5cGVdID09PSAnZnVuY3Rpb24nKSB7XG4gICAgICAgICAgICB0aGlzLmNhbGxiYWNrUmVnaXN0ZXJbcGFyc2VkWydAbWV0YSddLl90eXBlXS5jYWxsKHRoaXMuX2NvbmZpZywgcGFyc2VkWydAbWV0YSddLl9zeXN0ZW0pXG4gICAgICAgICAgfSBlbHNlIGlmICh0eXBlb2YgdGhpcy5jYWxsYmFja1JlZ2lzdGVyW3BhcnNlZFsnQG1ldGEnXS5faWRdID09PSAnZnVuY3Rpb24nKSB7XG4gICAgICAgICAgICB0aGlzLmNhbGxiYWNrUmVnaXN0ZXJbcGFyc2VkWydAbWV0YSddLl9pZF0uY2FsbCh0aGlzLl9jb25maWcsIHBhcnNlZC5tZXNzYWdlIHx8IG51bGwpXG4gICAgICAgICAgICBkZWxldGUgdGhpcy5jYWxsYmFja1JlZ2lzdGVyW3BhcnNlZFsnQG1ldGEnXS5faWRdXG4gICAgICAgICAgfVxuICAgICAgICB9XG4gICAgICAgIHRoaXMuY29uc29sZShbJ1tSQ1ZEXScsIHBhcnNlZF0sICdkZWJ1ZycpXG4gICAgICB9XG4gICAgICB0aGlzLmNvbm5lY3Rpb25zW2Nvbm5lY3Rpb25JZF0ub25jbG9zZSA9IGUgPT4ge1xuICAgICAgICB0aGlzLmNvbnNvbGUoWydXZWJTb2NrZXQgY2xvc2VkJywgZV0sICd3YXJuJylcbiAgICAgICAgaWYgKHRoaXMuZGlzY29ubmVjdC5pbmRleE9mKGNvbm5lY3Rpb25JZCkgPT09IC0xICYmIHR5cGVvZiB0aGlzLl9jb25maWcuY2xpZW50LmtlZXBBbGl2ZSA9PT0gJ251bWJlcicgJiYgdGhpcy5fY29uZmlnLmNsaWVudC5rZWVwQWxpdmUgPiAwKSB7XG4gICAgICAgICAgc2V0VGltZW91dCgoKSA9PiB7XG4gICAgICAgICAgICB0aGlzLmNvbnNvbGUoJ0F0dGVtcHRpbmcgdG8gcmVlc3RhYmxpc2ggV2ViU29ja2V0JywgJ2luZm8nKVxuICAgICAgICAgICAgdGhpcy5vcGVuKClcbiAgICAgICAgICB9LCB0aGlzLl9jb25maWcuY2xpZW50LmtlZXBBbGl2ZSlcbiAgICAgICAgfVxuICAgICAgICBkZWxldGUgdGhpcy5jb25uZWN0aW9uc1tjb25uZWN0aW9uSWRdXG4gICAgICB9XG4gICAgfVxuXG4gICAgcmV0dXJuIGNvbm5lY3Rpb25JZDtcbiAgfVxufVxuIl19
+exports.default = StreamSock;

dist/sockstream.min.js

@@ -1,1 +0,1 @@
-"use strict";function _classCallCheck(e,n){if(!(e instanceof n))throw new TypeError("Cannot call a class as a function")}Object.defineProperty(exports,"__esModule",{value:!0});var _typeof="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e},_createClass=function(){function e(e,n){for(var t=0;t<n.length;t++){var o=n[t];o.enumerable=o.enumerable||!1,o.configurable=!0,"value"in o&&(o.writable=!0),Object.defineProperty(e,o.key,o)}}return function(n,t,o){return t&&e(n.prototype,t),o&&e(n,o),n}}(),StreamSock=function(){function e(){var n=arguments.length>0&&void 0!==arguments[0]?arguments[0]:"localhost",t=arguments.length>1&&void 0!==arguments[1]?arguments[1]:8082,o=!(arguments.length>2&&void 0!==arguments[2])||arguments[2],i=this,s=arguments.length>3&&void 0!==arguments[3]?arguments[3]:800,c=arguments.length>4&&void 0!==arguments[4]?arguments[4]:0;_classCallCheck(this,e),this.callbackRegister={ping:function(e){i.send("pong"),i.console(["[PING]",e])},system:function(e){i.console(["[SYSTEM]",e])}},this.disconnect=[],this.connections={},this._config={client:{name:"sockstream.js",version:1.2,debugLevel:0,keepAlive:800},server:{name:"sockets/php-stream-socket-server",version:1.3,hostname:"localhost",port:8082,proto:"wss://"}},"object"===("undefined"==typeof n?"undefined":_typeof(n))?("object"===_typeof(n.client)&&(this._config.client=Object.assign({debugLevel:0,keepAlive:800},n.client,{name:"sockstream.js",version:.1})),"object"===_typeof(n.server)&&(this._config.server=Object.assign({hostname:"localhost",port:8082,proto:"wss://"},n.server,{name:"sockets/php-stream-socket-server",version:1.3}))):this._config={client:{name:"sockstream.js",version:.1,debugLevel:c,keepAlive:s},server:{name:"sockets/php-stream-socket-server",version:1.3,hostname:n,port:t,proto:o?"wss://":"ws://"}}}return _createClass(e,[{key:"console",value:function(e){function n(n){return e.apply(this,arguments)}return n.toString=function(){return e.toString()},n}(function(e){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:"log",t={log:4,debug:3,info:2,warn:1,error:0};this._config.client.debugLevel>=(t[n]||0)&&console[n](e)})},{key:"debug",value:function(e){return"undefined"!=typeof e&&(this._config.client.debug=!!e),this._config.client.debug}},{key:"close",value:function(){var e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:null,n=e||this.lastConnectionId;return"undefined"!=typeof this.connections[n]&&(this.disconnect.push(n),this.connections[n].close()),!0}},{key:"send",value:function(n,t){var o=this.lastConnectionId;if("function"!=typeof t&&"undefined"!=typeof this.connections[t]&&(this.lastConnectionId=o=t),"undefined"==typeof this.connections[o])return!1;if(this.connections[o].readyState===this.connections[o].OPEN){var i=e.generateUUID();return"function"==typeof t&&(this.callbackRegister[i]=t),this.connections[o].send(JSON.stringify({"@meta":Object.assign({_id:i},this._config),message:n})),!0}return this.console("WebSocket not open","warn"),!1}},{key:"open",value:function(n){var t=this;this.console(["[CONNECTING]",""+this._config.server.proto+this._config.server.hostname+":"+this._config.server.port],"info");var o=e.generateUUID();return this.lastConnectionId=o,this.connections[o]=new WebSocket(""+this._config.server.proto+this._config.server.hostname+":"+this._config.server.port),this.connections[o].readyState===this.connections[o].CONNECTING&&(this.connections[o].onopen=function(){t.console("connected","info"),setTimeout(function(){t.send("connecting",n)},20)},this.connections[o].onerror=function(e){t.console(["WebSocket error",e],"error")},this.connections[o].onmessage=function(n){var o=e.parseMessage(n.data);o&&"undefined"!=typeof o["@meta"]&&("function"==typeof t.callbackRegister[o["@meta"]._type]?t.callbackRegister[o["@meta"]._type].call(t._config,o["@meta"]._system):"function"==typeof t.callbackRegister[o["@meta"]._id]&&(t.callbackRegister[o["@meta"]._id].call(t._config,o.message||null),delete t.callbackRegister[o["@meta"]._id])),t.console(["[RCVD]",o],"debug")},this.connections[o].onclose=function(e){t.console(["WebSocket closed",e],"warn"),t.disconnect.indexOf(o)===-1&&"number"==typeof t._config.client.keepAlive&&t._config.client.keepAlive>0&&setTimeout(function(){t.console("Attempting to reestablish WebSocket","info"),t.open()},t._config.client.keepAlive),delete t.connections[o]}),o}}],[{key:"generateUUID",value:function(){var e=(new Date).getTime();return window.performance&&"function"==typeof window.performance.now&&(e+=performance.now()),"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,function(n){var t=(e+16*Math.random())%16|0;return e=Math.floor(e/16),("x"==n?t:3&t|8).toString(16)})}},{key:"parseMessage",value:function(e){return"undefined"==typeof e?null:"string"==typeof e?JSON.parse(e):e}}]),e}();exports.default=StreamSock;
+"use strict";function _toConsumableArray(e){if(Array.isArray(e)){for(var t=0,n=Array(e.length);t<e.length;t++)n[t]=e[t];return n}return Array.from(e)}function _classCallCheck(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}Object.defineProperty(exports,"__esModule",{value:!0});var _typeof="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e},_createClass=function(){function e(e,t){for(var n=0;n<t.length;n++){var o=t[n];o.enumerable=o.enumerable||!1,o.configurable=!0,"value"in o&&(o.writable=!0),Object.defineProperty(e,o.key,o)}}return function(t,n,o){return n&&e(t.prototype,n),o&&e(t,o),t}}(),StreamSock=function(){function e(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:"localhost",n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:8082,o=!(arguments.length>2&&void 0!==arguments[2])||arguments[2],i=this,s=arguments.length>3&&void 0!==arguments[3]?arguments[3]:800,r=arguments.length>4&&void 0!==arguments[4]?arguments[4]:0;_classCallCheck(this,e);var c="sockstream.js",a="1.3.3",l=800,f=0,u=8082,p="wss://",g="127.0.0.1";this.callbackRegister={ping:function(e){i.send("pong"),i.console(["[PING]",e])},system:function(e){i.console(["[SYSTEM]",e])}},this.maxKeepAliveAttempt=20,this.keepAliveAttempt=0,this.disconnect=[],this.connections={},this._config={client:{name:c,version:a,debugLevel:f,keepAlive:l},server:{hostname:g,port:u,proto:p}},"object"===("undefined"==typeof t?"undefined":_typeof(t))?("object"===_typeof(t.client)&&(this._config.client=Object.assign({debugLevel:f,keepAlive:l},t.client,{name:c,version:a})),"object"===_typeof(t.server)&&(this._config.server=Object.assign({hostname:g,port:u,proto:p},t.server))):this._config={client:{name:c,version:a,debugLevel:r,keepAlive:s},server:{hostname:t,port:n,proto:o?"wss://":"ws://"}}}return _createClass(e,[{key:"console",value:function(e){function t(t){return e.apply(this,arguments)}return t.toString=function(){return e.toString()},t}(function(e){var t,n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:"log",o={log:4,debug:3,info:2,warn:1,error:0};this._config.client.debugLevel>=(o[n]||0)&&(t=console)[n].apply(t,_toConsumableArray(e))})},{key:"debug",value:function(e){return"undefined"!=typeof e&&(this._config.client.debug=!!e),this._config.client.debug}},{key:"close",value:function(){var e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:null,t=e||this.lastConnectionId;return"undefined"!=typeof this.connections[t]&&(this.disconnect.push(t),this.connections[t].close()),!0}},{key:"send",value:function(t,n){var o=this.lastConnectionId;if("function"!=typeof n&&"undefined"!=typeof this.connections[n]&&(this.lastConnectionId=o=n),"undefined"==typeof this.connections[o])return!1;if(this.connections[o].readyState===this.connections[o].OPEN){var i=e.generateUUID();return"function"==typeof n&&(this.callbackRegister[i]=n),this.connections[o].send(JSON.stringify({"@meta":Object.assign({_id:i},this._config),message:t})),!0}return this.console("WebSocket not open","warn"),!1}},{key:"open",value:function(t){var n=this;this.console(["[CONNECTING]",""+this._config.server.proto+this._config.server.hostname+":"+this._config.server.port],"info");var o=e.generateUUID();this.lastConnectionId=o;try{this.connections[o]=new WebSocket(""+this._config.server.proto+this._config.server.hostname+":"+this._config.server.port)}catch(e){return}return this.connections[o].readyState===this.connections[o].CONNECTING&&(this.connections[o].onopen=function(){n.console("connected","info"),n.keepAliveAttempt=0,setTimeout(function(){n.send("connecting",t)},20)},this.connections[o].onerror=function(e){n.console(e,"error")},this.connections[o].onmessage=function(t){var o=e.parseMessage(t.data);o&&"undefined"!=typeof o["@meta"]?("function"==typeof n.callbackRegister[o["@meta"]._type]?n.callbackRegister[o["@meta"]._type].call(n._config,o["@meta"]._system):"function"==typeof n.callbackRegister[o["@meta"]._id]&&(n.callbackRegister[o["@meta"]._id].call(n._config,o.message),delete n.callbackRegister[o["@meta"]._id]),n.console(["[RCVD]",o.message],"debug")):n.console(["[RCVD]",t.data],"debug")},this.connections[o].onclose=function(e){if(n.console(["WebSocket closed",e],"warn"),n.disconnect.indexOf(o)===-1&&"number"==typeof n._config.client.keepAlive&&n._config.client.keepAlive>0){if(++n.keepAliveAttempt>n.maxKeepAliveAttempt)return;var t=n._config.client.keepAlive;n.keepAliveAttempt>5?t+=t/2:n.keepAliveAttempt>10&&(t=2*t),setTimeout(function(){n.console("Attempting to reestablish WebSocket","info"),n.open()},t)}delete n.connections[o]}),o}},{key:"setMaxKeepAliveAttempt",value:function(e){return this.maxKeepAliveAttempt="number"==typeof e?e:this.maxKeepAliveAttempt,this}}],[{key:"generateUUID",value:function(){var e=(new Date).getTime();return window.performance&&"function"==typeof window.performance.now&&(e+=performance.now()),"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,function(t){var n=(e+16*Math.random())%16|0;return e=Math.floor(e/16),("x"==t?n:3&n|8).toString(16)})}},{key:"parseMessage",value:function(e){return"undefined"==typeof e?null:"string"==typeof e?JSON.parse(e):e}}]),e}();exports.default=StreamSock;

gulpfile.babel.js

@@ -42,3 +42,4 @@ 'use strict';
     .pipe(babel({
-      presets: ['es2015', 'es2016', 'stage-0']
+      presets: ['es2015', 'es2016', 'stage-0'],
+      plugins: ['transform-es2015-destructuring']
     }))
@@ -75,2 +76,2 @@ .pipe(gulp.dest('./build'))
     .pipe(gulp.dest('./dist'))
-});
+});

package.json

 {
   "name": "sockstream",
-  "version": "1.3.2",
+  "version": "1.3.3",
   "description": "Provides a standard WebSocket thin manager",
@@ -31,2 +31,3 @@ "main": "src/sockstream.js",
     "babel-core": "^6.17.0",
+    "babel-plugin-transform-es2015-destructuring": "^6.16.0",
     "babel-polyfill": "^6.16.0",
@@ -43,7 +44,7 @@ "babel-preset-es2015": "^6.16.0",
     "gulp-if": "^2.0.1",
+    "gulp-minify": "latest",
     "gulp-sourcemaps": "^2.1.1",
     "gulp-uglify": "^2.0.0",
-    "run-sequence": "^1.2.2",
-    "gulp-minify": "latest"
+    "run-sequence": "^1.2.2"
   }
 }

src/sockstream.js

@@ -11,5 +11,3 @@ export default class StreamSock {
     let clientName = 'sockstream.js';
-    let clientVersion = '1.3.2';
-    let serverName = 'sockets/php-stream-socket-server';
-    let serverVersion = '1.3';
+    let clientVersion = '1.3.3';
     let defaultKeepAlive = 800;
@@ -29,2 +27,4 @@ let defaultDebugLevel = 0;
     }
+    this.maxKeepAliveAttempt = 20;
+    this.keepAliveAttempt = 0;
     this.disconnect = [];
@@ -40,4 +40,2 @@ this.connections = {};
       server: {
-        name: serverName,
-        version: serverVersion,
         hostname: defaultHost,
@@ -63,6 +61,3 @@ port: defaultPort,
           proto: defaultProto
-        }, host.server, {
-          name: serverName,
-          version: serverVersion
-        })
+        }, host.server)
       }
@@ -78,4 +73,2 @@ } else {
         server: {
-          name: serverName,
-          version: serverVersion,
           hostname: host,
@@ -97,3 +90,3 @@ port: port,
     }
-    this._config.client.debugLevel >= (levelMap[type]||0) && console[type](message)
+    this._config.client.debugLevel >= (levelMap[type]||0) && console[type](...message)
   }
@@ -185,6 +178,9 @@
     this.lastConnectionId = connectionId
-    this.connections[connectionId] = new WebSocket(`${this._config.server.proto}${this._config.server.hostname}:${this._config.server.port}`)
+    try {
+      this.connections[connectionId] = new WebSocket(`${this._config.server.proto}${this._config.server.hostname}:${this._config.server.port}`)
+    } catch(e){return}
     if (this.connections[connectionId].readyState === this.connections[connectionId].CONNECTING) {
       this.connections[connectionId].onopen = () => {
         this.console('connected', 'info')
+        this.keepAliveAttempt = 0
         setTimeout(() => {
@@ -195,3 +191,3 @@ this.send('connecting', cb)
       this.connections[connectionId].onerror = e => {
-        this.console(['WebSocket error', e], 'error')
+        this.console(e, 'error')
       }
@@ -204,7 +200,9 @@ this.connections[connectionId].onmessage = e => {
           } else if (typeof this.callbackRegister[parsed['@meta']._id] === 'function') {
-            this.callbackRegister[parsed['@meta']._id].call(this._config, parsed.message || null)
+            this.callbackRegister[parsed['@meta']._id].call(this._config, parsed.message)
             delete this.callbackRegister[parsed['@meta']._id]
           }
+          this.console(['[RCVD]', parsed.message], 'debug')
+        } else {
+          this.console(['[RCVD]', e.data], 'debug')
         }
-        this.console(['[RCVD]', parsed], 'debug')
       }
@@ -214,6 +212,15 @@ this.connections[connectionId].onclose = e => {
         if (this.disconnect.indexOf(connectionId) === -1 && typeof this._config.client.keepAlive === 'number' && this._config.client.keepAlive > 0) {
+          if (++this.keepAliveAttempt > this.maxKeepAliveAttempt) {
+            return;
+          }
+          let timeout = this._config.client.keepAlive;
+          if (this.keepAliveAttempt > 5) {
+            timeout = timeout + (timeout/2)
+          } else if (this.keepAliveAttempt > 10) {
+            timeout = timeout*2
+          }
           setTimeout(() => {
             this.console('Attempting to reestablish WebSocket', 'info')
             this.open()
-          }, this._config.client.keepAlive)
+          }, timeout)
         }
@@ -226,2 +233,10 @@ delete this.connections[connectionId]
   }
+
+  /**
+   * @param number int
+   */
+  setMaxKeepAliveAttempt(number) {
+    this.maxKeepAliveAttempt = typeof number === 'number' ? number : this.maxKeepAliveAttempt
+    return this
+  }
 }

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

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

Improved metrics

Lines of code

553

increased by8.64%

Worsened metrics

Total package byte prevSize

37537

decreased by-29.09%

Dev dependency count

18

increased by5.88%

No dependency changes