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

added all dps values to mqtt topic

Browse Source
This commit is contained in:
KarstenSiedentopp
2018-12-19 18:15:34 +01:00
parent c78063a15b
commit f66d41bfc3
1 changed files with 38 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
tuya-mqtt.js
View File

@@ -87,7 +87,7 @@ function publishStatus(device, status) {
var tuyaIP = device.options.ip;
if (tuyaID != undefined && tuyaKey != undefined && tuyaIP != undefined) {
var topic = "tuya/" + type + "/" + tuyaID + "/" + tuyaKey + "/" + tuyaIP + "/state";
var topic = CONFIG.topic + type + "/" + tuyaID + "/" + tuyaKey + "/" + tuyaIP + "/state";
mqtt_client.publish(topic, status, {
retain: true,
qos: 2
@@ -102,6 +102,42 @@ function publishStatus(device, status) {
}
}
/**
* publish all dps-values to topic
* @param {TuyaDevice} device
* @param {Object} dps
*/
function publishDPS(device, dps) {
if (mqtt_client.connected == true) {
try {
var type = device.type;
var tuyaID = device.options.id;
var tuyaKey = device.options.key;
var tuyaIP = device.options.ip;
if (tuyaID != undefined && tuyaKey != undefined && tuyaIP != undefined) {
var topic = CONFIG.topic + type + "/" + tuyaID + "/" + tuyaKey + "/" + tuyaIP + "/dps";
mqtt_client.publish(topic, JSON.stringify(dps), {
retain: true,
qos: 2
});
Object.keys(dps).forEach(function (key) {
var topic = CONFIG.topic + type + "/" + tuyaID + "/" + tuyaKey + "/" + tuyaIP + "/dps/" + key;
mqtt_client.publish(topic, dps[key], {
retain: true,
qos: 2
});
});
debug("mqtt dps updated to:" + topic + " -> " + dps);
} else {
debug("mqtt dps not updated");
}
} catch (e) {
debug(e);
}
}
}
/**
* event fires if TuyaDevice sends data
* @see TuyAPI (https://github.com/codetheweb/tuyapi)
@@ -113,6 +149,7 @@ TuyaDevice.onAll('data', function (data) {
status = true;
}
publishStatus(this, bmap(status));
publishDPS(this, data.dps);
});
/**