appbase-js - npm Package Compare versions

Comparing version 0.4.0 to 0.5.0

better_websocket.js

@@ -8,2 +8,4 @@ var WebSocket = require('ws')
 
+	ee.setMaxListeners(0)
+
 	ee.send = function(dataObj) {
@@ -10,0 +12,0 @@ if(conn.readyState !== 1) {

bower.json

 {
   "name": "appbase-js",
-  "version": "0.4.0",
+  "version": "0.5.0",
   "homepage": "https://github.com/appbaseio/appbase-js",
@@ -5,0 +5,0 @@ "authors": [

package.json

 {
   "name": "appbase-js",
-  "version": "0.4.0",
+  "version": "0.5.0",
   "description": "Appbase.io streaming client lib for Javascript",
@@ -21,2 +21,3 @@ "main": "appbase.js",
     "hyperquest": "^1.2.0",
+    "immutable": "^3.7.5",
     "through2": "^2.0.0",
@@ -23,0 +24,0 @@ "ws": "^0.8.0"

websocket_request.js

@@ -5,2 +5,3 @@ var Readable = require('stream').Readable;
 var through2 = require('through2')
+var immutable = require('immutable')
 var EventEmitter = require('events').EventEmitter
@@ -30,3 +31,3 @@
 
-	this.request = {
+	this.request = immutable.fromJS({
 		id: this.id,
@@ -37,3 +38,3 @@ path: this.client.appname + '/' + this.path + '?' + querystring.stringify(this.params),
 		authorization: 'Basic ' + (new Buffer(this.client.credentials).toString('base64'))
-	}
+	})
 
@@ -136,8 +137,7 @@ this.resultStream = through2.obj()
 	}
-	var unsubRequest = {}
-	for(var key in this.request) {
-		unsubRequest[key] = this.request[key]
+	var unsubRequest = this.request.set('unsubscribe', true)
+	if(this.unsubscribed !== true) {
+		this.client.ws.send(unsubRequest)
 	}
-	unsubRequest.unsubscribe = true
-	this.client.ws.send(unsubRequest)
+	this.unsubscribed = true
 }
@@ -144,0 +144,0 @@

No alert changes

Improved metrics

Total package byte prevSize

716813

increased by38.48%

Lines of code

16251

increased by37.42%

Worsened metrics

Dependency count

6

increased by20%

Number of package files

24

decreased by-4%

Dependency changes

• + Addedimmutable@^3.7.5

• + Addedimmutable@3.8.2(transitive)