From d75a1c98cc38d50d7b634bf5bac6ed04971852d3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=96=E7=95=8C?= Date: Sun, 22 Sep 2024 22:21:50 +0800 Subject: [PATCH] Reuse InterfaceFinder --- go.mod | 2 +- go.sum | 4 +-- monitor.go | 2 ++ monitor_shared.go | 69 +++++++++++++---------------------------------- 4 files changed, 23 insertions(+), 54 deletions(-) diff --git a/go.mod b/go.mod index 8c88c2a..1602671 100644 --- a/go.mod +++ b/go.mod @@ -8,7 +8,7 @@ require ( github.com/sagernet/gvisor v0.0.0-20240428053021-e691de28565f github.com/sagernet/netlink v0.0.0-20240612041022-b9a21c07ac6a github.com/sagernet/nftables v0.3.0-beta.4 - github.com/sagernet/sing v0.5.0-alpha.11.0.20240625144910-6bd878184516 + github.com/sagernet/sing v0.5.0-beta.2.0.20240922141512-c63546470b53 go4.org/netipx v0.0.0-20231129151722-fdeea329fbba golang.org/x/exp v0.0.0-20240613232115-7f521ea00fb8 golang.org/x/net v0.26.0 diff --git a/go.sum b/go.sum index 3975fcf..0e5752e 100644 --- a/go.sum +++ b/go.sum @@ -22,8 +22,8 @@ github.com/sagernet/netlink v0.0.0-20240612041022-b9a21c07ac6a h1:ObwtHN2VpqE0ZN github.com/sagernet/netlink v0.0.0-20240612041022-b9a21c07ac6a/go.mod h1:xLnfdiJbSp8rNqYEdIW/6eDO4mVoogml14Bh2hSiFpM= github.com/sagernet/nftables v0.3.0-beta.4 h1:kbULlAwAC3jvdGAC1P5Fa3GSxVwQJibNenDW2zaXr8I= github.com/sagernet/nftables v0.3.0-beta.4/go.mod h1:OQXAjvjNGGFxaTgVCSTRIhYB5/llyVDeapVoENYBDS8= -github.com/sagernet/sing v0.5.0-alpha.11.0.20240625144910-6bd878184516 h1:C5NYqSEQC2CcILDFhT31iZe5Kp5hFNEtdS9mnNWyW5c= -github.com/sagernet/sing v0.5.0-alpha.11.0.20240625144910-6bd878184516/go.mod h1:ARkL0gM13/Iv5VCZmci/NuoOlePoIsW0m7BWfln/Hak= +github.com/sagernet/sing v0.5.0-beta.2.0.20240922141512-c63546470b53 h1:skd2mM7USFsPTmyaPnnJJVrGWIMGv8PdzVyoKQPdqpU= +github.com/sagernet/sing v0.5.0-beta.2.0.20240922141512-c63546470b53/go.mod h1:ARkL0gM13/Iv5VCZmci/NuoOlePoIsW0m7BWfln/Hak= github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg= github.com/vishvananda/netns v0.0.4 h1:Oeaw1EM2JMxD51g9uhtC0D7erkIjgmj8+JZc26m1YX8= github.com/vishvananda/netns v0.0.4/go.mod h1:SpkAiCQRtJ6TvvxPnOSyH3BMl6unz3xZlaprSwhNNJM= diff --git a/monitor.go b/monitor.go index 2a0a419..e3db5c3 100644 --- a/monitor.go +++ b/monitor.go @@ -3,6 +3,7 @@ package tun import ( "net/netip" + "github.com/sagernet/sing/common/control" E "github.com/sagernet/sing/common/exceptions" "github.com/sagernet/sing/common/x/list" ) @@ -40,6 +41,7 @@ type DefaultInterfaceMonitor interface { } type DefaultInterfaceMonitorOptions struct { + InterfaceFinder control.InterfaceFinder OverrideAndroidVPN bool UnderNetworkExtension bool } diff --git a/monitor_shared.go b/monitor_shared.go index f456a78..651a87d 100644 --- a/monitor_shared.go +++ b/monitor_shared.go @@ -4,14 +4,12 @@ package tun import ( "errors" - "net" "net/netip" "sync" "time" - "github.com/sagernet/sing/common" + "github.com/sagernet/sing/common/control" "github.com/sagernet/sing/common/logger" - M "github.com/sagernet/sing/common/metadata" "github.com/sagernet/sing/common/x/list" ) @@ -37,8 +35,9 @@ func (m *networkUpdateMonitor) emit() { } type defaultInterfaceMonitor struct { - options DefaultInterfaceMonitorOptions - networkAddresses []networkAddress + interfaceFinder control.InterfaceFinder + overrideAndroidVPN bool + underNetworkExtension bool defaultInterfaceName string defaultInterfaceIndex int androidVPNEnabled bool @@ -51,15 +50,11 @@ type defaultInterfaceMonitor struct { logger logger.Logger } -type networkAddress struct { - interfaceName string - interfaceIndex int - addresses []netip.Prefix -} - func NewDefaultInterfaceMonitor(networkMonitor NetworkUpdateMonitor, logger logger.Logger, options DefaultInterfaceMonitorOptions) (DefaultInterfaceMonitor, error) { return &defaultInterfaceMonitor{ - options: options, + interfaceFinder: options.InterfaceFinder, + overrideAndroidVPN: options.OverrideAndroidVPN, + underNetworkExtension: options.UnderNetworkExtension, networkMonitor: networkMonitor, defaultInterfaceIndex: -1, logger: logger, @@ -81,7 +76,7 @@ func (m *defaultInterfaceMonitor) delayCheckUpdate() { } func (m *defaultInterfaceMonitor) postCheckUpdate() { - err := m.updateInterfaces() + err := m.interfaceFinder.Update() if err != nil { m.logger.Error("update interfaces: ", err) } @@ -100,34 +95,6 @@ func (m *defaultInterfaceMonitor) postCheckUpdate() { } } -func (m *defaultInterfaceMonitor) updateInterfaces() error { - interfaces, err := net.Interfaces() - if err != nil { - return err - } - var addresses []networkAddress - for _, iif := range interfaces { - var netAddresses []net.Addr - netAddresses, err = iif.Addrs() - if err != nil { - return err - } - var address networkAddress - address.interfaceName = iif.Name - address.interfaceIndex = iif.Index - address.addresses = common.Map(common.FilterIsInstance(netAddresses, func(it net.Addr) (*net.IPNet, bool) { - value, loaded := it.(*net.IPNet) - return value, loaded - }), func(it *net.IPNet) netip.Prefix { - bits, _ := it.Mask.Size() - return netip.PrefixFrom(M.AddrFromIP(it.IP), bits) - }) - addresses = append(addresses, address) - } - m.networkAddresses = addresses - return nil -} - func (m *defaultInterfaceMonitor) Close() error { if m.element != nil { m.networkMonitor.UnregisterCallback(m.element) @@ -136,10 +103,10 @@ func (m *defaultInterfaceMonitor) Close() error { } func (m *defaultInterfaceMonitor) DefaultInterfaceName(destination netip.Addr) string { - for _, address := range m.networkAddresses { - for _, prefix := range address.addresses { + for _, address := range m.interfaceFinder.Interfaces() { + for _, prefix := range address.Addresses { if prefix.Contains(destination) { - return address.interfaceName + return address.Name } } } @@ -147,10 +114,10 @@ func (m *defaultInterfaceMonitor) DefaultInterfaceName(destination netip.Addr) s } func (m *defaultInterfaceMonitor) DefaultInterfaceIndex(destination netip.Addr) int { - for _, address := range m.networkAddresses { - for _, prefix := range address.addresses { + for _, address := range m.interfaceFinder.Interfaces() { + for _, prefix := range address.Addresses { if prefix.Contains(destination) { - return address.interfaceIndex + return address.Index } } } @@ -158,10 +125,10 @@ func (m *defaultInterfaceMonitor) DefaultInterfaceIndex(destination netip.Addr) } func (m *defaultInterfaceMonitor) DefaultInterface(destination netip.Addr) (string, int) { - for _, address := range m.networkAddresses { - for _, prefix := range address.addresses { + for _, address := range m.interfaceFinder.Interfaces() { + for _, prefix := range address.Addresses { if prefix.Contains(destination) { - return address.interfaceName, address.interfaceIndex + return address.Name, address.Index } } } @@ -169,7 +136,7 @@ func (m *defaultInterfaceMonitor) DefaultInterface(destination netip.Addr) (stri } func (m *defaultInterfaceMonitor) OverrideAndroidVPN() bool { - return m.options.OverrideAndroidVPN + return m.overrideAndroidVPN } func (m *defaultInterfaceMonitor) AndroidVPNEnabled() bool {