netip-addrport.go |  7 +++++++
 peerconn.go       | 11 ++++++++---
 peerconn_test.go  | 31 ++++++++++++++++++++++---------
 pex.go            | 43 +++++++++++++++++--------------------------
 pex_test.go       | 36 ++++++++++++++++++------------------
 pexconn_test.go   |  2 +-

diff --git a/netip-addrport.go b/netip-addrport.go
index 4e2dc94d2b3686997d60b8924005064d849d8a90..a57ea2067070a4f71668e1491bceada232f949aa 100644
--- a/netip-addrport.go
+++ b/netip-addrport.go
@@ -43,3 +43,10 @@ 	default:
 		return netip.ParseAddrPort(pra.String())
 	}
 }
+
+func krpcNodeAddrFromAddrPort(addrPort netip.AddrPort) krpc.NodeAddr {
+	return krpc.NodeAddr{
+		IP:   addrPort.Addr().AsSlice(),
+		Port: int(addrPort.Port()),
+	}
+}
diff --git a/peerconn.go b/peerconn.go
index 9915758332b7ca1408e58fd566008e3bba224e19..a9b835ac584ac9b11de2adff7cf21e0af597caee 100644
--- a/peerconn.go
+++ b/peerconn.go
@@ -1072,10 +1072,15 @@ 	}
 	return netip.AddrPortFrom(addrPort.Addr(), uint16(c.PeerListenPort))
 }
 
-func (c *PeerConn) pexEvent(t pexEventType) pexEvent {
+func (c *PeerConn) pexEvent(t pexEventType) (_ pexEvent, err error) {
 	f := c.pexPeerFlags()
-	addr := c.dialAddr()
-	return pexEvent{t, addr, f, nil}
+	dialAddr := c.dialAddr()
+	addr, err := addrPortFromPeerRemoteAddr(dialAddr)
+	if err != nil || !addr.IsValid() {
+		err = fmt.Errorf("parsing dial addr %q: %w", dialAddr, err)
+		return
+	}
+	return pexEvent{t, addr, f, nil}, nil
 }
 
 func (c *PeerConn) String() string {
diff --git a/peerconn_test.go b/peerconn_test.go
index e418e07e670fe85cf02315f8b93f614f2c58f80a..a107976b27a88cc30c5e1afa744cb0e948bdb7d5 100644
--- a/peerconn_test.go
+++ b/peerconn_test.go
@@ -181,6 +181,7 @@ 	}
 }
 
 func TestConnPexEvent(t *testing.T) {
+	c := qt.New(t)
 	var (
 		udpAddr     = &net.UDPAddr{IP: net.IPv6loopback, Port: 4848}
 		tcpAddr     = &net.TCPAddr{IP: net.IPv6loopback, Port: 4848}
@@ -195,27 +196,39 @@ 	}{
 		{
 			pexAdd,
 			&PeerConn{Peer: Peer{RemoteAddr: udpAddr, Network: udpAddr.Network()}},
-			pexEvent{pexAdd, udpAddr, pp.PexSupportsUtp, nil},
+			pexEvent{pexAdd, udpAddr.AddrPort(), pp.PexSupportsUtp, nil},
 		},
 		{
 			pexDrop,
-			&PeerConn{Peer: Peer{RemoteAddr: tcpAddr, Network: tcpAddr.Network(), outgoing: true}, PeerListenPort: dialTcpAddr.Port},
-			pexEvent{pexDrop, tcpAddr, pp.PexOutgoingConn, nil},
+			&PeerConn{
+				Peer:           Peer{RemoteAddr: tcpAddr, Network: tcpAddr.Network(), outgoing: true},
+				PeerListenPort: dialTcpAddr.Port,
+			},
+			pexEvent{pexDrop, tcpAddr.AddrPort(), pp.PexOutgoingConn, nil},
 		},
 		{
 			pexAdd,
-			&PeerConn{Peer: Peer{RemoteAddr: tcpAddr, Network: tcpAddr.Network()}, PeerListenPort: dialTcpAddr.Port},
-			pexEvent{pexAdd, dialTcpAddr, 0, nil},
+			&PeerConn{
+				Peer:           Peer{RemoteAddr: tcpAddr, Network: tcpAddr.Network()},
+				PeerListenPort: dialTcpAddr.Port,
+			},
+			pexEvent{pexAdd, dialTcpAddr.AddrPort(), 0, nil},
 		},
 		{
 			pexDrop,
-			&PeerConn{Peer: Peer{RemoteAddr: udpAddr, Network: udpAddr.Network()}, PeerListenPort: dialUdpAddr.Port},
-			pexEvent{pexDrop, dialUdpAddr, pp.PexSupportsUtp, nil},
+			&PeerConn{
+				Peer:           Peer{RemoteAddr: udpAddr, Network: udpAddr.Network()},
+				PeerListenPort: dialUdpAddr.Port,
+			},
+			pexEvent{pexDrop, dialUdpAddr.AddrPort(), pp.PexSupportsUtp, nil},
 		},
 	}
 	for i, tc := range testcases {
-		e := tc.c.pexEvent(tc.t)
-		require.EqualValues(t, tc.e, e, i)
+		c.Run(fmt.Sprintf("%v", i), func(c *qt.C) {
+			e, err := tc.c.pexEvent(tc.t)
+			c.Assert(err, qt.IsNil)
+			c.Check(e, qt.Equals, tc.e)
+		})
 	}
 }
 
diff --git a/pex.go b/pex.go
index c5ed6099d3f046636e0f86f51abc7d3a3efa7929..4770f3d3bbf7f1804d66f33b8c230207092d9a3c 100644
--- a/pex.go
+++ b/pex.go
@@ -2,9 +2,8 @@ package torrent
 
 import (
 	"net"
+	"net/netip"
 	"sync"
-
-	"github.com/anacrolix/dht/v2/krpc"
 
 	pp "github.com/anacrolix/torrent/peer_protocol"
 )
@@ -26,7 +25,7 @@
 // represents a single connection (t=pexAdd) or disconnection (t=pexDrop) event
 type pexEvent struct {
 	t    pexEventType
-	addr PeerRemoteAddr
+	addr netip.AddrPort
 	f    pp.PexPeerFlags
 	next *pexEvent // event feed list
 }
@@ -34,8 +33,8 @@
 // facilitates efficient de-duplication while generating PEX messages
 type pexMsgFactory struct {
 	msg     pp.PexMsg
-	added   map[addrKey]struct{}
-	dropped map[addrKey]struct{}
+	added   map[netip.AddrPort]struct{}
+	dropped map[netip.AddrPort]struct{}
 }
 
 func (me *pexMsgFactory) DeltaLen() int {
@@ -44,11 +43,11 @@ 		int64(len(me.added)),
 		int64(len(me.dropped))))
 }
 
-type addrKey string
+type addrKey = netip.AddrPort
 
 // Returns the key to use to identify a given addr in the factory.
-func (me *pexMsgFactory) addrKey(addr PeerRemoteAddr) addrKey {
-	return addrKey(addr.String())
+func (me *pexMsgFactory) addrKey(addr netip.AddrPort) addrKey {
+	return addr
 }
 
 // Returns whether the entry was added (we can check if we're cancelling out another entry and so
@@ -61,10 +60,7 @@ 	}
 	if me.added == nil {
 		me.added = make(map[addrKey]struct{}, pexMaxDelta)
 	}
-	addr, ok := nodeAddr(e.addr)
-	if !ok {
-		return
-	}
+	addr := krpcNodeAddrFromAddrPort(e.addr)
 	m := &me.msg
 	switch {
 	case addr.IP.To4() != nil:
@@ -96,10 +92,7 @@
 // Returns whether the entry was added (we can check if we're cancelling out another entry and so
 // won't hit the limit consuming this event).
 func (me *pexMsgFactory) drop(e pexEvent) {
-	addr, ok := nodeAddr(e.addr)
-	if !ok {
-		return
-	}
+	addr := krpcNodeAddrFromAddrPort(e.addr)
 	key := me.addrKey(e.addr)
 	if me.dropped == nil {
 		me.dropped = make(map[addrKey]struct{}, pexMaxDelta)
@@ -146,14 +139,6 @@ }
 
 func (me *pexMsgFactory) PexMsg() *pp.PexMsg {
 	return &me.msg
-}
-
-// Convert an arbitrary torrent peer Addr into one that can be represented by the compact addr
-// format.
-func nodeAddr(addr PeerRemoteAddr) (krpc.NodeAddr, bool) {
-	ipport, _ := tryIpPortFromNetAddr(addr)
-	ok := ipport.IP != nil
-	return krpc.NodeAddr{IP: ipport.IP, Port: ipport.Port}, ok
 }
 
 // Per-torrent PEX state
@@ -184,6 +169,10 @@ 	s.msg0.append(*e)
 }
 
 func (s *pexState) Add(c *PeerConn) {
+	e, err := c.pexEvent(pexAdd)
+	if err != nil {
+		return
+	}
 	s.Lock()
 	defer s.Unlock()
 	s.nc++
@@ -194,7 +183,6 @@ 			s.append(&ne)
 		}
 		s.hold = s.hold[:0]
 	}
-	e := c.pexEvent(pexAdd)
 	c.pex.Listed = true
 	s.append(&e)
 }
@@ -204,9 +192,12 @@ 	if !c.pex.Listed {
 		// skip connections which were not previously Added
 		return
 	}
+	e, err := c.pexEvent(pexDrop)
+	if err != nil {
+		return
+	}
 	s.Lock()
 	defer s.Unlock()
-	e := c.pexEvent(pexDrop)
 	s.nc--
 	if s.nc < pexTargAdded && len(s.hold) < pexMaxHold {
 		s.hold = append(s.hold, e)
diff --git a/pex_test.go b/pex_test.go
index 7d8f6d5d0528e8c14e9e58f75b2fe8fd6e9fed43..089e0df2c5f2c63045bce3335b5065b2aa95cabd 100644
--- a/pex_test.go
+++ b/pex_test.go
@@ -47,12 +47,12 @@ 	targ := new(pexState)
 	require.EqualValues(t, targ, s)
 }
 
-func mustNodeAddr(addr net.Addr) krpc.NodeAddr {
-	ret, ok := nodeAddr(addr)
-	if !ok {
-		panic(addr)
+func krpcNodeAddrFromNetAddr(addr net.Addr) krpc.NodeAddr {
+	addrPort, err := addrPortFromPeerRemoteAddr(addr)
+	if err != nil {
+		panic(err)
 	}
-	return ret
+	return krpcNodeAddrFromAddrPort(addrPort)
 }
 
 var testcases = []struct {
@@ -99,13 +99,13 @@ 			return s
 		}(),
 		targ: pp.PexMsg{
 			Added: krpc.CompactIPv4NodeAddrs{
-				mustNodeAddr(addrs[2]),
-				mustNodeAddr(addrs[3]),
+				krpcNodeAddrFromNetAddr(addrs[2]),
+				krpcNodeAddrFromNetAddr(addrs[3]),
 			},
 			AddedFlags: []pp.PexPeerFlags{pp.PexOutgoingConn, 0},
 			Added6: krpc.CompactIPv6NodeAddrs{
-				mustNodeAddr(addrs[0]),
-				mustNodeAddr(addrs[1]),
+				krpcNodeAddrFromNetAddr(addrs[0]),
+				krpcNodeAddrFromNetAddr(addrs[1]),
 			},
 			Added6Flags: []pp.PexPeerFlags{0, pp.PexOutgoingConn},
 		},
@@ -120,10 +120,10 @@ 			return s
 		}(),
 		targ: pp.PexMsg{
 			Dropped: krpc.CompactIPv4NodeAddrs{
-				mustNodeAddr(addrs[2]),
+				krpcNodeAddrFromNetAddr(addrs[2]),
 			},
 			Dropped6: krpc.CompactIPv6NodeAddrs{
-				mustNodeAddr(addrs[0]),
+				krpcNodeAddrFromNetAddr(addrs[0]),
 			},
 		},
 	},
@@ -144,7 +144,7 @@ 			return s
 		}(),
 		targ: pp.PexMsg{
 			Added6: krpc.CompactIPv6NodeAddrs{
-				mustNodeAddr(addrs[1]),
+				krpcNodeAddrFromNetAddr(addrs[1]),
 			},
 			Added6Flags: []pp.PexPeerFlags{0},
 		},
@@ -168,12 +168,12 @@ 			return s
 		}(),
 		targ: pp.PexMsg{
 			Added: krpc.CompactIPv4NodeAddrs{
-				mustNodeAddr(addrs[2]),
+				krpcNodeAddrFromNetAddr(addrs[2]),
 			},
 			AddedFlags: []pp.PexPeerFlags{0},
 			Added6: krpc.CompactIPv6NodeAddrs{
-				mustNodeAddr(addrs[0]),
-				mustNodeAddr(addrs[1]),
+				krpcNodeAddrFromNetAddr(addrs[0]),
+				krpcNodeAddrFromNetAddr(addrs[1]),
 			},
 			Added6Flags: []pp.PexPeerFlags{0, 0},
 		},
@@ -193,7 +193,7 @@ 			return s
 		}(),
 		targ: pp.PexMsg{
 			Added6: krpc.CompactIPv6NodeAddrs{
-				mustNodeAddr(addrs[1]),
+				krpcNodeAddrFromNetAddr(addrs[1]),
 			},
 			Added6Flags: []pp.PexPeerFlags{0},
 		},
@@ -207,7 +207,7 @@ 			return s
 		}(),
 		targ: pp.PexMsg{
 			Added6: krpc.CompactIPv6NodeAddrs{
-				mustNodeAddr(addrs[0]),
+				krpcNodeAddrFromNetAddr(addrs[0]),
 			},
 			Added6Flags: []pp.PexPeerFlags{0},
 		},
@@ -216,7 +216,7 @@ 			s.Add(&PeerConn{Peer: Peer{RemoteAddr: addrs[1]}})
 		},
 		targ1: pp.PexMsg{
 			Added6: krpc.CompactIPv6NodeAddrs{
-				mustNodeAddr(addrs[1]),
+				krpcNodeAddrFromNetAddr(addrs[1]),
 			},
 			Added6Flags: []pp.PexPeerFlags{0},
 		},
diff --git a/pexconn_test.go b/pexconn_test.go
index 603398c54cc93fb3927617b8f2938acbb960b8a7..f8b9c9e07ae162a7e384855fd96669976f4fa446 100644
--- a/pexconn_test.go
+++ b/pexconn_test.go
@@ -53,7 +53,7 @@ 	targx := pp.PexMsg{
 		Added:      krpc.CompactIPv4NodeAddrs(nil),
 		AddedFlags: []pp.PexPeerFlags{},
 		Added6: krpc.CompactIPv6NodeAddrs{
-			mustNodeAddr(addr),
+			krpcNodeAddrFromNetAddr(addr),
 		},
 		Added6Flags: []pp.PexPeerFlags{0},
 	}