diff --git a/libp2p/protocols/pubsub/gossipsub.nim b/libp2p/protocols/pubsub/gossipsub.nim index 3a50e05b92..1bb3c51168 100644 --- a/libp2p/protocols/pubsub/gossipsub.nim +++ b/libp2p/protocols/pubsub/gossipsub.nim @@ -193,7 +193,7 @@ method init*(g: GossipSub) = trace "GossipSub handler leaks an error", exc = exc.msg, conn g.handler = handler - g.codecs &= GossipSubCodec + g.codecs &= GossipSubCodec_11 g.codecs &= GossipSubCodec_10 method onNewPeer*(g: GossipSub, peer: PubSubPeer) = diff --git a/libp2p/protocols/pubsub/gossipsub/types.nim b/libp2p/protocols/pubsub/gossipsub/types.nim index 13dcb8809d..9db6755d40 100644 --- a/libp2p/protocols/pubsub/gossipsub/types.nim +++ b/libp2p/protocols/pubsub/gossipsub/types.nim @@ -18,7 +18,7 @@ import "../../.."/[peerid, multiaddress, utility] export options, tables, sets const - GossipSubCodec* = "/meshsub/1.1.0" + GossipSubCodec_11* = "/meshsub/1.1.0" GossipSubCodec_10* = "/meshsub/1.0.0" # overlay parameters diff --git a/tests/pubsub/utils.nim b/tests/pubsub/utils.nim index 94bbd4081d..355a1c2307 100644 --- a/tests/pubsub/utils.nim +++ b/tests/pubsub/utils.nim @@ -26,9 +26,9 @@ type proc getPubSubPeer*(p: TestGossipSub, peerId: PeerId): PubSubPeer = proc getConn(): Future[Connection] = - p.switch.dial(peerId, GossipSubCodec) + p.switch.dial(peerId, GossipSubCodec_11) - let pubSubPeer = PubSubPeer.new(peerId, getConn, nil, GossipSubCodec, 1024 * 1024) + let pubSubPeer = PubSubPeer.new(peerId, getConn, nil, GossipSubCodec_11, 1024 * 1024) debug "created new pubsub peer", peerId p.peers[peerId] = pubSubPeer