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-05 07:23:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/master' into stress_test

Browse Source
This commit is contained in:
aya 2025-03-09 12:16:22 +02:00
commit 01b6d5d24a
3 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
.gitignore vendored
View File

@ -23,3 +23,9 @@ go.work
# Generated dependencies and cache
third_party
nimcache
waku/store.sqlite3
waku/store.sqlite3-shm
waku/store.sqlite3-wal

2
waku/nwaku_test_utils.go
View File

@ -233,7 +233,7 @@ func (n *WakuNode) GetStoredMessages(storeNode *WakuNode, storeRequest *common.S
if len(storeMultiaddr) == 0 {
Error("Store node has no available listen addresses")
return nil, fmt.Errorf("store node has no available listen addresses")
return nil, errors.New("store node has no available listen addresses")
}
storeNodeAddrInfo, err := peer.AddrInfoFromString(storeMultiaddr[0].String())

18
waku/store_test.go
View File

@ -148,7 +148,7 @@ func TestStoreQueryMultipleMessages(t *testing.T) {
}
Debug("Waiting for message delivery to Node2")
time.Sleep(5 * time.Second)
time.Sleep(1 * time.Second)
Debug("Node3 querying stored messages from Node2")
res, err := node3.GetStoredMessages(node2, nil)
@ -230,7 +230,7 @@ func TestStoreQueryWith5Pagination(t *testing.T) {
}
Debug("Waiting for message delivery to Node2")
time.Sleep(5 * time.Second)
time.Sleep(1 * time.Second)
Debug("Node3 querying stored messages from Node2 with PaginationLimit = 5")
storeRequest := common.StoreQueryRequest{
@ -313,7 +313,7 @@ func TestStoreQueryWithPaginationMultiplePages(t *testing.T) {
}
Debug("Waiting for message delivery to Node2")
time.Sleep(5 * time.Second)
time.Sleep(1 * time.Second)
Debug("Node3 querying first page of stored messages from Node2")
storeRequest1 := common.StoreQueryRequest{
@ -419,7 +419,7 @@ func TestStoreQueryWithPaginationReverseOrder(t *testing.T) {
}
Debug("Waiting for message delivery to Node2")
time.Sleep(5 * time.Second)
time.Sleep(1 * time.Second)
Debug("Node3 querying first page of stored messages from Node2 (Newest first)")
storeRequest1 := common.StoreQueryRequest{
@ -463,7 +463,7 @@ func TestStoreQueryWithPaginationReverseOrder(t *testing.T) {
Debug("Test successfully verified store query pagination in reverse order")
}
func TestQueryFailwhenNoStorePeer(t *testing.T) {
func TestQueryFailWhenNoStorePeer(t *testing.T) {
Debug("Starting test to verify store query failure when node2 has no store")
node1Config := DefaultWakuConfig
@ -633,10 +633,6 @@ func TestStoreQueryWithoutData(t *testing.T) {
storedmsgs, err := node3.GetStoredMessages(node2, storeQueryRequest)
require.NoError(t, err, "Failed to query store messages from Node2")
require.NotNil(t, storedmsgs.Messages, "Expected store response to contain message hashes")
//require.Len(t, *storedmsgs.Messages, 1, "Expected exactly one stored message")
// Access the first message
// firstMessage := (*storedmsgs.Messages)[0]
firstMessage := (*storedmsgs.Messages)[0]
require.Nil(t, firstMessage.WakuMessage, "Expected message payload to be empty when IncludeData is false")
@ -702,9 +698,7 @@ func TestStoreQueryWithWrongContentTopic(t *testing.T) {
}
storedmsgs, _ := node3.GetStoredMessages(node2, storeQueryRequest)
//require.Error(t, err, "Expected error when querying with an incorrect content topic and old timestamp")
require.Nil(t, (*storedmsgs.Messages)[0], "Expected no messages to be returned for incorrect content topic and timestamp")
//Debug("Queried message hash: %s", (*storedmsgs.Messages)[0].MessageHash)
Debug("Test successfully verified that store query fails when using an incorrect content topic and an old timestamp")
}
@ -1138,7 +1132,7 @@ func TestStoredMessagesWithVersionField(t *testing.T) {
Debug("Test finished successfully ")
}
func TestStoredDublicateMessage(t *testing.T) {
func TestStoredDuplicateMessage(t *testing.T) {
Debug("Starting test")
node1Config := DefaultWakuConfig