From 68eca51a2ea7e595607d51e5244e7b5bda7e4b56 Mon Sep 17 00:00:00 2001 From: Fabiana Cecin Date: Tue, 21 Oct 2025 12:14:21 -0300 Subject: [PATCH 1/2] fix test TestStressStoreQuery5kMessagesWithPagination (#70) --- waku/stress_test.go | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/waku/stress_test.go b/waku/stress_test.go index 44fd484..d5b4da9 100644 --- a/waku/stress_test.go +++ b/waku/stress_test.go @@ -79,14 +79,15 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) { require.NoError(t, err, "Failed to start Waku node") node2.ConnectPeer(wakuNode) + time.Sleep(200 * time.Millisecond) + defer func() { Debug("Stopping and destroying Waku node") wakuNode.StopAndDestroy() node2.StopAndDestroy() }() - - iterations := 1000 + iterations := 2500 captureMemory(t.Name(), "at start") @@ -95,9 +96,14 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) { for i := 0; i < iterations; i++ { message := wakuNode.CreateMessage() message.Payload = []byte(fmt.Sprintf("Test endurance message payload %d", i)) - _, err := wakuNode.RelayPublishNoCTX(DefaultPubsubTopic, message) + hash, err := wakuNode.RelayPublishNoCTX(DefaultPubsubTopic, message) require.NoError(t, err, "Failed to publish message") + err = node2.VerifyMessageReceived(message, hash) + require.NoError(t, err, "node2 failed to receive message %d", i) + err = wakuNode.VerifyMessageReceived(message, hash) + require.NoError(t, err, "wakuNode failed to receive message %d", i) + if i%10 == 0 { storeQueryRequest := &common.StoreQueryRequest{ From 7b46909177e6108f81980885cdcfc087259d2c04 Mon Sep 17 00:00:00 2001 From: Fabiana Cecin Date: Tue, 21 Oct 2025 12:19:45 -0300 Subject: [PATCH 2/2] Fix tabs vs. spaces ident --- waku/stress_test.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/waku/stress_test.go b/waku/stress_test.go index d5b4da9..ceea537 100644 --- a/waku/stress_test.go +++ b/waku/stress_test.go @@ -99,9 +99,9 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) { hash, err := wakuNode.RelayPublishNoCTX(DefaultPubsubTopic, message) require.NoError(t, err, "Failed to publish message") - err = node2.VerifyMessageReceived(message, hash) + err = node2.VerifyMessageReceived(message, hash) require.NoError(t, err, "node2 failed to receive message %d", i) - err = wakuNode.VerifyMessageReceived(message, hash) + err = wakuNode.VerifyMessageReceived(message, hash) require.NoError(t, err, "wakuNode failed to receive message %d", i) if i%10 == 0 {