3diy
/
moonraker
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

mqtt: send connect and disconnect events 

Signed-off-by:  Eric Callahan <arksine.code@gmail.com>
This commit is contained in:
Eric Callahan 2021-12-12 15:42:38 -05:00
parent 3ac8f8cd81
commit f57bddfe4a
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
moonraker/components/mqtt.py
View File

@ -301,6 +301,7 @@ class MQTTClient(APITransport, Subscribable):
BrokerAckLogger(topics, "subscribe")) BrokerAckLogger(topics, "subscribe"))
self.pending_acks[msg_id] = sub_fut self.pending_acks[msg_id] = sub_fut
self.connect_evt.set() self.connect_evt.set()
self.server.send_event("mqtt:connected")
else: else:
if isinstance(reason_code, int): if isinstance(reason_code, int):
err_str = paho_mqtt.connack_string(reason_code) err_str = paho_mqtt.connack_string(reason_code)
@ -323,6 +324,7 @@ class MQTTClient(APITransport, Subscribable):
f"{paho_mqtt.error_string(reason_code)}") f"{paho_mqtt.error_string(reason_code)}")
if self.reconnect_task is None: if self.reconnect_task is None:
self.reconnect_task = asyncio.create_task(self._do_reconnect()) self.reconnect_task = asyncio.create_task(self._do_reconnect())
self.server.send_event("mqtt:disconnected")
self.connect_evt.clear() self.connect_evt.clear()
def _on_publish(self, def _on_publish(self,