Track more info for observed addresses

p2p/protocol/identify/id.go

@@ -393,7 +393,8 @@ func (ids *IDService) consumeObservedAddress(observed []byte, c inet.Conn) {
 
 	// ok! we have the observed version of one of our ListenAddresses!
 	log.Debugf("added own observed listen addr: %s --> %s", c.LocalMultiaddr(), maddr)
-	ids.observedAddrs.Add(maddr, c.RemoteMultiaddr())
+	ids.observedAddrs.Add(maddr, c.LocalMultiaddr(), c.RemoteMultiaddr(),
+		c.Stat().Direction)
 }
 
 func addrInAddrs(a ma.Multiaddr, as []ma.Multiaddr) bool {

p2p/protocol/identify/obsaddr.go

@@ -4,6 +4,7 @@ import (
 	"sync"
 	"time"
 
+	net "github.com/libp2p/go-libp2p-net"
 	pstore "github.com/libp2p/go-libp2p-peerstore"
 	ma "github.com/multiformats/go-multiaddr"
 )
@@ -16,9 +17,11 @@ const ActivationThresh = 4
 // - have been observed at least once recently (1h), because our position in the
 //   network, or network port mapppings, may have changed.
 type ObservedAddr struct {
-	Addr      ma.Multiaddr
+	Addr          ma.Multiaddr // observed address by peers
+	InternalAddr  ma.Multiaddr // corresponding internal address
 	SeenBy        map[string]time.Time
 	LastSeen      time.Time
+	ConnDirection net.Direction
 	Activated     bool
 }
 
@@ -70,7 +73,9 @@ func (oas *ObservedAddrSet) Addrs() []ma.Multiaddr {
 	return addrs
 }
 
-func (oas *ObservedAddrSet) Add(addr ma.Multiaddr, observer ma.Multiaddr) {
+func (oas *ObservedAddrSet) Add(observed, local, observer ma.Multiaddr,
+	direction net.Direction) {
+
 	oas.Lock()
 	defer oas.Unlock()
 
@@ -80,14 +85,16 @@ func (oas *ObservedAddrSet) Add(addr ma.Multiaddr, observer ma.Multiaddr) {
 		oas.ttl = pstore.OwnObservedAddrTTL
 	}
 
-	s := addr.String()
+	s := observed.String()
 	oa, found := oas.addrs[s]
 
 	// first time seeing address.
 	if !found {
 		oa = &ObservedAddr{
-			Addr:   addr,
+			Addr:          observed,
+			InternalAddr:  local,
 			SeenBy:        make(map[string]time.Time),
+			ConnDirection: direction,
 		}
 		oas.addrs[s] = oa
 	}