address.go 5.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223
  1. package net
  2. import (
  3. "bytes"
  4. "encoding/json"
  5. "github.com/golang/protobuf/jsonpb"
  6. "net"
  7. "strings"
  8. )
  9. var (
  10. // LocalHostIP is a constant value for localhost IP in IPv4.
  11. LocalHostIP = IPAddress([]byte{127, 0, 0, 1})
  12. // AnyIP is a constant value for any IP in IPv4.
  13. AnyIP = IPAddress([]byte{0, 0, 0, 0})
  14. // LocalHostDomain is a constant value for localhost domain.
  15. LocalHostDomain = DomainAddress("localhost")
  16. // LocalHostIPv6 is a constant value for localhost IP in IPv6.
  17. LocalHostIPv6 = IPAddress([]byte{0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 1})
  18. // AnyIPv6 is a constant value for any IP in IPv6.
  19. AnyIPv6 = IPAddress([]byte{0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0})
  20. )
  21. // AddressFamily is the type of address.
  22. type AddressFamily byte
  23. const (
  24. // AddressFamilyIPv4 represents address as IPv4
  25. AddressFamilyIPv4 = AddressFamily(0)
  26. // AddressFamilyIPv6 represents address as IPv6
  27. AddressFamilyIPv6 = AddressFamily(1)
  28. // AddressFamilyDomain represents address as Domain
  29. AddressFamilyDomain = AddressFamily(2)
  30. )
  31. // IsIPv4 returns true if current AddressFamily is IPv4.
  32. func (af AddressFamily) IsIPv4() bool {
  33. return af == AddressFamilyIPv4
  34. }
  35. // IsIPv6 returns true if current AddressFamily is IPv6.
  36. func (af AddressFamily) IsIPv6() bool {
  37. return af == AddressFamilyIPv6
  38. }
  39. // IsIP returns true if current AddressFamily is IPv6 or IPv4.
  40. func (af AddressFamily) IsIP() bool {
  41. return af == AddressFamilyIPv4 || af == AddressFamilyIPv6
  42. }
  43. // IsDomain returns true if current AddressFamily is Domain.
  44. func (af AddressFamily) IsDomain() bool {
  45. return af == AddressFamilyDomain
  46. }
  47. // Address represents a network address to be communicated with. It may be an IP address or domain
  48. // address, not both. This interface doesn't resolve IP address for a given domain.
  49. type Address interface {
  50. IP() net.IP // IP of this Address
  51. Domain() string // Domain of this Address
  52. Family() AddressFamily
  53. String() string // String representation of this Address
  54. }
  55. func isAlphaNum(c byte) bool {
  56. return (c >= '0' && c <= '9') || (c >= 'a' && c <= 'z') || (c >= 'A' && c <= 'Z')
  57. }
  58. // ParseAddress parses a string into an Address. The return value will be an IPAddress when
  59. // the string is in the form of IPv4 or IPv6 address, or a DomainAddress otherwise.
  60. func ParseAddress(addr string) Address {
  61. // Handle IPv6 address in form as "[2001:4860:0:2001::68]"
  62. lenAddr := len(addr)
  63. if lenAddr > 0 && addr[0] == '[' && addr[lenAddr-1] == ']' {
  64. addr = addr[1 : lenAddr-1]
  65. lenAddr -= 2
  66. }
  67. if lenAddr > 0 && (!isAlphaNum(addr[0]) || !isAlphaNum(addr[len(addr)-1])) {
  68. addr = strings.TrimSpace(addr)
  69. }
  70. ip := net.ParseIP(addr)
  71. if ip != nil {
  72. return IPAddress(ip)
  73. }
  74. return DomainAddress(addr)
  75. }
  76. var bytes0 = []byte{0, 0, 0, 0, 0, 0, 0, 0, 0, 0}
  77. // IPAddress creates an Address with given IP.
  78. func IPAddress(ip []byte) Address {
  79. switch len(ip) {
  80. case net.IPv4len:
  81. var addr ipv4Address = [4]byte{ip[0], ip[1], ip[2], ip[3]}
  82. return addr
  83. case net.IPv6len:
  84. if bytes.Equal(ip[:10], bytes0) && ip[10] == 0xff && ip[11] == 0xff {
  85. return IPAddress(ip[12:16])
  86. }
  87. var addr ipv6Address = [16]byte{
  88. ip[0], ip[1], ip[2], ip[3],
  89. ip[4], ip[5], ip[6], ip[7],
  90. ip[8], ip[9], ip[10], ip[11],
  91. ip[12], ip[13], ip[14], ip[15],
  92. }
  93. return addr
  94. default:
  95. newError("invalid IP format: ", ip).AtError().WriteToLog()
  96. return nil
  97. }
  98. }
  99. // DomainAddress creates an Address with given domain.
  100. func DomainAddress(domain string) Address {
  101. return domainAddress(domain)
  102. }
  103. type ipv4Address [4]byte
  104. func (a ipv4Address) IP() net.IP {
  105. return net.IP(a[:])
  106. }
  107. func (ipv4Address) Domain() string {
  108. panic("Calling Domain() on an IPv4Address.")
  109. }
  110. func (ipv4Address) Family() AddressFamily {
  111. return AddressFamilyIPv4
  112. }
  113. func (a ipv4Address) String() string {
  114. return a.IP().String()
  115. }
  116. type ipv6Address [16]byte
  117. func (a ipv6Address) IP() net.IP {
  118. return net.IP(a[:])
  119. }
  120. func (ipv6Address) Domain() string {
  121. panic("Calling Domain() on an IPv6Address.")
  122. }
  123. func (ipv6Address) Family() AddressFamily {
  124. return AddressFamilyIPv6
  125. }
  126. func (a ipv6Address) String() string {
  127. return "[" + a.IP().String() + "]"
  128. }
  129. type domainAddress string
  130. func (domainAddress) IP() net.IP {
  131. panic("Calling IP() on a DomainAddress.")
  132. }
  133. func (a domainAddress) Domain() string {
  134. return string(a)
  135. }
  136. func (domainAddress) Family() AddressFamily {
  137. return AddressFamilyDomain
  138. }
  139. func (a domainAddress) String() string {
  140. return a.Domain()
  141. }
  142. // AsAddress translates IPOrDomain to Address.
  143. func (d *IPOrDomain) AsAddress() Address {
  144. if d == nil {
  145. return nil
  146. }
  147. switch addr := d.Address.(type) {
  148. case *IPOrDomain_Ip:
  149. return IPAddress(addr.Ip)
  150. case *IPOrDomain_Domain:
  151. return DomainAddress(addr.Domain)
  152. }
  153. panic("Common|Net: Invalid address.")
  154. }
  155. // NewIPOrDomain translates Address to IPOrDomain
  156. func NewIPOrDomain(addr Address) *IPOrDomain {
  157. switch addr.Family() {
  158. case AddressFamilyDomain:
  159. return &IPOrDomain{
  160. Address: &IPOrDomain_Domain{
  161. Domain: addr.Domain(),
  162. },
  163. }
  164. case AddressFamilyIPv4, AddressFamilyIPv6:
  165. return &IPOrDomain{
  166. Address: &IPOrDomain_Ip{
  167. Ip: addr.IP(),
  168. },
  169. }
  170. default:
  171. panic("Unknown Address type.")
  172. }
  173. }
  174. func (d *IPOrDomain) UnmarshalJSONPB(unmarshaler *jsonpb.Unmarshaler, bytes []byte) error {
  175. var ipOrDomain string
  176. if err := json.Unmarshal(bytes, &ipOrDomain); err != nil {
  177. return err
  178. }
  179. result := NewIPOrDomain(ParseAddress(ipOrDomain))
  180. d.Address = result.Address
  181. return nil
  182. }