Prepare interface modularity

RNS/Interfaces/AX25KISSInterface.py

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

RNS/Interfaces/Android/KISSInterface.py

@@ -85,7 +85,7 @@ class KISSInterface(Interface):
 
         super().__init__()
 
-        c = configuration
+        c = Interface.get_config_obj(configuration)
         name = c["name"]
         preamble = int(c["preamble"]) if "preamble" in c else None
         txtail = int(c["txtail"]) if "txtail" in c else None
@@ -97,7 +97,7 @@ class KISSInterface(Interface):
         databits = int(c["databits"]) if "databits" in c else 8
         parity = c["parity"] if "parity" in c else "N"
         stopbits = int(c["stopbits"]) if "stopbits" in c else 1
-        beacon_interval = int(c["beacon_interval"]) if "beacon_interval" in c else None
+        beacon_interval = int(c["beacon_interval"]) if "beacon_interval" in c and c["beacon_interval"] != None else None
         beacon_data = c["beacon_data"] if "beacon_data" in c else None
         
         self.HW_MTU = 564

RNS/Interfaces/Android/RNodeInterface.py

@@ -343,24 +343,24 @@ class RNodeInterface(Interface):
 
 
     def __init__(self, owner, configuration):
-        c = configuration
+        c = Interface.get_config_obj(configuration)
         name = c["name"]
-        allow_bluetooth = c["allow_bluetooth"]
+        allow_bluetooth = c.as_bool("allow_bluetooth") if "allow_bluetooth" in c else False
-        target_device_name = c["target_device_name"]
+        target_device_name = c["target_device_name"] if "target_device_name" in c else None
-        target_device_address = c["target_device_address"]
+        target_device_address = c["target_device_address"] if "target_device_address" in c else None
-        ble_name = c["ble_name"]
+        ble_name = c["ble_name"] if "ble_name" in c else None
-        ble_addr = c["ble_addr"]
+        ble_addr = c["ble_addr"] if "ble_addr" in c else None
-        force_ble = c["force_ble"]
+        force_ble = c["force_ble"] if "force_ble" in c else False
-        frequency = int(c["frequency"]) if "frequency" in c else None
+        frequency = int(c["frequency"]) if "frequency" in c else 0
-        bandwidth = int(c["bandwidth"]) if "bandwidth" in c else None
+        bandwidth = int(c["bandwidth"]) if "bandwidth" in c else 0
-        txpower = int(c["txpower"]) if "txpower" in c else None
+        txpower = int(c["txpower"]) if "txpower" in c else 0
-        sf = int(c["spreadingfactor"]) if "spreadingfactor" in c else None
+        sf = int(c["spreadingfactor"]) if "spreadingfactor" in c else 0
-        cr = int(c["codingrate"]) if "codingrate" in c else None
+        cr = int(c["codingrate"]) if "codingrate" in c else 0
         flow_control = c.as_bool("flow_control") if "flow_control" in c else False
-        id_interval = int(c["id_interval"]) if "id_interval" in c else None
+        id_interval = int(c["id_interval"]) if "id_interval" in c and c["id_interval"] != None else None
         id_callsign = c["id_callsign"] if "id_callsign" in c else None
-        st_alock = float(c["airtime_limit_short"]) if "airtime_limit_short" in c else None
+        st_alock = float(c["airtime_limit_short"]) if "airtime_limit_short" in c and c["airtime_limit_short"] != None else None
-        lt_alock = float(c["airtime_limit_long"]) if "airtime_limit_long" in c else None
+        lt_alock = float(c["airtime_limit_long"]) if "airtime_limit_long" in c and c["airtime_limit_long"] != None else None
         port = c["port"] if "port" in c else None
 
         import importlib

RNS/Interfaces/Android/SerialInterface.py

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

RNS/Interfaces/AutoInterface.py

@@ -88,7 +88,7 @@ class AutoInterface(Interface):
         return socket.if_nametoindex(ifname)
 
     def __init__(self, owner, configuration):
-        c = configuration
+        c                      = Interface.get_config_obj(configuration)
         name                   = c["name"]
         group_id               = c["group_id"] if "group_id" 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
         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
-        configured_bitrate     = c["configured_bitrate"]
+        configured_bitrate     = c["configured_bitrate"] if "configured_bitrate" in c else None
 
         from RNS.vendor.ifaddr import niwrapper
         super().__init__()

RNS/Interfaces/I2PInterface.py

@@ -834,14 +834,14 @@ class I2PInterface(Interface):
     def __init__(self, owner, configuration):
         super().__init__()
 
-        c = configuration
+        c = Interface.get_config_obj(configuration)
         name = c["name"]
         rns_storagepath = c["storagepath"]
         peers = c.as_list("peers") if "peers" in c else None
         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
 

RNS/Interfaces/Interface.py

@@ -24,6 +24,7 @@ import RNS
 import time
 import threading
 from collections import deque
+from RNS.vendor.configobj import ConfigObj
 
 class Interface:
     IN  = False
@@ -239,3 +240,14 @@ class Interface:
 
     def detach(self):
         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")

RNS/Interfaces/KISSInterface.py

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

RNS/Interfaces/PipeInterface.py

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

RNS/Interfaces/RNodeInterface.py

@@ -132,13 +132,13 @@ class RNodeInterface(Interface):
 
         super().__init__()
 
-        c = configuration
+        c = Interface.get_config_obj(configuration)
         name         = c["name"]
-        frequency = int(c["frequency"]) if "frequency" in c else None
+        frequency    = int(c["frequency"]) if "frequency" in c else 0
-        bandwidth = int(c["bandwidth"]) if "bandwidth" in c else None
+        bandwidth    = int(c["bandwidth"]) if "bandwidth" in c else 0
-        txpower = int(c["txpower"]) if "txpower" in c else None
+        txpower      = int(c["txpower"]) if "txpower" in c else 0
-        sf = int(c["spreadingfactor"]) if "spreadingfactor" in c else None
+        sf           = int(c["spreadingfactor"]) if "spreadingfactor" in c else 0
-        cr = int(c["codingrate"]) if "codingrate" in c else None
+        cr           = int(c["codingrate"]) if "codingrate" in c else 0
         flow_control = c.as_bool("flow_control") if "flow_control" in c else False
         id_interval  = int(c["id_interval"]) if "id_interval" in c else None
         id_callsign  = c["id_callsign"] if "id_callsign" in c else None

RNS/Interfaces/RNodeMultiInterface.py

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

RNS/Interfaces/SerialInterface.py

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

RNS/Interfaces/TCPInterface.py

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

RNS/Interfaces/UDPInterface.py

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