mirror of
https://github.com/MetaCubeX/mihomo.git
synced 2024-11-16 19:56:51 +08:00
126 lines
2.6 KiB
Go
126 lines
2.6 KiB
Go
package dns
|
|
|
|
import (
|
|
"net"
|
|
"net/netip"
|
|
|
|
"github.com/Dreamacro/clash/common/cache"
|
|
"github.com/Dreamacro/clash/common/nnip"
|
|
"github.com/Dreamacro/clash/component/fakeip"
|
|
C "github.com/Dreamacro/clash/constant"
|
|
)
|
|
|
|
type ResolverEnhancer struct {
|
|
mode C.DNSMode
|
|
fakePool *fakeip.Pool
|
|
mapping *cache.LruCache[netip.Addr, string]
|
|
}
|
|
|
|
func (h *ResolverEnhancer) FakeIPEnabled() bool {
|
|
return h.mode == C.DNSFakeIP
|
|
}
|
|
|
|
func (h *ResolverEnhancer) MappingEnabled() bool {
|
|
return h.mode == C.DNSFakeIP || h.mode == C.DNSMapping
|
|
}
|
|
|
|
func (h *ResolverEnhancer) IsExistFakeIP(ip net.IP) bool {
|
|
if !h.FakeIPEnabled() {
|
|
return false
|
|
}
|
|
|
|
if pool := h.fakePool; pool != nil {
|
|
return pool.Exist(nnip.IpToAddr(ip))
|
|
}
|
|
|
|
return false
|
|
}
|
|
|
|
func (h *ResolverEnhancer) IsFakeIP(ip net.IP) bool {
|
|
if !h.FakeIPEnabled() {
|
|
return false
|
|
}
|
|
|
|
addr := nnip.IpToAddr(ip)
|
|
|
|
if pool := h.fakePool; pool != nil {
|
|
return pool.IPNet().Contains(addr) && addr != pool.Gateway() && addr != pool.Broadcast()
|
|
}
|
|
|
|
return false
|
|
}
|
|
|
|
func (h *ResolverEnhancer) IsFakeBroadcastIP(ip net.IP) bool {
|
|
if !h.FakeIPEnabled() {
|
|
return false
|
|
}
|
|
|
|
if pool := h.fakePool; pool != nil {
|
|
return pool.Broadcast() == nnip.IpToAddr(ip)
|
|
}
|
|
|
|
return false
|
|
}
|
|
|
|
func (h *ResolverEnhancer) FindHostByIP(ip net.IP) (string, bool) {
|
|
addr := nnip.IpToAddr(ip)
|
|
if pool := h.fakePool; pool != nil {
|
|
if host, existed := pool.LookBack(addr); existed {
|
|
return host, true
|
|
}
|
|
}
|
|
|
|
if mapping := h.mapping; mapping != nil {
|
|
if host, existed := h.mapping.Get(addr); existed {
|
|
return host, true
|
|
}
|
|
}
|
|
|
|
return "", false
|
|
}
|
|
|
|
func (h *ResolverEnhancer) InsertHostByIP(ip net.IP, host string) {
|
|
if mapping := h.mapping; mapping != nil {
|
|
h.mapping.Set(nnip.IpToAddr(ip), host)
|
|
}
|
|
}
|
|
|
|
func (h *ResolverEnhancer) FlushFakeIP() error {
|
|
if h.fakePool != nil {
|
|
return h.fakePool.FlushFakeIP()
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (h *ResolverEnhancer) PatchFrom(o *ResolverEnhancer) {
|
|
if h.mapping != nil && o.mapping != nil {
|
|
o.mapping.CloneTo(h.mapping)
|
|
}
|
|
|
|
if h.fakePool != nil && o.fakePool != nil {
|
|
h.fakePool.CloneFrom(o.fakePool)
|
|
}
|
|
}
|
|
|
|
func (h *ResolverEnhancer) StoreFakePoolState() {
|
|
if h.fakePool != nil {
|
|
h.fakePool.StoreState()
|
|
}
|
|
}
|
|
|
|
func NewEnhancer(cfg Config) *ResolverEnhancer {
|
|
var fakePool *fakeip.Pool
|
|
var mapping *cache.LruCache[netip.Addr, string]
|
|
|
|
if cfg.EnhancedMode != C.DNSNormal {
|
|
fakePool = cfg.Pool
|
|
mapping = cache.NewLRUCache[netip.Addr, string](cache.WithSize[netip.Addr, string](4096), cache.WithStale[netip.Addr, string](true))
|
|
}
|
|
|
|
return &ResolverEnhancer{
|
|
mode: cfg.EnhancedMode,
|
|
fakePool: fakePool,
|
|
mapping: mapping,
|
|
}
|
|
}
|