From 68eca51a2ea7e595607d51e5244e7b5bda7e4b56 Mon Sep 17 00:00:00 2001 From: Fabiana Cecin Date: Tue, 21 Oct 2025 12:14:21 -0300 Subject: [PATCH] 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{