Mirrors
/
Sideband
mirror of https://github.com/markqvist/Sideband.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Updated telemetry change processing method

This commit is contained in:
Mark Qvist 2024-07-20 18:21:17 +02:00
parent 0d38fa7ef7
commit 51523a216d
2 changed files with 37 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
sbapp/main.py
View File

@ -1,6 +1,6 @@
__debug_build__ = False
__disable_shaders__ = False
__version__ = "0.9.1"
__version__ = "0.9.2"
__variant__ = "beta"
import sys

32
sbapp/sideband/core.py
View File

@ -13,6 +13,7 @@ import RNS.Interfaces.Interface as Interface
import multiprocessing.connection
from copy import deepcopy
from threading import Lock
from .res import sideband_fb_data
from .sense import Telemeter, Commands
@ -2592,27 +2593,36 @@ class SidebandCore():
def update_telemetry(self):
try:
try:
latest_telemetry = deepcopy(self.latest_telemetry)
except:
latest_telemetry = None
telemetry = self.get_telemetry()
packed_telemetry = self.get_packed_telemetry()
telemetry_changed = False
if telemetry != None and packed_telemetry != None:
if self.latest_telemetry == None or len(telemetry) != len(self.latest_telemetry):
if latest_telemetry == None or len(telemetry) != len(latest_telemetry):
telemetry_changed = True
if latest_telemetry != None:
if not telemetry_changed:
for sn in telemetry:
if telemetry_changed:
break
if sn != "time":
if sn in self.latest_telemetry:
if telemetry[sn] != self.latest_telemetry[sn]:
if sn in latest_telemetry:
if telemetry[sn] != latest_telemetry[sn]:
telemetry_changed = True
else:
telemetry_changed = True
if self.latest_telemetry != None:
for sn in self.latest_telemetry:
if not telemetry_changed:
for sn in latest_telemetry:
if telemetry_changed:
break
@ -2626,6 +2636,11 @@ class SidebandCore():
self.latest_packed_telemetry = packed_telemetry
self.setstate("app.flags.last_telemetry", time.time())
# TODO: Remove
# tbt = Telemeter.from_packed(packed_telemetry)
# tbts = tbt.read_all()["time"]["utc"]
# RNS.log("TELEMETRY CHANGED, TIMEBASE IS NOW "+str(tbts))
if self.is_client:
try:
self.service_set_latest_telemetry(self.latest_telemetry, self.latest_packed_telemetry)
@ -3523,7 +3538,7 @@ class SidebandCore():
try:
telemeter = Telemeter.from_packed(message.fields[LXMF.FIELD_TELEMETRY])
telemetry_timebase = telemeter.read_all()["time"]["utc"]
RNS.log("Setting last successul telemetry timebase for "+RNS.prettyhexrep(message.destination_hash)+" to "+str(telemetry_timebase))
RNS.log("Setting last successul telemetry timebase for "+RNS.prettyhexrep(message.destination_hash)+" to "+str(telemetry_timebase), RNS.LOG_DEBUG)
self.setpersistent(f"telemetry.{RNS.hexrep(message.destination_hash, delimit=False)}.last_send_success_timebase", telemetry_timebase)
except Exception as e:
RNS.log("Error while setting last successul telemetry timebase for "+RNS.prettyhexrep(message.destination_hash), RNS.LOG_DEBUG)
@ -3536,10 +3551,11 @@ class SidebandCore():
if send_telemetry and self.latest_packed_telemetry != None:
telemeter = Telemeter.from_packed(self.latest_packed_telemetry)
telemetry_timebase = telemeter.read_all()["time"]["utc"]
if telemetry_timebase > (self.getpersistent(f"telemetry.{RNS.hexrep(context_dest, delimit=False)}.last_send_success_timebase") or 0):
last_success_tb = (self.getpersistent(f"telemetry.{RNS.hexrep(context_dest, delimit=False)}.last_send_success_timebase") or 0)
if telemetry_timebase > last_success_tb:
RNS.log("Embedding own telemetry in message since current telemetry is newer than latest successful timebase", RNS.LOG_DEBUG)
else:
RNS.log("Not embedding own telemetry in message since current telemetry is not newer than latest successful timebase", RNS.LOG_DEBUG)
RNS.log("Not embedding own telemetry in message since current telemetry timebase ("+str(telemetry_timebase)+") is not newer than latest successful timebase ("+str(last_success_tb)+")", RNS.LOG_DEBUG)
send_telemetry = False
send_appearance = False
if signal_already_sent: