jacob.eva/Sideband_CE
1
0
Fork 0
mirror of https://github.com/liberatedsystems/Sideband_CE.git synced 2024-09-03 04:13:27 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added radio modem support

Browse Source
This commit is contained in:
Mark Qvist 2022-10-15 14:55:47 +02:00
parent 634097e048
commit 1d6a68d46d
1 changed files with 72 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
sbapp/sideband/core.py
View File

@ -151,7 +151,6 @@ class SidebandCore():
RNS.Transport.register_announce_handler(self) RNS.Transport.register_announce_handler(self)
RNS.Transport.register_announce_handler(self.propagation_detector) RNS.Transport.register_announce_handler(self.propagation_detector)
def __init_config(self): def __init_config(self):
RNS.log("Creating new Sideband configuration...") RNS.log("Creating new Sideband configuration...")
if os.path.isfile(self.identity_path): if os.path.isfile(self.identity_path):
@ -208,10 +207,16 @@ class SidebandCore():
self.config["hw_rnode_tx_power"] = 0 self.config["hw_rnode_tx_power"] = 0
self.config["hw_rnode_beaconinterval"] = None self.config["hw_rnode_beaconinterval"] = None
self.config["hw_rnode_beacondata"] = None self.config["hw_rnode_beacondata"] = None
self.config["hw_modem_baudrate"] = 57600
self.config["hw_modem_databits"] = 8
self.config["hw_modem_stopbits"] = 1
self.config["hw_modem_parity"] = "none"
self.config["hw_modem_preamble"] = 150 self.config["hw_modem_preamble"] = 150
self.config["hw_modem_tail"] = 20 self.config["hw_modem_tail"] = 20
self.config["hw_modem_persistence"] = 220 self.config["hw_modem_persistence"] = 220
self.config["hw_modem_slottime"] = 20 self.config["hw_modem_slottime"] = 20
self.config["hw_modem_beaconinterval"] = None
self.config["hw_modem_beacondata"] = None
self.config["hw_serial_baudrate"] = 57600 self.config["hw_serial_baudrate"] = 57600
self.config["hw_serial_databits"] = 8 self.config["hw_serial_databits"] = 8
self.config["hw_serial_stopbits"] = 1 self.config["hw_serial_stopbits"] = 1
@ -284,6 +289,14 @@ class SidebandCore():
if not "hw_rnode_beacondata" in self.config: if not "hw_rnode_beacondata" in self.config:
self.config["hw_rnode_beacondata"] = None self.config["hw_rnode_beacondata"] = None
if not "hw_modem_baudrate" in self.config:
self.config["hw_modem_baudrate"] = 115200
if not "hw_modem_databits" in self.config:
self.config["hw_modem_databits"] = 8
if not "hw_modem_stopbits" in self.config:
self.config["hw_modem_stopbits"] = 1
if not "hw_modem_parity" in self.config:
self.config["hw_modem_parity"] = "none"
if not "hw_modem_preamble" in self.config: if not "hw_modem_preamble" in self.config:
self.config["hw_modem_preamble"] = 150 self.config["hw_modem_preamble"] = 150
if not "hw_modem_tail" in self.config: if not "hw_modem_tail" in self.config:
@ -292,6 +305,10 @@ class SidebandCore():
self.config["hw_modem_persistence"] = 220 self.config["hw_modem_persistence"] = 220
if not "hw_modem_slottime" in self.config: if not "hw_modem_slottime" in self.config:
self.config["hw_modem_slottime"] = 20 self.config["hw_modem_slottime"] = 20
if not "hw_modem_beaconinterval" in self.config:
self.config["hw_modem_beaconinterval"] = None
if not "hw_modem_beacondata" in self.config:
self.config["hw_modem_beacondata"] = None
if not "hw_serial_baudrate" in self.config: if not "hw_serial_baudrate" in self.config:
self.config["hw_serial_baudrate"] = 57600 self.config["hw_serial_baudrate"] = 57600
@ -309,7 +326,6 @@ class SidebandCore():
self._db_initstate() self._db_initstate()
self._db_initpersistent() self._db_initpersistent()
def __reload_config(self): def __reload_config(self):
RNS.log("Reloading Sideband configuration... "+str(self.config_path), RNS.LOG_DEBUG) RNS.log("Reloading Sideband configuration... "+str(self.config_path), RNS.LOG_DEBUG)
config_file = open(self.config_path, "rb") config_file = open(self.config_path, "rb")
@ -346,7 +362,6 @@ class SidebandCore():
except Exception as e: except Exception as e:
RNS.log("Error while setting LXMF propagation node: "+str(e), RNS.LOG_ERROR) RNS.log("Error while setting LXMF propagation node: "+str(e), RNS.LOG_ERROR)
def notify(self, title, content, group=None, context_id=None): def notify(self, title, content, group=None, context_id=None):
if self.config["notifications_on"]: if self.config["notifications_on"]:
if RNS.vendor.platformutils.get_platform() == "android": if RNS.vendor.platformutils.get_platform() == "android":
@ -1086,8 +1101,6 @@ class SidebandCore():
self.setpersistent("lxmf.lastsync", time.time()) self.setpersistent("lxmf.lastsync", time.time())
self.setpersistent("lxmf.syncretrying", False) self.setpersistent("lxmf.syncretrying", False)
def __start_jobs_deferred(self): def __start_jobs_deferred(self):
if self.config["start_announce"]: if self.config["start_announce"]:
self.lxmf_announce() self.lxmf_announce()
@ -1306,6 +1319,52 @@ class SidebandCore():
RNS.log("Error while adding Serial Interface. The contained exception was: "+str(e)) RNS.log("Error while adding Serial Interface. The contained exception was: "+str(e))
self.interface_serial = None self.interface_serial = None
elif self.config["connect_modem"]:
self.setstate("init.loadingstate", "Starting Radio Modem")
try:
RNS.log("Adding Modem Interface...")
target_device = None
if len(self.owner_app.usb_devices) > 0:
# TODO: Add more intelligent selection here
target_device = self.owner_app.usb_devices[0]
if target_device:
if self.config["connect_modem_ifac_netname"] == "":
ifac_netname = None
else:
ifac_netname = self.config["connect_modem_ifac_netname"]
if self.config["connect_modem_ifac_passphrase"] == "":
ifac_netkey = None
else:
ifac_netkey = self.config["connect_modem_ifac_passphrase"]
modeminterface = RNS.Interfaces.Android.KISSInterface.KISSInterface(
RNS.Transport,
"ModemInterface",
target_device["port"],
self.config["hw_modem_baudrate"],
self.config["hw_modem_databits"],
self.config["hw_modem_parity"],
self.config["hw_modem_stopbits"],
self.config["hw_modem_preamble"],
self.config["hw_modem_tail"],
self.config["hw_modem_persistence"],
self.config["hw_modem_slottime"],
False, # flow control
self.config["hw_modem_beaconinterval"],
self.config["hw_modem_beacondata"],
)
modeminterface.OUT = True
self.reticulum._add_interface(modeminterface,ifac_netname=ifac_netname,ifac_netkey=ifac_netkey)
self.interface_modem = modeminterface
except Exception as e:
RNS.log("Error while adding Modem Interface. The contained exception was: "+str(e))
self.interface_modem = None
RNS.log("Reticulum started, activating LXMF...") RNS.log("Reticulum started, activating LXMF...")
self.setstate("init.loadingstate", "Activating LXMF Router") self.setstate("init.loadingstate", "Activating LXMF Router")
self.message_router = LXMF.LXMRouter(identity = self.identity, storagepath = self.lxmf_storage, autopeer = True) self.message_router = LXMF.LXMRouter(identity = self.identity, storagepath = self.lxmf_storage, autopeer = True)
@ -1340,7 +1399,6 @@ class SidebandCore():
else: else:
self.lxm_ingest(message, originator=True) self.lxm_ingest(message, originator=True)
def send_message(self, content, destination_hash, propagation): def send_message(self, content, destination_hash, propagation):
try: try:
if content == "": if content == "":
@ -1446,7 +1504,6 @@ class SidebandCore():
self.notify(title=self.peer_display_name(context_dest), content=notification_content, group="LXM", context_id=RNS.hexrep(context_dest, delimit=False)) self.notify(title=self.peer_display_name(context_dest), content=notification_content, group="LXM", context_id=RNS.hexrep(context_dest, delimit=False))
def start(self): def start(self):
self._db_clean_messages() self._db_clean_messages()
self.__start_jobs_immediate() self.__start_jobs_immediate()
@ -1473,7 +1530,6 @@ class SidebandCore():
def get_sync_progress(self): def get_sync_progress(self):
return self.message_router.propagation_transfer_progress return self.message_router.propagation_transfer_progress
def lxmf_delivery(self, message): def lxmf_delivery(self, message):
time_string = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(message.timestamp)) time_string = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(message.timestamp))
signature_string = "Signature is invalid, reason undetermined" signature_string = "Signature is invalid, reason undetermined"