From aca80972b664b45b3f037fe2e00d6d8a7eb7bd1d Mon Sep 17 00:00:00 2001 From: Richard Ramos Date: Wed, 24 Mar 2021 09:49:43 -0400 Subject: [PATCH] Change mod name and remove unused parameter --- go.mod | 3 ++- go.sum | 2 ++ gossipsub.go | 2 +- 3 files changed, 5 insertions(+), 2 deletions(-) diff --git a/go.mod b/go.mod index 41d3c15..44e051e 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/libp2p/go-libp2p-pubsub +module github.com/status-im/go-wakurelay-pubsub go 1.13 @@ -10,6 +10,7 @@ require ( github.com/libp2p/go-libp2p-connmgr v0.2.4 github.com/libp2p/go-libp2p-core v0.7.0 github.com/libp2p/go-libp2p-discovery v0.5.0 + github.com/libp2p/go-libp2p-pubsub v0.4.1 github.com/libp2p/go-libp2p-swarm v0.3.1 github.com/libp2p/go-msgio v0.0.6 github.com/multiformats/go-multiaddr v0.3.1 diff --git a/go.sum b/go.sum index 97646f1..f4150f2 100644 --- a/go.sum +++ b/go.sum @@ -162,6 +162,8 @@ github.com/libp2p/go-libp2p-peerstore v0.2.6 h1:2ACefBX23iMdJU9Ke+dcXt3w86MIryes github.com/libp2p/go-libp2p-peerstore v0.2.6/go.mod h1:ss/TWTgHZTMpsU/oKVVPQCGuDHItOpf2W8RxAi50P2s= github.com/libp2p/go-libp2p-pnet v0.2.0 h1:J6htxttBipJujEjz1y0a5+eYoiPcFHhSYHH6na5f0/k= github.com/libp2p/go-libp2p-pnet v0.2.0/go.mod h1:Qqvq6JH/oMZGwqs3N1Fqhv8NVhrdYcO0BW4wssv21LA= +github.com/libp2p/go-libp2p-pubsub v0.4.1 h1:j4umIg5nyus+sqNfU+FWvb9aeYFQH/A+nDFhWj+8yy8= +github.com/libp2p/go-libp2p-pubsub v0.4.1/go.mod h1:izkeMLvz6Ht8yAISXjx60XUQZMq9ZMe5h2ih4dLIBIQ= github.com/libp2p/go-libp2p-swarm v0.2.8 h1:cIUUvytBzNQmGSjnXFlI6UpoBGsaud82mJPIJVfkDlg= github.com/libp2p/go-libp2p-swarm v0.2.8/go.mod h1:JQKMGSth4SMqonruY0a8yjlPVIkb0mdNSwckW7OYziM= github.com/libp2p/go-libp2p-swarm v0.3.1 h1:UTobu+oQHGdXTOGpZ4RefuVqYoJXcT0EBtSR74m2LkI= diff --git a/gossipsub.go b/gossipsub.go index 9f1a5b8..de55796 100644 --- a/gossipsub.go +++ b/gossipsub.go @@ -169,7 +169,7 @@ var ( ) // NewWakuRelaySub returns a new PubSub object using WakuRelaySubRouter as the router. -func NewWakuRelaySub(ctx context.Context, h host.Host, customProtocols []protocol.ID, opts ...Option) (*PubSub, error) { +func NewWakuRelaySub(ctx context.Context, h host.Host, opts ...Option) (*PubSub, error) { rt := &WakuRelaySubRouter{ peers: make(map[peer.ID]protocol.ID), mesh: make(map[string]map[peer.ID]struct{}),