Sort addresses in /id

api/util.go

@@ -2,7 +2,6 @@ package api
 
 import (
 	peer "github.com/libp2p/go-libp2p-core/peer"
-	ma "github.com/multiformats/go-multiaddr"
 )
 
 // PeersToStrings IDB58Encodes a list of peers.
@@ -29,16 +28,3 @@ func StringsToPeers(strs []string) []peer.ID {
 	}
 	return peers
 }
-
-// MustLibp2pMultiaddrJoin takes a LibP2P multiaddress and a peer ID and
-// encapsulates a new /ipfs/<peerID> address. It will panic if the given
-// peer ID is bad.
-func MustLibp2pMultiaddrJoin(addr Multiaddr, p peer.ID) Multiaddr {
-	v := addr.Value()
-	pidAddr, err := ma.NewMultiaddr("/ipfs/" + peer.IDB58Encode(p))
-	// let this break badly
-	if err != nil {
-		panic("called MustLibp2pMultiaddrJoin with bad peer!")
-	}
-	return Multiaddr{Multiaddr: v.Encapsulate(pidAddr)}
-}

cluster.go

@@ -721,15 +721,11 @@ func (c *Cluster) ID(ctx context.Context) *api.ID {
 			Error: err.Error(),
 		}
 	}
-	var addrs []api.Multiaddr
 
-	addrsSet := make(map[string]struct{}) // to filter dups
-	for _, addr := range c.host.Addrs() {
-		addrsSet[addr.String()] = struct{}{}
-	}
-	for k := range addrsSet {
-		addr, _ := api.NewMultiaddr(k)
-		addrs = append(addrs, api.MustLibp2pMultiaddrJoin(addr, c.id))
+	var addrs []api.Multiaddr
+	mAddrs, _ := peer.AddrInfoToP2pAddrs(&peer.AddrInfo{ID: c.id, Addrs: c.host.Addrs()})
+	for _, mAddr := range mAddrs {
+		addrs = append(addrs, api.NewMultiaddrWithValue(mAddr))
 	}
 
 	peers := []peer.ID{}

pstoremgr/pstoremgr.go

@@ -15,6 +15,7 @@ import (
 	"time"
 
 	logging "github.com/ipfs/go-log"
+	utils "github.com/ipfs/ipfs-cluster/utils"
 	host "github.com/libp2p/go-libp2p-core/host"
 	net "github.com/libp2p/go-libp2p-core/network"
 	peer "github.com/libp2p/go-libp2p-core/peer"
@@ -142,6 +143,7 @@ func (pm *Manager) filteredPeerAddrs(p peer.ID) []ma.Multiaddr {
 		return peerDNSAddrs
 	}
 
+	sort.Sort(utils.ByString(peerAddrs))
 	return peerAddrs
 }
 

utils/utils.go

@@ -0,0 +1,12 @@
+package utils
+
+import (
+	ma "github.com/multiformats/go-multiaddr"
+)
+
+// ByString can sort multiaddresses by its string
+type ByString []ma.Multiaddr
+
+func (m ByString) Len() int           { return len(m) }
+func (m ByString) Swap(i, j int)      { m[i], m[j] = m[j], m[i] }
+func (m ByString) Less(i, j int) bool { return m[i].String() < m[j].String() }