From 6fc8050bac14d1cc52822f053651f06648b50d07 Mon Sep 17 00:00:00 2001 From: vyzo Date: Thu, 21 Nov 2019 23:13:20 +0200 Subject: [PATCH] protocol ID for gossipsub v1.1 --- gossipsub.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/gossipsub.go b/gossipsub.go index 31c5724..2decff3 100644 --- a/gossipsub.go +++ b/gossipsub.go @@ -14,7 +14,8 @@ import ( ) const ( - GossipSubID = protocol.ID("/meshsub/1.0.0") + GossipSubID = protocol.ID("/meshsub/1.0.0") + GossipSubID_v11 = protocol.ID("/meshsub/1.1.0") ) var ( @@ -69,7 +70,7 @@ type GossipSubRouter struct { } func (gs *GossipSubRouter) Protocols() []protocol.ID { - return []protocol.ID{GossipSubID, FloodSubID} + return []protocol.ID{GossipSubID_v11, GossipSubID, FloodSubID} } func (gs *GossipSubRouter) Attach(p *PubSub) { @@ -681,7 +682,7 @@ func (gs *GossipSubRouter) getPeers(topic string, count int, filter func(peer.ID peers := make([]peer.ID, 0, len(tmap)) for p := range tmap { - if gs.peers[p] == GossipSubID && filter(p) { + if (gs.peers[p] == GossipSubID || gs.peers[p] == GossipSubID_v11) && filter(p) { peers = append(peers, p) } }