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 00:13:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Revert "removing legacy store test"

Browse Source 
This reverts commit 9f3317591461a9618f45ff5af963be4c614e5865.
This commit is contained in:
Gabriel mermelstein 2025-05-30 11:09:42 +02:00
parent 9f33175914
commit ca714712ab
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
1 changed files with 49 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
waku/store_test.go
View File

@ -822,6 +822,55 @@ func TestCheckStoredMSGsEphemeralFalse(t *testing.T) {
Debug("Test finished successfully ")
}
func TestCheckLegacyStore(t *testing.T) {
Debug("Starting test ")
node1Config := DefaultWakuConfig
node1Config.Relay = true
Debug("Creating Node1 ")
node1, err := StartWakuNode("Node1", &node1Config)
require.NoError(t, err, "Failed to start Node1")
node2Config := DefaultWakuConfig
node2Config.Relay = true
node2Config.Store = true
node2Config.LegacyStore = true
Debug("Creating Node2")
node2, err := StartWakuNode("Node2", &node2Config)
require.NoError(t, err, "Failed to start Node2")
defer func() {
Debug("Stopping and destroying both nodes")
node1.StopAndDestroy()
node2.StopAndDestroy()
}()
Debug("Connecting Node2 to Node1")
err = node2.ConnectPeer(node1)
require.NoError(t, err, "Failed to connect Node2 to Node1")
queryTimestamp := proto.Int64(time.Now().UnixNano())
Debug("Sender Node1 is publishing a message")
message := node1.CreateMessage()
msgHash, err := node1.RelayPublishNoCTX(DefaultPubsubTopic, message)
require.NoError(t, err)
require.NotEmpty(t, msgHash)
Debug("Querying stored messages from Node2 using Node1")
storeQueryRequest := &common.StoreQueryRequest{
TimeStart: queryTimestamp,
}
storedmsgs, err := node1.GetStoredMessages(node2, storeQueryRequest)
require.NoError(t, err, "Failed to query store messages from Node2")
require.Equal(t, 1, len(*storedmsgs.Messages), "Expected exactly one stored message")
Debug("Test finished successfully ")
}
func TestStoredMessagesWithVDifferentPayloads(t *testing.T) {
Debug("Starting test ")