logos-messaging/logos-messaging-go-bindings
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-go-bindings.git synced 2026-01-07 16:33:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix test TestStoreQueryWithPaginationReverseOrder

Browse Source
This commit is contained in:
aya 2025-03-18 12:35:55 +02:00
parent e39e2e298c
commit 4bf65df24b
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
waku/store_test.go
View File

@ -404,6 +404,7 @@ func TestStoreQueryWithPaginationReverseOrder(t *testing.T) {
var sentHashes []common.MessageHash var sentHashes []common.MessageHash
defaultPubsubTopic := DefaultPubsubTopic defaultPubsubTopic := DefaultPubsubTopic
queryTimestamp := proto.Int64(time.Now().UnixNano())
Debug("Publishing %d messages from Node1 using RelayPublish", numMessages) Debug("Publishing %d messages from Node1 using RelayPublish", numMessages)
for i := 0; i < numMessages; i++ { for i := 0; i < numMessages; i++ {
message := node1.CreateMessage(&pb.WakuMessage{ message := node1.CreateMessage(&pb.WakuMessage{
@ -428,6 +429,7 @@ func TestStoreQueryWithPaginationReverseOrder(t *testing.T) {
ContentTopics: &[]string{"test-content-topic"}, ContentTopics: &[]string{"test-content-topic"},
PaginationLimit: proto.Uint64(5), PaginationLimit: proto.Uint64(5),
PaginationForward: false, PaginationForward: false,
TimeStart: queryTimestamp,
} }
res1, err := node3.GetStoredMessages(node2, &storeRequest1) res1, err := node3.GetStoredMessages(node2, &storeRequest1)
@ -436,6 +438,9 @@ func TestStoreQueryWithPaginationReverseOrder(t *testing.T) {
storedMessages1 := *res1.Messages storedMessages1 := *res1.Messages
require.Len(t, storedMessages1, 5, "Expected to retrieve exactly 5 messages from first query") require.Len(t, storedMessages1, 5, "Expected to retrieve exactly 5 messages from first query")
for i := 0; i < 5; i++ {
Debug("stored hashes round 2 iteration %i is %s", i, storedMessages1[i].MessageHash)
}
for i := 0; i < 5; i++ { for i := 0; i < 5; i++ {
require.Equal(t, sentHashes[i+3], storedMessages1[i].MessageHash, "Message order mismatch in first query") require.Equal(t, sentHashes[i+3], storedMessages1[i].MessageHash, "Message order mismatch in first query")
@ -445,9 +450,10 @@ func TestStoreQueryWithPaginationReverseOrder(t *testing.T) {
storeRequest2 := common.StoreQueryRequest{ storeRequest2 := common.StoreQueryRequest{
IncludeData: true, IncludeData: true,
ContentTopics: &[]string{"test-content-topic"}, ContentTopics: &[]string{"test-content-topic"},
PaginationLimit: proto.Uint64(5), PaginationLimit: proto.Uint64(3),
PaginationForward: false, PaginationForward: false,
PaginationCursor: &res1.PaginationCursor, PaginationCursor: &res1.PaginationCursor,
TimeStart: queryTimestamp,
} }
res2, err := node3.GetStoredMessages(node2, &storeRequest2) res2, err := node3.GetStoredMessages(node2, &storeRequest2)
@ -457,8 +463,8 @@ func TestStoreQueryWithPaginationReverseOrder(t *testing.T) {
storedMessages2 := *res2.Messages storedMessages2 := *res2.Messages
require.Len(t, storedMessages2, 3, "Expected to retrieve exactly 3 messages from second query") require.Len(t, storedMessages2, 3, "Expected to retrieve exactly 3 messages from second query")
for i := 2; i < 5; i++ { for i := 0; i < 3; i++ {
require.Equal(t, sentHashes[i-2], storedMessages2[i].MessageHash, "Message order mismatch in second query") require.Equal(t, sentHashes[i], storedMessages2[i].MessageHash, "Message order mismatch in second query")
} }