jacob.eva/Reticulum
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added Access Point interface mode

Browse Source
This commit is contained in:
Mark Qvist 2022-02-25 18:47:55 +01:00
parent 8ec356a28e
commit 0e1279d012
5 changed files with 49 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
README.md
View File

@ -86,19 +86,19 @@ Reticulum implements a range of generalised interface types that covers most of
## Feature Roadmap
- Stream mode for links
- Globally routable multicast
## Planned Features
- More interface types for even broader compatibility
- ESP32 devices (ESP-Now, Bluetooth, etc.)
- More LoRa transceivers
- AT-compatible modems
- AWDL / OWL
- HF Modems
- CAN-bus
- ZeroMQ
- MQTT
- SPI
- i²c
- Globally routable multicast
## Dependencies:
- Python 3.6

4
RNS/Interfaces/Interface.py
View File

@ -7,6 +7,10 @@ class Interface:
RPT = False
name = None
MODE_FULL = 0x01
MODE_POINT_TO_POINT = 0x02
MODE_ACCESS_POINT = 0x03
def __init__(self):
self.rxb = 0
self.txb = 0

2
RNS/Interfaces/LocalInterface.py
View File

@ -37,6 +37,7 @@ class LocalClientInterface(Interface):
self.never_connected = True
self.detached = False
self.name = name
self.mode = RNS.Interfaces.Interface.Interface.MODE_FULL
if connected_socket != None:
self.receives = True
@ -237,6 +238,7 @@ class LocalServerInterface(Interface):
self.IN = True
self.OUT = False
self.name = "Reticulum"
self.mode = RNS.Interfaces.Interface.Interface.MODE_FULL
if (bindport != None):
self.receives = True

28
RNS/Reticulum.py
View File

@ -280,6 +280,16 @@ class Reticulum:
if not name in interface_names:
c = self.config["interfaces"][name]
interface_mode = Interface.Interface.MODE_FULL
if "mode" in c:
if c["mode"] == "full":
interface_mode = Interface.Interface.MODE_FULL
elif c["mode"] == "accesspoint" or c["mode"] == "ap":
interface_mode = Interface.Interface.MODE_ACCESS_POINT
elif c["mode"] == "pointtopoint" or c["mode"] == "ptp":
interface_mode = Interface.Interface.MODE_POINT_TO_POINT
try:
if ("interface_enabled" in c) and c.as_bool("interface_enabled") == True:
if c["type"] == "AutoInterface":
@ -307,6 +317,8 @@ class Reticulum:
else:
interface.OUT = True
interface.mode = interface_mode
RNS.Transport.interfaces.append(interface)
else:
RNS.log("AutoInterface is not currently supported on Windows, disabling interface.", RNS.LOG_ERROR);
@ -343,6 +355,8 @@ class Reticulum:
else:
interface.OUT = True
interface.mode = interface_mode
RNS.Transport.interfaces.append(interface)
@ -370,6 +384,8 @@ class Reticulum:
else:
interface.OUT = True
interface.mode = interface_mode
RNS.Transport.interfaces.append(interface)
@ -394,6 +410,8 @@ class Reticulum:
else:
interface.OUT = True
interface.mode = interface_mode
RNS.Transport.interfaces.append(interface)
@ -414,6 +432,8 @@ class Reticulum:
else:
interface.OUT = True
interface.mode = interface_mode
RNS.Transport.interfaces.append(interface)
@ -442,6 +462,8 @@ class Reticulum:
else:
interface.OUT = True
interface.mode = interface_mode
RNS.Transport.interfaces.append(interface)
if c["type"] == "KISSInterface":
@ -483,6 +505,8 @@ class Reticulum:
else:
interface.OUT = True
interface.mode = interface_mode
RNS.Transport.interfaces.append(interface)
if c["type"] == "AX25KISSInterface":
@ -525,6 +549,8 @@ class Reticulum:
else:
interface.OUT = True
interface.mode = interface_mode
RNS.Transport.interfaces.append(interface)
if c["type"] == "RNodeInterface":
@ -561,6 +587,8 @@ class Reticulum:
else:
interface.OUT = True
interface.mode = interface_mode
RNS.Transport.interfaces.append(interface)
else:
RNS.log("Skipping disabled interface \""+name+"\"", RNS.LOG_DEBUG)

13
RNS/Transport.py
View File

@ -35,6 +35,7 @@ class Transport:
PATHFINDER_T = 10 # Retry grace period
PATHFINDER_RW = 10 # Random window for announce rebroadcast
PATHFINDER_E = 60*60*24*7 # Path expiration in seconds
AP_PATH_TIME = 60*60*24 # Expiration for Access Point paths
# TODO: Calculate an optimal number for this in
# various situations
@ -511,14 +512,20 @@ class Transport:
for interface in Transport.interfaces:
if interface.OUT:
should_transmit = True
if packet.destination.type == RNS.Destination.LINK:
if packet.destination.status == RNS.Link.CLOSED:
should_transmit = False
if interface != packet.destination.attached_interface:
should_transmit = False
if packet.attached_interface != None and interface != packet.attached_interface:
should_transmit = False
if packet.packet_type == RNS.Packet.ANNOUNCE:
if packet.attached_interface == None and interface.mode == RNS.Interfaces.Interface.Interface.MODE_ACCESS_POINT:
should_transmit = False
if should_transmit:
if not stored_hash:
Transport.packet_hashlist.append(packet.packet_hash)
@ -862,13 +869,17 @@ class Transport:
if should_add:
now = time.time()
retries = 0
expires = now + Transport.PATHFINDER_E
announce_hops = packet.hops
local_rebroadcasts = 0
block_rebroadcasts = False
attached_interface = None
retransmit_timeout = now + math.pow(Transport.PATHFINDER_C, packet.hops) + (RNS.rand() * Transport.PATHFINDER_RW)
if packet.receiving_interface.mode == RNS.Interfaces.Interface.Interface.MODE_ACCESS_POINT:
expires = now + Transport.AP_PATH_TIME
else:
expires = now + Transport.PATHFINDER_E
random_blobs.append(random_blob)
if (RNS.Reticulum.transport_enabled() or Transport.from_local_client(packet)) and packet.context != RNS.Packet.PATH_RESPONSE: