package constant import ( "encoding/json" "fmt" "net" "net/netip" "strconv" ) // Socks addr type const ( AtypIPv4 = 1 AtypDomainName = 3 AtypIPv6 = 4 TCP NetWork = iota UDP ALLNet HTTP Type = iota HTTPCONNECT SOCKS4 SOCKS5 REDIR TPROXY TUN INNER ) type NetWork int func (n NetWork) String() string { if n == TCP { return "tcp" } else if n == UDP { return "udp" } return "all" } func (n NetWork) MarshalJSON() ([]byte, error) { return json.Marshal(n.String()) } type Type int func (t Type) String() string { switch t { case HTTP: return "HTTP" case HTTPCONNECT: return "HTTP Connect" case SOCKS4: return "Socks4" case SOCKS5: return "Socks5" case REDIR: return "Redir" case TPROXY: return "TProxy" case TUN: return "Tun" case INNER: return "Inner" default: return "Unknown" } } func (t Type) MarshalJSON() ([]byte, error) { return json.Marshal(t.String()) } // Metadata is used to store connection address type Metadata struct { NetWork NetWork `json:"network"` Type Type `json:"type"` SrcIP netip.Addr `json:"sourceIP"` DstIP netip.Addr `json:"destinationIP"` SrcPort string `json:"sourcePort"` DstPort string `json:"destinationPort"` AddrType int `json:"-"` Host string `json:"host"` DNSMode DNSMode `json:"dnsMode"` Process string `json:"process"` ProcessPath string `json:"processPath"` } func (m *Metadata) RemoteAddress() string { if m.DstIP.IsValid() { return net.JoinHostPort(m.DstIP.String(), m.DstPort) } else { return net.JoinHostPort(m.String(), m.DstPort) } } func (m *Metadata) SourceAddress() string { return net.JoinHostPort(m.SrcIP.String(), m.SrcPort) } func (m *Metadata) SourceDetail() string { if m.Type == INNER { return fmt.Sprintf("[%s]", ClashName) } if m.Process != "" { return fmt.Sprintf("%s(%s)", m.SourceAddress(), m.Process) } else { return fmt.Sprintf("%s", m.SourceAddress()) } } func (m *Metadata) Resolved() bool { return m.DstIP.IsValid() } // Pure is used to solve unexpected behavior // when dialing proxy connection in DNSMapping mode. func (m *Metadata) Pure() *Metadata { if m.DNSMode == DNSMapping && m.DstIP.IsValid() { copyM := *m copyM.Host = "" if copyM.DstIP.Is4() { copyM.AddrType = AtypIPv4 } else { copyM.AddrType = AtypIPv6 } return ©M } return m } func (m *Metadata) UDPAddr() *net.UDPAddr { if m.NetWork != UDP || !m.DstIP.IsValid() { return nil } port, _ := strconv.ParseUint(m.DstPort, 10, 16) return &net.UDPAddr{ IP: m.DstIP.AsSlice(), Port: int(port), } } func (m *Metadata) String() string { if m.Host != "" { return m.Host } else if m.DstIP.IsValid() { return m.DstIP.String() } else { return "" } } func (m *Metadata) Valid() bool { return m.Host != "" || m.DstIP.IsValid() }