This commit is contained in:
Mark Qvist 2025-01-26 14:12:13 +01:00
parent 120d29db75
commit c873b9fa33
14 changed files with 9 additions and 6595 deletions

View file

@ -3228,9 +3228,10 @@ class SidebandCore():
if self.config["telemetry_enabled"] == True:
self.update_telemeter_config()
if self.telemeter != None:
def mqtt_job():
self.mqtt_handle_telemetry(self.lxmf_destination.hash, self.telemeter.packed())
threading.Thread(target=mqtt_job, daemon=True).start()
if self.config["telemetry_to_mqtt"]:
def mqtt_job():
self.mqtt_handle_telemetry(self.lxmf_destination.hash, self.telemeter.packed())
threading.Thread(target=mqtt_job, daemon=True).start()
return self.telemeter.read_all()
else:
return {}