Skip to content
Snippets Groups Projects
Commit 193fdf1e authored by Torben Petersen's avatar Torben Petersen
Browse files

Started implementing the sending of messaged towards the node via mqtt

parent 4d73703e
No related branches found
No related tags found
No related merge requests found
......@@ -56,6 +56,11 @@ class DefaultThread(ReaderThread):
self.usb_device = usb_device
self.serial_number = serial_number
self.logger = Logger( __name__+'.'+self.__class__.__name__ )
tx_topic = self.hotplug_module.mqtt_topic_prefix + self.serial_number + "/tx"
self.hotplug_module.logger.debug("Subscribed to topic {}".format(tx_topic))
self.hotplug_module.mqtt_client.subscribe(tx_topic, qos=2)
super(DefaultThread, self).__init__(serial, protocol)
def run(self):
......@@ -116,6 +121,8 @@ class Hotplug(Module):
handle = hotplug.register_callback(events, flags, 0x0403, 0x6001, dev_class, self.hotplug_callback, {'baud': 19200})
self.handles.append( handle )
self.mqtt_client.on_message = self.on_message
return
#TODO
if hasattr(node_config, 'serial'):
......@@ -135,6 +142,14 @@ class Hotplug(Module):
#product_id = 0x204b
#handle = hotplug.register_callback(events, flags, vendor_id, product_id, dev_class, self.hotplug_callback, user_data)
def on_message(self, client, userdata, msg):
node_id = msg.topic.split('/')[2]
self.logger.debug("Got message for {}".format(node_id))
self.logger.debug("Length of devices: {}".format(len(self.devices)))
for addr, node_device in self.devices.items():
self.logger.debug("Checking node_device with serial number {}".format(node_device.serial_number))
if node_device.serial_number == node_id:
self.logger.debug("Found device, forwarding message")
#def send(self, send_dict):
# self.callback_send(send_dict)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment