mhop/tuya-mqtt
1
0
Fork 0
mirror of https://github.com/lehanspb/tuya-mqtt.git synced 2025-12-16 17:54:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

should fix #11

Browse Source
This commit is contained in:
KarstenSiedentopp
2019-01-24 17:59:04 +01:00
parent 2c7ed22e14
commit c38b7e9087
2 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
config.json.sample
View File

@@ -3,5 +3,6 @@
"port": 1883,
"topic": "tuya/",
"mqtt_user": "",
"mqtt_pass": ""
"mqtt_pass": "",
"qos": 2
}

21
tuya-mqtt.js
View File

@@ -36,7 +36,9 @@ mqtt_client.on('connect', function (err) {
debugMqtt("Verbindung mit MQTT-Server hergestellt");
connected = true;
var topic = CONFIG.topic + '#';
mqtt_client.subscribe(topic);
mqtt_client.subscribe(topic, {
qos: CONFIG.qos
});
});
mqtt_client.on("reconnect", function (error) {
@@ -76,7 +78,7 @@ mqtt_client.on('message', function (topic, message) {
if (exec == "command") {
var status = topic[6];
if ( status == null ) {
if (status == null) {
device.onoff(message);
} else {
device.onoff(status);
@@ -109,7 +111,7 @@ function publishStatus(device, status) {
var topic = CONFIG.topic + type + "/" + tuyaID + "/" + tuyaKey + "/" + tuyaIP + "/state";
mqtt_client.publish(topic, status, {
retain: true,
qos: 2
qos: CONFIG.qos
});
debugTuya("mqtt status updated to:" + topic + " -> " + status);
} else {
@@ -140,7 +142,7 @@ function publishDPS(device, dps) {
debugTuya("mqtt dps updated to:" + topic + " -> ", data);
mqtt_client.publish(topic, data, {
retain: true,
qos: 2
qos: CONFIG.qos
});
Object.keys(dps).forEach(function (key) {
@@ -149,7 +151,7 @@ function publishDPS(device, dps) {
debugTuya("mqtt dps updated to:" + topic + " -> dps[" + key + "]", data);
mqtt_client.publish(topic, data, {
retain: true,
qos: 2
qos: CONFIG.qos
});
});
} else {
@@ -169,10 +171,9 @@ TuyaDevice.onAll('data', function (data) {
try {
debugTuya('Data from device ' + this.type + ' :', data);
var status = data.dps['1'];
if (this.type == "lightbulb" && status == undefined) {
status = true;
if (status != undefined) {
publishStatus(this, bmap(status));
}
publishStatus(this, bmap(status));
publishDPS(this, data.dps);
} catch (e) {
debugError(e);
@@ -217,5 +218,5 @@ var tester = new MQTT_Tester();
*/
function onExit() {
TuyaDevice.disconnectAll();
if(tester) tester.destroy();
};
if (tester) tester.destroy();
};