mirror of
https://github.com/liberatedsystems/openCom-Companion.git
synced 2025-02-22 09:19:51 +01:00
Set default stale time for LXMF PN sensor, cleanup
This commit is contained in:
parent
be6a1de135
commit
cc722dec9f
@ -39,6 +39,7 @@ class MQTT():
|
|||||||
if len(self.waiting_msgs) > 0:
|
if len(self.waiting_msgs) > 0:
|
||||||
RNS.log(f"Processing {len(self.waiting_msgs)} MQTT messages", RNS.LOG_DEBUG)
|
RNS.log(f"Processing {len(self.waiting_msgs)} MQTT messages", RNS.LOG_DEBUG)
|
||||||
self.process_queue()
|
self.process_queue()
|
||||||
|
RNS.log("All MQTT messages processed", RNS.LOG_DEBUG)
|
||||||
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
RNS.log("An error occurred while running MQTT scheduler jobs: {e}", RNS.LOG_ERROR)
|
RNS.log("An error occurred while running MQTT scheduler jobs: {e}", RNS.LOG_ERROR)
|
||||||
|
@ -2508,7 +2508,7 @@ class RNSTransport(Sensor):
|
|||||||
|
|
||||||
class LXMFPropagation(Sensor):
|
class LXMFPropagation(Sensor):
|
||||||
SID = Sensor.SID_LXMF_PROPAGATION
|
SID = Sensor.SID_LXMF_PROPAGATION
|
||||||
STALE_TIME = 5
|
STALE_TIME = 120
|
||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
self.identity = None
|
self.identity = None
|
||||||
@ -2578,9 +2578,6 @@ class LXMFPropagation(Sensor):
|
|||||||
if self.data == None:
|
if self.data == None:
|
||||||
return None
|
return None
|
||||||
|
|
||||||
from rich.pretty import pprint
|
|
||||||
pprint(self.data["peers"])
|
|
||||||
|
|
||||||
try:
|
try:
|
||||||
d = self.data
|
d = self.data
|
||||||
values = {
|
values = {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user