tobru
/
pylokid
1
0
Fork 0
Code Pull Requests Releases Activity

mqtt topics update for client compat

This commit is contained in:
Tobias Brunner 2018-01-18 22:45:14 +01:00
parent 5d178e575a
commit ed312b91fb
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
library/mqtt.py
View File

@ -29,12 +29,11 @@ class MQTTClient:
def send_message(self, f_type, f_id, pdf_data=None, pdf_file=None):
""" Publish a message over MQTT """
topic = "{0}/{1}/".format(self.base_topic, f_id)
self.logger.info('[%s] Publishing information on MQTT topic %s*', f_id, topic)
if f_type == 'Einsatzausdruck_FW':
try:
self.mqtt_client.publish(topic + 'typ', 'Einsatzauftrag')
topic = "{0}/Einsatzausdruck_FW/{1}/".format(self.base_topic, f_id)
self.mqtt_client.publish(topic + 'json', json.dumps(pdf_data))
## Publish the PDF blob
@ -44,4 +43,5 @@ class MQTTClient:
except IndexError as err:
self.logger.info('[%s] Cannot publish information: %s', f_id, err)
elif f_type == 'Einsatzprotokoll':
self.mqtt_client.publish(topic + 'typ', 'Einsatzprotokoll')
topic = "{0}/Einsatzprotokoll/{1}/".format(self.base_topic, f_id)
self.mqtt_client.publish(topic + 'json', '{}')