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 TestStoreQueryWithWrongContentTopic

Browse Source
This commit is contained in:
aya 2025-03-19 10:54:22 +02:00
parent 2690e05f5a
commit 4d2c8b7cfd
1 changed files with 47 additions and 50 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

97
waku/store_test.go
View File

@ -658,67 +658,66 @@ func TestStoreQueryWithoutData(t *testing.T) {
Debug("Test successfully verified that store query returns only message hashes when IncludeData is false") Debug("Test successfully verified that store query returns only message hashes when IncludeData is false")
} }
/* func TestStoreQueryWithWrongContentTopic(t *testing.T) {
func TestStoreQueryWithWrongContentTopic(t *testing.T) { Debug("Starting test to verify store query fails when using an incorrect content topic and an old timestamp")
Debug("Starting test to verify store query fails when using an incorrect content topic and an old timestamp")
node1Config := DefaultWakuConfig node1Config := DefaultWakuConfig
node1Config.Relay = true node1Config.Relay = true
Debug("Creating Node1 with Relay enabled") Debug("Creating Node1 with Relay enabled")
node1, err := StartWakuNode("Node1", &node1Config) node1, err := StartWakuNode("Node1", &node1Config)
require.NoError(t, err, "Failed to start Node1") require.NoError(t, err, "Failed to start Node1")
node2Config := DefaultWakuConfig node2Config := DefaultWakuConfig
node2Config.Relay = true node2Config.Relay = true
node2Config.Store = true node2Config.Store = true
Debug("Creating Node2 with Store enabled") Debug("Creating Node2 with Store enabled")
node2, err := StartWakuNode("Node2", &node2Config) node2, err := StartWakuNode("Node2", &node2Config)
require.NoError(t, err, "Failed to start Node2") require.NoError(t, err, "Failed to start Node2")
node3Config := DefaultWakuConfig node3Config := DefaultWakuConfig
node3Config.Relay = true node3Config.Relay = true
Debug("Creating Node3") Debug("Creating Node3")
node3, err := StartWakuNode("Node3", &node3Config) node3, err := StartWakuNode("Node3", &node3Config)
require.NoError(t, err, "Failed to start Node3") require.NoError(t, err, "Failed to start Node3")
defer func() { defer func() {
Debug("Stopping and destroying all Waku nodes") Debug("Stopping and destroying all Waku nodes")
node1.StopAndDestroy() node1.StopAndDestroy()
node2.StopAndDestroy() node2.StopAndDestroy()
node3.StopAndDestroy() node3.StopAndDestroy()
}() }()
Debug("Connecting Node2 to Node1") Debug("Connecting Node2 to Node1")
err = node2.ConnectPeer(node1) err = node2.ConnectPeer(node1)
require.NoError(t, err, "Failed to connect Node2 to Node1") require.NoError(t, err, "Failed to connect Node2 to Node1")
Debug("Connecting Node3 to Node2") Debug("Connecting Node3 to Node2")
err = node3.ConnectPeer(node2) err = node3.ConnectPeer(node2)
require.NoError(t, err, "Failed to connect Node3 to Node2") require.NoError(t, err, "Failed to connect Node3 to Node2")
Debug("Recording timestamp before message publication") Debug("Recording timestamp before message publication")
queryTimestamp := proto.Int64(time.Now().UnixNano()) queryTimestamp := proto.Int64(time.Now().UnixNano())
Debug("Sender Node1 is publishing a message with a correct content topic") Debug("Sender Node1 is publishing a message with a correct content topic")
message := node1.CreateMessage() message := node1.CreateMessage()
msgHash, err := node1.RelayPublishNoCTX(DefaultPubsubTopic, message) msgHash, err := node1.RelayPublishNoCTX(DefaultPubsubTopic, message)
require.NoError(t, err) require.NoError(t, err)
require.NotEmpty(t, msgHash) require.NotEmpty(t, msgHash)
Debug("Querying stored messages from Node3 with an incorrect content topic and an old timestamp") Debug("Querying stored messages from Node3 with an incorrect content topic and an old timestamp")
storeQueryRequest := &common.StoreQueryRequest{ storeQueryRequest := &common.StoreQueryRequest{
ContentTopics: &[]string{"incorrect-content-topic"}, ContentTopics: &[]string{"incorrect-content-topic"},
TimeStart: queryTimestamp, TimeStart: queryTimestamp,
}
storedmsgs, _ := node3.GetStoredMessages(node2, storeQueryRequest)
require.Nil(t, (*storedmsgs.Messages)[0], "Expected no messages to be returned for incorrect content topic and timestamp")
Debug("Test successfully verified that store query fails when using an incorrect content topic and an old timestamp")
} }
*/
storedmsgs, _ := node3.GetStoredMessages(node2, storeQueryRequest)
require.Empty(t, (*storedmsgs.Messages), "Expected no messages to be returned for incorrect content topic and timestamp")
Debug("Test successfully verified that store query fails when using an incorrect content topic and an old timestamp")
}
func TestCheckStoredMSGsEphemeralTrue(t *testing.T) { func TestCheckStoredMSGsEphemeralTrue(t *testing.T) {
Debug("Starting test to verify ephemeral messages are not stored") Debug("Starting test to verify ephemeral messages are not stored")
@ -823,7 +822,6 @@ func TestCheckStoredMSGsEphemeralFalse(t *testing.T) {
Debug("Test finished successfully ") Debug("Test finished successfully ")
} }
/*
func TestCheckLegacyStore(t *testing.T) { func TestCheckLegacyStore(t *testing.T) {
Debug("Starting test ") Debug("Starting test ")
@ -872,7 +870,6 @@ func TestCheckLegacyStore(t *testing.T) {
Debug("Test finished successfully ") Debug("Test finished successfully ")
} }
*/
func TestStoredMessagesWithVDifferentPayloads(t *testing.T) { func TestStoredMessagesWithVDifferentPayloads(t *testing.T) {
Debug("Starting test ") Debug("Starting test ")