import (
"fmt"
- "net"
"net/netip"
"github.com/anacrolix/dht/v2/krpc"
)
+type addrPorter interface {
+ AddrPort() netip.AddrPort
+}
+
func ipv4AddrPortFromKrpcNodeAddr(na krpc.NodeAddr) (_ netip.AddrPort, err error) {
ip4 := na.IP.To4()
if ip4 == nil {
func addrPortFromPeerRemoteAddr(pra PeerRemoteAddr) (netip.AddrPort, error) {
switch v := pra.(type) {
- case *net.TCPAddr:
- return v.AddrPort(), nil
- case *net.UDPAddr:
+ case addrPorter:
return v.AddrPort(), nil
case netip.AddrPort:
return v, nil
return netip.ParseAddrPort(pra.String())
}
}
+
+func krpcNodeAddrFromAddrPort(addrPort netip.AddrPort) krpc.NodeAddr {
+ return krpc.NodeAddr{
+ IP: addrPort.Addr().AsSlice(),
+ Port: int(addrPort.Port()),
+ }
+}