Fix mqtt prefix handling on thermostat worker
This commit is contained in:
@@ -59,6 +59,8 @@ class MqttClient:
|
|||||||
self.mqttc.connect(self.hostname, port=self.port)
|
self.mqttc.connect(self.hostname, port=self.port)
|
||||||
|
|
||||||
for topic, callback in callbacks:
|
for topic, callback in callbacks:
|
||||||
|
if self.topic_prefix is not None:
|
||||||
|
topic = "{}/{}".format(self.topic_prefix, topic)
|
||||||
self.mqttc.message_callback_add(topic, callback)
|
self.mqttc.message_callback_add(topic, callback)
|
||||||
self.mqttc.subscribe(topic)
|
self.mqttc.subscribe(topic)
|
||||||
|
|
||||||
|
|||||||
@@ -71,7 +71,9 @@ class ThermostatWorker(BaseWorker):
|
|||||||
return ret
|
return ret
|
||||||
|
|
||||||
def on_command(self, topic, value):
|
def on_command(self, topic, value):
|
||||||
_, device_name, method, _ = topic.split('/')
|
if self.topic_prefix is not None:
|
||||||
|
_, device_name, method, _ = topic[len(self.topic_prefix+"/"):].split('/')
|
||||||
|
|
||||||
thermostat = self.devices[device_name]
|
thermostat = self.devices[device_name]
|
||||||
|
|
||||||
value = value.decode('utf-8')
|
value = value.decode('utf-8')
|
||||||
|
|||||||
Reference in New Issue
Block a user