From 4ce04a2abfcbafae2c38d54f06b16aef7c97c9ae Mon Sep 17 00:00:00 2001 From: Reisen Date: Thu, 21 Sep 2023 10:10:00 +0000 Subject: [PATCH] feat(hermes): print libp2p peer addresses --- hermes/src/network/p2p.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/hermes/src/network/p2p.go b/hermes/src/network/p2p.go index c33fa78eb5..306ee8a63b 100644 --- a/hermes/src/network/p2p.go +++ b/hermes/src/network/p2p.go @@ -175,6 +175,16 @@ func RegisterObservationCallback(f C.callback_t, network_id, bootstrap_addrs, li idht, err := dht.New(ctx, h, dht.Mode(dht.ModeServer), dht.ProtocolPrefix(protocol.ID("/"+networkID)), dht.BootstrapPeers(bootstrappers...), + dht.RoutingTableFilter(func(dht interface{}, p peer.ID) bool { + peerInfo := h.Peerstore().PeerInfo(p) + fmt.Printf("Accepted Peer: %s; Addresses: ", peerInfo.ID) + for _, addr := range peerInfo.Addrs { + fmt.Printf("%s ", addr) + } + fmt.Println("") + + return true + }), ) return idht, err }),