diff --git a/package.json b/package.json index 32f08ba..8bf235c 100644 --- a/package.json +++ b/package.json @@ -3,7 +3,7 @@ "version": "0.2.4", "description": "MQTT Broker server on Node-RED", "dependencies": { - "mosca": "^2.7.0" + "mosca": "^2.8.0" }, "license": "MIT", "repository": { @@ -16,7 +16,7 @@ "mqtt" ], "scripts": { - "test": "mocha test/**/*_spec.js" + "test": "npm link node-red & mocha test/**/*_spec.js" }, "node-red": { "nodes": { diff --git a/test/mosca_spec.js b/test/mosca_spec.js index daccc9e..5acd1f6 100644 --- a/test/mosca_spec.js +++ b/test/mosca_spec.js @@ -1,8 +1,6 @@ -var should = require('should'); var helper = require('node-red-node-test-helper'); var moscaNode = require('../mosca.js'); var mqttNode = require('../node_modules/node-red/nodes/core/io/10-mqtt.js'); -var injectNode = require('../node_modules/node-red/nodes/core/core/20-inject.js'); describe('MQTT Broker Node', function () { @@ -36,7 +34,7 @@ describe('MQTT Broker Node', function () { var timestamp = new Date(); timestamp.setSeconds(timestamp.getSeconds() + 1); - helper.load([injectNode, moscaNode, mqttNode], [{ + helper.load([moscaNode, mqttNode], [{ id: 'n1', type: 'mosca in', mqtt_port: '1883', @@ -64,7 +62,6 @@ describe('MQTT Broker Node', function () { } ], function () { - var n1 = helper.getNode('n1'); var n2 = helper.getNode('n2'); n2.on('input', function (msg) { msg.should.have.property('topic', 'clientConnected'); @@ -78,7 +75,7 @@ describe('MQTT Broker Node', function () { var timestamp = new Date(); timestamp.setSeconds(timestamp.getSeconds() + 1); - helper.load([injectNode, moscaNode, mqttNode], [{ + helper.load([moscaNode, mqttNode], [{ id: 'n1', type: 'mosca in', mqtt_port: '1883', @@ -127,25 +124,23 @@ describe('MQTT Broker Node', function () { name: 'Broker', broker: 'localhost', port: '1884' - }, + } ], function () { var i = 0; - var n1 = helper.getNode('n1'); var n2 = helper.getNode('n2'); n2.on('input', function (msg) { msg.should.have.property('topic', 'clientConnected'); i++; - if (i == 2) { + if (i === 2) { done(); } }); - var n11 = helper.getNode('n11'); var n12 = helper.getNode('n12'); n12.on('input', function (msg) { msg.should.have.property('topic', 'clientConnected'); i++; - if (i == 2) { + if (i === 2) { done(); } });