diff --git a/waku/v2/protocol/relay/waku_relay_test.go b/waku/v2/protocol/relay/waku_relay_test.go index 06c2b19e..9b68507b 100644 --- a/waku/v2/protocol/relay/waku_relay_test.go +++ b/waku/v2/protocol/relay/waku_relay_test.go @@ -21,7 +21,6 @@ func TestWakuRelay(t *testing.T) { host, err := tests.MakeHost(context.Background(), port, rand.Reader) require.NoError(t, err) - relay := NewWakuRelay(nil, 0, timesource.NewDefaultClock(), utils.Logger()) relay.SetHost(host) err = relay.Start(context.Background()) diff --git a/waku/v2/rest/relay_test.go b/waku/v2/rest/relay_test.go index 7339702b..f61f0dfc 100644 --- a/waku/v2/rest/relay_test.go +++ b/waku/v2/rest/relay_test.go @@ -59,6 +59,9 @@ func TestRelaySubscription(t *testing.T) { go d.Start(context.Background()) defer d.Stop() + // Wait for node to start + time.Sleep(500 * time.Millisecond) + topics := []string{"test"} topicsJSONBytes, err := json.Marshal(topics) require.NoError(t, err) diff --git a/waku/v2/rpc/filter_test.go b/waku/v2/rpc/filter_test.go index dd4efef0..3260ea7a 100644 --- a/waku/v2/rpc/filter_test.go +++ b/waku/v2/rpc/filter_test.go @@ -39,7 +39,6 @@ func makeFilterService(t *testing.T, isFullNode bool) *FilterService { go func() { for range sub.Ch { } - fmt.Println("stuck") }() require.NoError(t, err) }