From 9207dbcb4acde3e47e845584f98b8107d9d1f4cf Mon Sep 17 00:00:00 2001 From: Richard Ramos Date: Thu, 1 Jun 2023 08:26:03 -0400 Subject: [PATCH] fix: addPeers --- waku/node.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/waku/node.go b/waku/node.go index d7340010..7c7db599 100644 --- a/waku/node.go +++ b/waku/node.go @@ -295,11 +295,6 @@ func Execute(options Options) { failOnErr(err, "Wakunode") - addPeers(wakuNode, options.Store.Nodes, store.StoreID_v20beta4) - addPeers(wakuNode, options.LightPush.Nodes, lightpush.LightPushID_v20beta1) - addPeers(wakuNode, options.Rendezvous.Nodes, rendezvous.RendezvousID) - addPeers(wakuNode, options.Filter.Nodes, filter.FilterSubscribeID_v20beta1) - if options.Filter.UseV1 { addPeers(wakuNode, options.Filter.NodesV1, legacy_filter.FilterID_v20beta1) } @@ -308,6 +303,11 @@ func Execute(options Options) { logger.Fatal("starting waku node", zap.Error(err)) } + addPeers(wakuNode, options.Store.Nodes, store.StoreID_v20beta4) + addPeers(wakuNode, options.LightPush.Nodes, lightpush.LightPushID_v20beta1) + addPeers(wakuNode, options.Rendezvous.Nodes, rendezvous.RendezvousID) + addPeers(wakuNode, options.Filter.Nodes, filter.FilterSubscribeID_v20beta1) + if options.DiscV5.Enable { if err = wakuNode.DiscV5().Start(ctx); err != nil { logger.Fatal("starting discovery v5", zap.Error(err))