From cc722dec9f7dd84fa96a116d6478f8fca82d16dc Mon Sep 17 00:00:00 2001 From: Mark Qvist Date: Fri, 24 Jan 2025 22:32:57 +0100 Subject: [PATCH] Set default stale time for LXMF PN sensor, cleanup --- sbapp/sideband/mqtt.py | 1 + sbapp/sideband/sense.py | 5 +---- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/sbapp/sideband/mqtt.py b/sbapp/sideband/mqtt.py index 962f6b4..6131d1c 100644 --- a/sbapp/sideband/mqtt.py +++ b/sbapp/sideband/mqtt.py @@ -39,6 +39,7 @@ class MQTT(): if len(self.waiting_msgs) > 0: RNS.log(f"Processing {len(self.waiting_msgs)} MQTT messages", RNS.LOG_DEBUG) self.process_queue() + RNS.log("All MQTT messages processed", RNS.LOG_DEBUG) except Exception as e: RNS.log("An error occurred while running MQTT scheduler jobs: {e}", RNS.LOG_ERROR) diff --git a/sbapp/sideband/sense.py b/sbapp/sideband/sense.py index db18db2..4b700fb 100644 --- a/sbapp/sideband/sense.py +++ b/sbapp/sideband/sense.py @@ -2508,7 +2508,7 @@ class RNSTransport(Sensor): class LXMFPropagation(Sensor): SID = Sensor.SID_LXMF_PROPAGATION - STALE_TIME = 5 + STALE_TIME = 120 def __init__(self): self.identity = None @@ -2578,9 +2578,6 @@ class LXMFPropagation(Sensor): if self.data == None: return None - from rich.pretty import pprint - pprint(self.data["peers"]) - try: d = self.data values = {