MySmartHome/bt-mqtt-gateway
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix thermostat commands

Browse Source
This commit is contained in:
zewelor
2017-11-29 10:23:21 +01:00
parent ddc224f389
commit 1bc7b1f92b
3 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
config.yaml.example
+2 -2
View File
@@ -7,6 +7,6 @@ workers:
args: args:
devices: devices:
bedroom: 00:11:22:33:44:55 bedroom: 00:11:22:33:44:55
topic_prefix: thermostat topic_prefix: thermostat
topic_subscription: thermostat topic_subscription: thermostat/+/+/set
update_interval: 60 update_interval: 60
workers/thermostat.py
+1 -4
View File
@@ -64,7 +64,7 @@ class ThermostatWorker(BaseWorker):
return ret return ret
def on_command(self, topic, value): def on_command(self, topic, value):
_, device_name, method = topic.split('/') _, device_name, method, _ = topic.split('/')
thermostat = self.devices[device_name] thermostat = self.devices[device_name]
if method == STATE_AWAY: if method == STATE_AWAY:
@@ -94,6 +94,3 @@ class ThermostatWorker(BaseWorker):
def device_for(self, mac): def device_for(self, mac):
return eq3bt.Thermostat(mac) return eq3bt.Thermostat(mac)
def format_topic(self, device, attr):
return '/'.join([device, attr])
workers_manager.py
+2 -2
View File
@@ -44,9 +44,9 @@ class WorkersManager:
) )
if 'topic_subscription' in worker_config: if 'topic_subscription' in worker_config:
_LOGGER.debug("Subscribing to: %s" % worker_config['topic_subscription'] + '/#') _LOGGER.debug("Subscribing to: %s" % worker_config['topic_subscription'])
mqtt_callbacks.append(( mqtt_callbacks.append((
worker_config['topic_subscription'] + '/#', worker_config['topic_subscription'],
lambda client, _ , c: _WORKERS_QUEUE.put(cls.Command(worker_obj.on_command, [c.topic, c.payload])) lambda client, _ , c: _WORKERS_QUEUE.put(cls.Command(worker_obj.on_command, [c.topic, c.payload]))
)) ))