Prepare interface modularity

This commit is contained in:
Mark Qvist 2024-11-21 14:41:22 +01:00
parent 760ab981d0
commit a762af035a
14 changed files with 43 additions and 31 deletions

View File

@ -80,7 +80,7 @@ class AX25KISSInterface(Interface):
super().__init__() super().__init__()
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
preamble = int(c["preamble"]) if "preamble" in c else None preamble = int(c["preamble"]) if "preamble" in c else None
txtail = int(c["txtail"]) if "txtail" in c else None txtail = int(c["txtail"]) if "txtail" in c else None

View File

@ -85,7 +85,7 @@ class KISSInterface(Interface):
super().__init__() super().__init__()
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
preamble = int(c["preamble"]) if "preamble" in c else None preamble = int(c["preamble"]) if "preamble" in c else None
txtail = int(c["txtail"]) if "txtail" in c else None txtail = int(c["txtail"]) if "txtail" in c else None

View File

@ -343,7 +343,7 @@ class RNodeInterface(Interface):
def __init__(self, owner, configuration): def __init__(self, owner, configuration):
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
allow_bluetooth = c["allow_bluetooth"] allow_bluetooth = c["allow_bluetooth"]
target_device_name = c["target_device_name"] target_device_name = c["target_device_name"]

View File

@ -75,7 +75,7 @@ class SerialInterface(Interface):
super().__init__() super().__init__()
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
port = c["port"] if "port" in c else None port = c["port"] if "port" in c else None
speed = int(c["speed"]) if "speed" in c else 9600 speed = int(c["speed"]) if "speed" in c else 9600

View File

@ -88,7 +88,7 @@ class AutoInterface(Interface):
return socket.if_nametoindex(ifname) return socket.if_nametoindex(ifname)
def __init__(self, owner, configuration): def __init__(self, owner, configuration):
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
group_id = c["group_id"] if "group_id" in c else None group_id = c["group_id"] if "group_id" in c else None
discovery_scope = c["discovery_scope"] if "discovery_scope" in c else None discovery_scope = c["discovery_scope"] if "discovery_scope" in c else None
@ -97,7 +97,7 @@ class AutoInterface(Interface):
data_port = int(c["data_port"]) if "data_port" in c else None data_port = int(c["data_port"]) if "data_port" in c else None
allowed_interfaces = c.as_list("devices") if "devices" in c else None allowed_interfaces = c.as_list("devices") if "devices" in c else None
ignored_interfaces = c.as_list("ignored_devices") if "ignored_devices" in c else None ignored_interfaces = c.as_list("ignored_devices") if "ignored_devices" in c else None
configured_bitrate = c["configured_bitrate"] configured_bitrate = c["configured_bitrate"] if "configured_bitrate" in c else None
from RNS.vendor.ifaddr import niwrapper from RNS.vendor.ifaddr import niwrapper
super().__init__() super().__init__()

View File

@ -834,14 +834,14 @@ class I2PInterface(Interface):
def __init__(self, owner, configuration): def __init__(self, owner, configuration):
super().__init__() super().__init__()
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
rns_storagepath = c["storagepath"] rns_storagepath = c["storagepath"]
peers = c.as_list("peers") if "peers" in c else None peers = c.as_list("peers") if "peers" in c else None
connectable = c.as_bool("connectable") if "connectable" in c else False connectable = c.as_bool("connectable") if "connectable" in c else False
ifac_size = c["ifac_size"] ifac_size = c["ifac_size"] if "ifac_size" in c else None
ifac_netname = c["ifac_netname"] ifac_netname = c["ifac_netname"] if "ifac_netname" in c else None
ifac_netkey = c["ifac_netkey"] ifac_netkey = c["ifac_netkey"] if "ifac_netkey" in c else None
self.HW_MTU = 1064 self.HW_MTU = 1064

View File

@ -24,6 +24,7 @@ import RNS
import time import time
import threading import threading
from collections import deque from collections import deque
from RNS.vendor.configobj import ConfigObj
class Interface: class Interface:
IN = False IN = False
@ -239,3 +240,14 @@ class Interface:
def detach(self): def detach(self):
pass pass
@staticmethod
def get_config_obj(config_in):
if type(config_in) == ConfigObj:
return config_in
else:
try:
return ConfigObj(config_in)
except Exception as e:
RNS.log(f"Could not parse supplied configuration data. The contained exception was: {e}", RNS.LOG_ERROR)
raise SystemError("Invalid configuration data supplied")

View File

@ -73,7 +73,7 @@ class KISSInterface(Interface):
super().__init__() super().__init__()
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
preamble = int(c["preamble"]) if "preamble" in c else None preamble = int(c["preamble"]) if "preamble" in c else None
txtail = int(c["txtail"]) if "txtail" in c else None txtail = int(c["txtail"]) if "txtail" in c else None

View File

@ -54,7 +54,7 @@ class PipeInterface(Interface):
def __init__(self, owner, configuration): def __init__(self, owner, configuration):
super().__init__() super().__init__()
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
command = c["command"] if "command" in c else None command = c["command"] if "command" in c else None
respawn_delay = c.as_float("respawn_delay") if "respawn_delay" in c else None respawn_delay = c.as_float("respawn_delay") if "respawn_delay" in c else None

View File

@ -132,7 +132,7 @@ class RNodeInterface(Interface):
super().__init__() super().__init__()
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
frequency = int(c["frequency"]) if "frequency" in c else None frequency = int(c["frequency"]) if "frequency" in c else None
bandwidth = int(c["bandwidth"]) if "bandwidth" in c else None bandwidth = int(c["bandwidth"]) if "bandwidth" in c else None

View File

@ -188,7 +188,7 @@ class RNodeMultiInterface(Interface):
super().__init__() super().__init__()
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
count = 0 count = 0

View File

@ -63,7 +63,7 @@ class SerialInterface(Interface):
super().__init__() super().__init__()
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
port = c["port"] if "port" in c else None port = c["port"] if "port" in c else None
speed = int(c["speed"]) if "speed" in c else 9600 speed = int(c["speed"]) if "speed" in c else 9600

View File

@ -85,10 +85,10 @@ class TCPClientInterface(Interface):
def __init__(self, owner, configuration, connected_socket=None): def __init__(self, owner, configuration, connected_socket=None):
super().__init__() super().__init__()
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
target_ip = c["target_host"] target_ip = c["target_host"] if "target_host" in c else None
target_port = int(c["target_port"]) target_port = int(c["target_port"]) if "target_port" in c else None
kiss_framing = False kiss_framing = False
if "kiss_framing" in c and c.as_bool("kiss_framing") == True: if "kiss_framing" in c and c.as_bool("kiss_framing") == True:
kiss_framing = True kiss_framing = True
@ -468,7 +468,7 @@ class TCPServerInterface(Interface):
def __init__(self, owner, configuration): def __init__(self, owner, configuration):
super().__init__() super().__init__()
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
device = c["device"] if "device" in c else None device = c["device"] if "device" in c else None
port = int(c["port"]) if "port" in c else None port = int(c["port"]) if "port" in c else None

View File

@ -48,7 +48,7 @@ class UDPInterface(Interface):
def __init__(self, owner, configuration): def __init__(self, owner, configuration):
super().__init__() super().__init__()
c = configuration c = Interface.get_config_obj(configuration)
name = c["name"] name = c["name"]
device = c["device"] if "device" in c else None device = c["device"] if "device" in c else None
port = int(c["port"]) if "port" in c else None port = int(c["port"]) if "port" in c else None