From f57bddfe4a80a55df26a82a4bec91ccb00937e18 Mon Sep 17 00:00:00 2001 From: Eric Callahan Date: Sun, 12 Dec 2021 15:42:38 -0500 Subject: [PATCH] mqtt: send connect and disconnect events Signed-off-by: Eric Callahan --- moonraker/components/mqtt.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/moonraker/components/mqtt.py b/moonraker/components/mqtt.py index 65c3e32..a31abee 100644 --- a/moonraker/components/mqtt.py +++ b/moonraker/components/mqtt.py @@ -301,6 +301,7 @@ class MQTTClient(APITransport, Subscribable): BrokerAckLogger(topics, "subscribe")) self.pending_acks[msg_id] = sub_fut self.connect_evt.set() + self.server.send_event("mqtt:connected") else: if isinstance(reason_code, int): err_str = paho_mqtt.connack_string(reason_code) @@ -323,6 +324,7 @@ class MQTTClient(APITransport, Subscribable): f"{paho_mqtt.error_string(reason_code)}") if self.reconnect_task is None: self.reconnect_task = asyncio.create_task(self._do_reconnect()) + self.server.send_event("mqtt:disconnected") self.connect_evt.clear() def _on_publish(self,