From 4eb5f540c1937a070066590bb0d8730a97a40e2a Mon Sep 17 00:00:00 2001 From: Github GPG acces Date: Sun, 13 Oct 2024 10:45:23 +0200 Subject: [PATCH 1/2] Add retain to availability topic Added the forgotten topic retain, but important for this kind of data --- glances/exports/glances_mqtt/__init__.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/glances/exports/glances_mqtt/__init__.py b/glances/exports/glances_mqtt/__init__.py index 63bce38d..471404b3 100755 --- a/glances/exports/glances_mqtt/__init__.py +++ b/glances/exports/glances_mqtt/__init__.py @@ -82,15 +82,15 @@ class Export(GlancesExport): def on_connect(client, userdata, flags, reason_code, properties): """Action to perform when connecting.""" - self.client.publish(topic='/'.join([self.topic, self.devicename, "availability"]), payload="Online") + self.client.publish(topic='/'.join([self.topic, self.devicename, "availability"]), payload="online", retain=True) def on_disconnect(client, userdata, flags, reason_code, properties): """Action to perform when the connection is over.""" - self.client.publish(topic='/'.join([self.topic, self.devicename, "availability"]), payload="Offline") + self.client.publish(topic='/'.join([self.topic, self.devicename, "availability"]), payload="offline", retain=True) client.on_connect = on_connect client.on_disconnect = on_disconnect - client.will_set(topic='/'.join([self.topic, self.devicename, "availability"]), payload="Offline") + client.will_set(topic='/'.join([self.topic, self.devicename, "availability"]), payload="offline", retain=True) client.username_pw_set(username=self.user, password=self.password) if self.tls: From 252f593bcc19bc136e9459a93739b1c2eddd3dbf Mon Sep 17 00:00:00 2001 From: Github GPG acces Date: Sun, 13 Oct 2024 11:06:03 +0200 Subject: [PATCH 2/2] reformatted for pass ruff test --- glances/exports/glances_mqtt/__init__.py | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/glances/exports/glances_mqtt/__init__.py b/glances/exports/glances_mqtt/__init__.py index 471404b3..dd32d6ef 100755 --- a/glances/exports/glances_mqtt/__init__.py +++ b/glances/exports/glances_mqtt/__init__.py @@ -82,15 +82,24 @@ class Export(GlancesExport): def on_connect(client, userdata, flags, reason_code, properties): """Action to perform when connecting.""" - self.client.publish(topic='/'.join([self.topic, self.devicename, "availability"]), payload="online", retain=True) + self.client.publish( + topic='/'.join([self.topic, self.devicename, "availability"]), + payload="online", + retain=True) def on_disconnect(client, userdata, flags, reason_code, properties): """Action to perform when the connection is over.""" - self.client.publish(topic='/'.join([self.topic, self.devicename, "availability"]), payload="offline", retain=True) + self.client.publish( + topic='/'.join([self.topic, self.devicename, "availability"]), + payload="offline", + retain=True) client.on_connect = on_connect client.on_disconnect = on_disconnect - client.will_set(topic='/'.join([self.topic, self.devicename, "availability"]), payload="offline", retain=True) + client.will_set( + topic='/'.join([self.topic, self.devicename, "availability"]), + payload="offline", + retain=True) client.username_pw_set(username=self.user, password=self.password) if self.tls: