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

global topic_prefix fix try 2

Browse Source
This commit is contained in:
unconfigured
2018-12-20 12:33:29 +01:00
parent fabc48784b
commit f9f95a756b
2 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
workers_manager.py
+4 -2
View File
@@ -102,6 +102,8 @@ class WorkersManager:
for package in package_names:
pip_main(['install', '-q', package])
def _on_command_wrapper(self, worker_obj, client, _, c):
def _on_command_wrapper(self, worker_obj, client, userdata, c):
_LOGGER.debug("on command wrapper for with %s: %s", c.topic, c.payload)
self._queue_command(self.Command(worker_obj.on_command, [c.topic, c.payload]))
global_topic_prefix = userdata['global_topic_prefix']
topic = c.topic[len(global_topic_prefix+'/'):] if global_topic_prefix is not None else c.topic
self._queue_command(self.Command(worker_obj.on_command, [topic, c.payload]))