diff --git a/devices/tuya-device.js b/devices/tuya-device.js index c92adda..9892c64 100644 --- a/devices/tuya-device.js +++ b/devices/tuya-device.js @@ -11,6 +11,8 @@ class TuyaDevice { this.config = deviceInfo.configDevice this.mqttClient = deviceInfo.mqttClient this.topic = deviceInfo.topic + this.qos = deviceInfo.qos + this.retain = deviceInfo.retain // Build TuyAPI device options from device config info this.options = { @@ -634,8 +636,13 @@ class TuyaDevice { // Publish MQTT publishMqtt(topic, message, isDebug) { + var options = { + qos: this.qos, + retain: this.retain + } + if (isDebug) { debugState(topic, message) } - this.mqttClient.publish(topic, message, { qos: 1 }); + this.mqttClient.publish(topic, message, options); } } diff --git a/tuya-mqtt.js b/tuya-mqtt.js index 47a6dde..087ab26 100644 --- a/tuya-mqtt.js +++ b/tuya-mqtt.js @@ -35,7 +35,9 @@ function getDevice(configDevice, mqttClient) { const deviceInfo = { configDevice: configDevice, mqttClient: mqttClient, - topic: CONFIG.topic + topic: CONFIG.topic, + qos: CONFIG.qos, + retain: CONFIG.retain } switch (configDevice.type) { case 'SimpleSwitch':