frodovdr/node-red
1
0
Fork 0
mirror of https://github.com/node-red/node-red.git synced 2025-12-26 23:26:46 +01:00
Code Issues Packages Projects Releases Wiki Activity

Slight tidy to MQTT - move to fa icons - use built in close method.

Browse Source
This commit is contained in:
Dave C-J
2014-07-21 20:29:10 +01:00
parent d1300c0632
commit 0b308deb79
2 changed files with 25 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
nodes/core/io/10-mqtt.js
View File

@@ -1,5 +1,5 @@
/**
* Copyright 2013 IBM Corp.
* Copyright 2013,2014 IBM Corp.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -17,7 +17,6 @@
module.exports = function(RED) {
"use strict";
var connectionPool = require("./lib/mqttConnectionPool");
var util = require("util");
function MQTTBrokerNode(n) {
RED.nodes.createNode(this,n);
@@ -62,55 +61,48 @@ module.exports = function(RED) {
} else {
this.error("missing broker configuration");
}
this.on('close', function() {
if (this.client) {
this.client.disconnect();
}
});
}
RED.nodes.registerType("mqtt in",MQTTInNode);
MQTTInNode.prototype.close = function() {
if (this.client) {
this.client.disconnect();
}
}
function MQTTOutNode(n) {
RED.nodes.createNode(this,n);
this.topic = n.topic;
this.broker = n.broker;
this.brokerConfig = RED.nodes.getNode(this.broker);
if (this.brokerConfig) {
this.status({fill:"red",shape:"ring",text:"disconnected"},true);
this.client = connectionPool.get(this.brokerConfig.broker,this.brokerConfig.port,this.brokerConfig.clientid,this.brokerConfig.username,this.brokerConfig.password);
var node = this;
this.on("input",function(msg) {
if (msg != null) {
if (this.topic) {
msg.topic = this.topic;
if (node.topic) {
msg.topic = node.topic;
}
this.client.publish(msg);
}
});
var node = this;
this.client.on("connectionlost",function() {
node.status({fill:"red",shape:"ring",text:"disconnected"});
});
this.client.on("connect",function() {
node.status({fill:"green",shape:"dot",text:"connected"});
});
this.client.connect();
} else {
this.error("missing broker configuration");
}
this.on('close', function() {
if (this.client) {
this.client.disconnect();
}
});
}
RED.nodes.registerType("mqtt out",MQTTOutNode);
MQTTOutNode.prototype.close = function() {
if (this.client) {
this.client.disconnect();
}
}
}