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-02 14:03:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

improve sleep and add debug logs

Browse Source
This commit is contained in:
Gabriel mermelstein 2025-07-15 14:16:30 +02:00
parent 6314223966
commit d44007a30e
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
2 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
waku/nwaku_test_utils.go
View File

@ -138,7 +138,7 @@ func WaitForAutoConnection(nodeList []*WakuNode) error {
}
// Wait for the protocol connections to settle
time.Sleep(2 * time.Second)
time.Sleep(1 * time.Second)
Debug("Auto-connection check completed successfully")
return nil
}

8
waku/store_test.go
View File

@ -1181,12 +1181,20 @@ func TestStoredDuplicateMessage(t *testing.T) {
err = WaitForAutoConnection([]*WakuNode{node1, node2})
require.NoError(t, err, "Nodes did not connect within timeout")
peers1, err := node1.GetConnectedPeers()
require.NoError(t, err, "failed getting node1's peers")
fmt.Println("---------- node1 connected peers: ", peers1)
queryTimestamp := proto.Int64(time.Now().UnixNano())
var msg = node1.CreateMessage()
Debug("Node1 is publishing two identical messages")
_, err = node1.RelayPublishNoCTX(DefaultPubsubTopic, msg)
require.NoError(t, err, "Failed to publish first message")
peers2, err := node2.GetConnectedPeers()
require.NoError(t, err, "failed getting node2's peers")
fmt.Println("---------- node2 connected peers: ", peers2)
_, err = node2.RelayPublishNoCTX(DefaultPubsubTopic, msg)
require.NoError(t, err, "Failed to publish second message")