From 4c804a954a1c0aa153006a16b1981612d6bc738a Mon Sep 17 00:00:00 2001 From: Yusef Napora Date: Wed, 22 Jan 2020 10:23:47 -0500 Subject: [PATCH] track changes to peer records in -core --- gossipsub.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/gossipsub.go b/gossipsub.go index 7a03c33..7d6714b 100644 --- a/gossipsub.go +++ b/gossipsub.go @@ -3,6 +3,7 @@ package pubsub import ( "context" "fmt" + "github.com/libp2p/go-libp2p-core/record" "math/rand" "time" @@ -311,16 +312,16 @@ func (gs *GossipSubRouter) pxConnect(peers []*pb.PeerInfo) { // the peer sent us a signed record; ensure that it is valid envelope, r, err := record.ConsumeEnvelope(pi.SignedPeerRecord, peer.PeerRecordEnvelopeDomain) if err != nil { - log.Warnf("error unmarshalling peer record obtained through px: %s", err) + log.Warningf("error unmarshalling peer record obtained through px: %s", err) continue } rec, ok := r.(*peer.PeerRecord) if !ok { - log.Warnf("bogus peer record obtained through px: envelope payload is not PeerRecord") + log.Warningf("bogus peer record obtained through px: envelope payload is not PeerRecord") continue } if rec.PeerID != p { - log.Warnf("bogus peer record obtained through px: peer ID %s doesn't match expected peer %s", rec.PeerID, p) + log.Warningf("bogus peer record obtained through px: peer ID %s doesn't match expected peer %s", rec.PeerID, p) continue } spr = envelope