aedes - npm Package Compare versions

Comparing version 0.35.3 to 0.36.0

aedes.js

@@ -39,3 +39,3 @@ 'use strict'
 
-  this.id = shortid()
+  this.id = opts.id || shortid()
   this.counter = 0
@@ -42,0 +42,0 @@ this.connectTimeout = opts.connectTimeout

lib/client.js

@@ -152,6 +152,2 @@ 'use strict'
 
-function drainRequest (req) {
-  req.callback()
-}
-
 function onError (err) {
@@ -279,8 +275,2 @@ this.errored = true
 
-    // hack to clean up the write callbacks
-    // supports streams2 & streams3, so node 0.10, 0.11, and iojs
-    var state = that.conn._writableState
-    var list = (state.getBuffer && state.getBuffer()) || state.buffer
-    list.forEach(drainRequest)
-
     // clear up the drain event listeners
@@ -287,0 +277,0 @@ that.conn.emit('drain')

package.json

 {
   "name": "aedes",
-  "version": "0.35.3",
+  "version": "0.36.0",
   "description": "Stream-based MQTT broker",
@@ -41,3 +41,3 @@ "main": "aedes.js",
   "devDependencies": {
-    "@types/node": "^8.10.25",
+    "@types/node": "^8.10.38",
     "compute-mode": "^1.0.0",
@@ -47,13 +47,13 @@ "concat-stream": "^1.6.2",
     "coveralls": "^3.0.2",
-    "duplexify": "^3.6.0",
+    "duplexify": "^3.6.1",
     "faucet": "0.0.1",
     "istanbul": "^0.4.1",
-    "mqtt": "^2.18.3",
-    "mqtt-connection": "^3.2.0",
+    "mqtt": "^2.18.8",
+    "mqtt-connection": "^4.0.0",
     "pre-commit": "^1.0.10",
-    "standard": "^11.0.0",
+    "standard": "^12.0.0",
     "tape": "^4.9.1",
     "tslint": "^5.11.0",
-    "tslint-config-standard": "^7.1.0",
-    "typescript": "^2.9.2",
+    "tslint-config-standard": "^8.0.1",
+    "typescript": "^3.1.6",
     "websocket-stream": "^5.1.2"
@@ -63,3 +63,3 @@ },
     "aedes-packet": "^1.0.0",
-    "aedes-persistence": "^5.1.1",
+    "aedes-persistence": "^6.0.0",
     "bulk-write-stream": "^1.1.4",
@@ -72,9 +72,8 @@ "end-of-stream": "^1.4.1",
     "mqemitter": "^2.2.0",
-    "mqtt-packet": "^5.6.0",
+    "mqtt-packet": "^6.0.0",
     "pump": "^3.0.0",
     "retimer": "^1.1.0",
     "reusify": "^1.0.4",
-    "safe-buffer": "^5.1.2",
-    "shortid": "^2.2.12",
-    "through2": "^2.0.0",
+    "shortid": "^2.2.14",
+    "through2": "^3.0.0",
     "uuid": "^3.3.2",
@@ -81,0 +80,0 @@ "xtend": "^4.0.1"

README.md

@@ -98,2 +98,4 @@ # Aedes  [![Build Status](https://travis-ci.org/mcollina/aedes.svg?branch=master)](https://travis-ci.org/mcollina/aedes) [![Coverage Status](https://coveralls.io/repos/mcollina/aedes/badge.svg?branch=master&service=github)](https://coveralls.io/github/mcollina/aedes?branch=master)
   packet to arrive, defaults to `30000` milliseconds
+* `id`: id used to identify this broker instance in `$SYS` messages,
+  defaults to `shortid()`
 * `authenticate`: function used to authenticate clients, see
@@ -100,0 +102,0 @@ [instance.authenticate()](#authenticate)

test/basic.js

@@ -717,1 +717,13 @@ 'use strict'
 })
+
+test('id option', function (t) {
+  t.plan(2)
+
+  var broker1 = aedes()
+  setup(broker1)
+  t.ok(broker1.id, 'broker gets random id when id option not set')
+
+  var broker2 = aedes({ id: 'abc' })
+  setup(broker2)
+  t.equal(broker2.id, 'abc', 'broker id equals id option when set')
+})

No alert changes

Improved metrics

Total package byte prevSize

151437

increased by0.04%

Dependency count

17

decreased by-5.56%

Lines of code

4965

increased by0.02%

Number of lines in readme file

410

increased by0.49%

Dependency changes

• + Addedaedes-persistence@6.0.0(transitive)

• + Addedbase64-js@1.5.1(transitive)

• + Addedbl@4.1.0(transitive)

• + Addedbuffer@5.7.1(transitive)

• + Addeddebug@4.3.5(transitive)

• + Addedieee754@1.2.1(transitive)

• + Addedmqtt-packet@6.10.0(transitive)

• + Addedms@2.1.2(transitive)

• + Addedqlobber@3.1.0(transitive)

• + Addedreadable-stream@3.6.2(transitive)

• + Addedstring_decoder@1.3.0(transitive)

• + Addedthrough2@3.0.2(transitive)

• - Removedsafe-buffer@^5.1.2

• - Removedaedes-persistence@5.1.1(transitive)

• - Removedbl@1.2.3(transitive)

• - Removedmqtt-packet@5.6.1(transitive)

• - Removedthrough2@2.0.5(transitive)

• Updatedaedes-persistence@^6.0.0

• Updatedmqtt-packet@^6.0.0

• Updatedshortid@^2.2.14

• Updatedthrough2@^3.0.0