package resolver import ( "context" "errors" "math/rand" "net" "net/netip" "strings" "time" "github.com/Dreamacro/clash/component/trie" ) var ( // DefaultResolver aim to resolve ip DefaultResolver Resolver // ProxyServerHostResolver resolve ip to proxies server host ProxyServerHostResolver Resolver // DisableIPv6 means don't resolve ipv6 host // default value is true DisableIPv6 = true // DefaultHosts aim to resolve hosts DefaultHosts = trie.New[netip.Addr]() // DefaultDNSTimeout defined the default dns request timeout DefaultDNSTimeout = time.Second * 5 ) var ( ErrIPNotFound = errors.New("couldn't find ip") ErrIPVersion = errors.New("ip version error") ErrIPv6Disabled = errors.New("ipv6 disabled") ) type Resolver interface { ResolveIP(host string) (ip net.IP, err error) ResolveIPv4(host string) (ip net.IP, err error) ResolveIPv6(host string) (ip net.IP, err error) } // ResolveIPv4 with a host, return ipv4 func ResolveIPv4(host string) (net.IP, error) { return ResolveIPv4WithResolver(host, DefaultResolver) } func ResolveIPv4WithResolver(host string, r Resolver) (net.IP, error) { if node := DefaultHosts.Search(host); node != nil { if ip := node.Data; ip.Is4() { return ip.AsSlice(), nil } } ip := net.ParseIP(host) if ip != nil { if !strings.Contains(host, ":") { return ip, nil } return nil, ErrIPVersion } if r != nil { return r.ResolveIPv4(host) } if DefaultResolver == nil { ctx, cancel := context.WithTimeout(context.Background(), DefaultDNSTimeout) defer cancel() ipAddrs, err := net.DefaultResolver.LookupIP(ctx, "ip4", host) if err != nil { return nil, err } else if len(ipAddrs) == 0 { return nil, ErrIPNotFound } return ipAddrs[rand.Intn(len(ipAddrs))], nil } return nil, ErrIPNotFound } // ResolveIPv6 with a host, return ipv6 func ResolveIPv6(host string) (net.IP, error) { return ResolveIPv6WithResolver(host, DefaultResolver) } func ResolveIPv6WithResolver(host string, r Resolver) (net.IP, error) { if DisableIPv6 { return nil, ErrIPv6Disabled } if node := DefaultHosts.Search(host); node != nil { if ip := node.Data; ip.Is6() { return ip.AsSlice(), nil } } ip := net.ParseIP(host) if ip != nil { if strings.Contains(host, ":") { return ip, nil } return nil, ErrIPVersion } if r != nil { return r.ResolveIPv6(host) } if DefaultResolver == nil { ctx, cancel := context.WithTimeout(context.Background(), DefaultDNSTimeout) defer cancel() ipAddrs, err := net.DefaultResolver.LookupIP(ctx, "ip6", host) if err != nil { return nil, err } else if len(ipAddrs) == 0 { return nil, ErrIPNotFound } return ipAddrs[rand.Intn(len(ipAddrs))], nil } return nil, ErrIPNotFound } // ResolveIPWithResolver same as ResolveIP, but with a resolver func ResolveIPWithResolver(host string, r Resolver) (net.IP, error) { if node := DefaultHosts.Search(host); node != nil { ip := node.Data return ip.Unmap().AsSlice(), nil } if r != nil { if DisableIPv6 { return r.ResolveIPv4(host) } return r.ResolveIP(host) } else if DisableIPv6 { return ResolveIPv4(host) } ip := net.ParseIP(host) if ip != nil { return ip, nil } if DefaultResolver == nil { ipAddr, err := net.ResolveIPAddr("ip", host) if err != nil { return nil, err } return ipAddr.IP, nil } return nil, ErrIPNotFound } // ResolveIP with a host, return ip func ResolveIP(host string) (net.IP, error) { return ResolveIPWithResolver(host, DefaultResolver) } // ResolveIPv4ProxyServerHost proxies server host only func ResolveIPv4ProxyServerHost(host string) (net.IP, error) { if ProxyServerHostResolver != nil { return ResolveIPv4WithResolver(host, ProxyServerHostResolver) } return ResolveIPv4(host) } // ResolveIPv6ProxyServerHost proxies server host only func ResolveIPv6ProxyServerHost(host string) (net.IP, error) { if ProxyServerHostResolver != nil { return ResolveIPv6WithResolver(host, ProxyServerHostResolver) } return ResolveIPv6(host) } // ResolveProxyServerHost proxies server host only func ResolveProxyServerHost(host string) (net.IP, error) { if ProxyServerHostResolver != nil { return ResolveIPWithResolver(host, ProxyServerHostResolver) } return ResolveIP(host) }