Mirror/Reticulum
1
0
Fork 0
mirror of https://github.com/markqvist/Reticulum.git synced 2026-05-22 15:54:48 -07:00
Code Issues Packages Projects Releases Wiki Activity

Added auto-connect of discovered interfaces on instance start

Browse Source
This commit is contained in:
Mark Qvist
2026-01-03 00:52:39 +01:00
parent 2b3d6a0989
commit 1a77b5752c
1 changed files with 15 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
RNS/Discovery.py
View File

@@ -322,6 +322,7 @@ class InterfaceDiscovery():
if discover_interfaces: if discover_interfaces:
self.handler = InterfaceAnnounceHandler(callback=self.interface_discovered, required_value=self.required_value) self.handler = InterfaceAnnounceHandler(callback=self.interface_discovered, required_value=self.required_value)
RNS.Transport.register_announce_handler(self.handler) RNS.Transport.register_announce_handler(self.handler)
threading.Thread(target=self.connect_discovered, daemon=True).start()
def list_discovered_interfaces(self): def list_discovered_interfaces(self):
now = time.time() now = time.time()
@@ -456,11 +457,24 @@ class InterfaceDiscovery():
except Exception as e: except Exception as e:
RNS.log(f"Error while de-registering auto-connected interface from transport: {e}", RNS.LOG_ERROR) RNS.log(f"Error while de-registering auto-connected interface from transport: {e}", RNS.LOG_ERROR)
def autoconnect_count(self):
return len([i for i in RNS.Transport.interfaces if hasattr(i, "autoconnect_hash")])
def connect_discovered(self):
if RNS.Reticulum.should_autoconnect_discovered_interfaces():
try:
discovered_interfaces = self.list_discovered_interfaces()
for info in discovered_interfaces:
if self.autoconnect_count() >= RNS.Reticulum.max_autoconnected_interfaces(): break
self.autoconnect(info)
except Exception as e:
RNS.log(f"Error while reconnecting discovered interfaces: {e}", RNS.LOG_ERROR)
def autoconnect(self, info): def autoconnect(self, info):
try: try:
if RNS.Reticulum.should_autoconnect_discovered_interfaces(): if RNS.Reticulum.should_autoconnect_discovered_interfaces():
autoconnected_count = len([i for i in RNS.Transport.interfaces if hasattr(i, "autoconnect_hash")]) autoconnected_count = self.autoconnect_count()
if autoconnected_count < RNS.Reticulum.max_autoconnected_interfaces(): if autoconnected_count < RNS.Reticulum.max_autoconnected_interfaces():
interface_type = info["type"] interface_type = info["type"]
if interface_type in self.AUTOCONNECT_TYPES: if interface_type in self.AUTOCONNECT_TYPES: