feat: lokale Subnetze vor VPN-Verbindung ermitteln und Versionsnummer auf 1.0.30 erhöht
This commit is contained in:
41
app.py
41
app.py
@@ -332,42 +332,42 @@ import ipaddress as _ipaddress
|
|||||||
_wg_managed_subnets: list = [] # beim Connect gemerkte Subnetze für sauberes Cleanup
|
_wg_managed_subnets: list = [] # beim Connect gemerkte Subnetze für sauberes Cleanup
|
||||||
|
|
||||||
|
|
||||||
def _local_subnets() -> list:
|
def _local_subnets_before_vpn() -> list:
|
||||||
"""Alle direkt verbundenen IPv4-Subnetze außer WireGuard-Interface und Loopback."""
|
"""Subnetze aller lokalen Interfaces (außer Loopback) via 'ip addr show'.
|
||||||
r = subprocess.run(['ip', '-4', 'route', 'show', 'table', 'main'],
|
Muss VOR wg-quick up aufgerufen werden, damit wg-quick die Tabelle noch
|
||||||
capture_output=True, text=True)
|
nicht verändert hat."""
|
||||||
|
r = subprocess.run(['ip', '-4', 'addr', 'show'], capture_output=True, text=True)
|
||||||
seen, result = set(), []
|
seen, result = set(), []
|
||||||
|
current_iface = ''
|
||||||
for line in r.stdout.splitlines():
|
for line in r.stdout.splitlines():
|
||||||
parts = line.split()
|
if not line[:1].isspace():
|
||||||
if not parts or parts[0] in ('default', 'unreachable', 'prohibit'):
|
# Zeile wie "2: wlan0: <BROADCAST,..."
|
||||||
continue
|
current_iface = line.split(':')[1].strip().split('@')[0] if ':' in line else ''
|
||||||
if 'dev' not in parts:
|
elif current_iface and current_iface != 'lo':
|
||||||
continue
|
s = line.strip()
|
||||||
dev = parts[parts.index('dev') + 1]
|
if s.startswith('inet '):
|
||||||
if dev == WG_IFACE:
|
|
||||||
continue
|
|
||||||
try:
|
try:
|
||||||
net = str(_ipaddress.IPv4Network(parts[0], strict=False))
|
net = str(_ipaddress.IPv4Interface(s.split()[1]).network)
|
||||||
if net not in seen and not _ipaddress.IPv4Network(net).is_loopback:
|
if net not in seen:
|
||||||
seen.add(net)
|
seen.add(net)
|
||||||
result.append(net)
|
result.append(net)
|
||||||
except ValueError:
|
except Exception:
|
||||||
pass
|
pass
|
||||||
return result
|
return result
|
||||||
|
|
||||||
|
|
||||||
def _wg_add_local_routes():
|
def _wg_add_local_routes(subnets: list):
|
||||||
"""Alle lokalen Subnetze (Hotspot, WLAN, LAN) vom VPN-Tunnel ausschließen."""
|
"""Alle lokalen Subnetze (Hotspot, WLAN, LAN) vom VPN-Tunnel ausschließen."""
|
||||||
global _wg_managed_subnets
|
global _wg_managed_subnets
|
||||||
_wg_managed_subnets = _local_subnets()
|
_wg_managed_subnets = subnets
|
||||||
for i, subnet in enumerate(_wg_managed_subnets):
|
for i, subnet in enumerate(subnets):
|
||||||
prio_from = 100 + i * 2
|
prio_from = 100 + i * 2
|
||||||
prio_to = 101 + i * 2
|
prio_to = 101 + i * 2
|
||||||
subprocess.run(['ip', 'rule', 'add', 'from', subnet,
|
subprocess.run(['ip', 'rule', 'add', 'from', subnet,
|
||||||
'table', 'main', 'priority', str(prio_from)], capture_output=True)
|
'table', 'main', 'priority', str(prio_from)], capture_output=True)
|
||||||
subprocess.run(['ip', 'rule', 'add', 'to', subnet,
|
subprocess.run(['ip', 'rule', 'add', 'to', subnet,
|
||||||
'table', 'main', 'priority', str(prio_to)], capture_output=True)
|
'table', 'main', 'priority', str(prio_to)], capture_output=True)
|
||||||
log.info(f'Lokale Routing-Regeln gesetzt: {_wg_managed_subnets}')
|
log.info(f'Lokale Routing-Regeln gesetzt: {subnets}')
|
||||||
|
|
||||||
|
|
||||||
def _wg_remove_local_routes():
|
def _wg_remove_local_routes():
|
||||||
@@ -389,11 +389,12 @@ def wg_connect():
|
|||||||
with wg_lock:
|
with wg_lock:
|
||||||
wg_state['error'] = 'Keine Konfiguration vorhanden'
|
wg_state['error'] = 'Keine Konfiguration vorhanden'
|
||||||
return False
|
return False
|
||||||
|
local_nets = _local_subnets_before_vpn() # VOR wg-quick lesen
|
||||||
r = subprocess.run(['wg-quick', 'up', WG_IFACE],
|
r = subprocess.run(['wg-quick', 'up', WG_IFACE],
|
||||||
capture_output=True, text=True, timeout=30)
|
capture_output=True, text=True, timeout=30)
|
||||||
if r.returncode == 0:
|
if r.returncode == 0:
|
||||||
time.sleep(1)
|
time.sleep(1)
|
||||||
_wg_add_local_routes()
|
_wg_add_local_routes(local_nets)
|
||||||
wg_update_state()
|
wg_update_state()
|
||||||
log.info('WireGuard verbunden')
|
log.info('WireGuard verbunden')
|
||||||
return True
|
return True
|
||||||
|
|||||||
@@ -1 +1 @@
|
|||||||
1.0.29
|
1.0.30
|
||||||
Reference in New Issue
Block a user