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-28 10:23:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix review points

Browse Source
This commit is contained in:
aya 2025-02-19 11:40:37 +02:00
parent e53eb9d583
commit 2f789647a2
1 changed files with 2 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
waku/relay_test.go
View File

@ -94,18 +94,13 @@ func TestRelayMessageTransmission(t *testing.T) {
err = WaitForAutoConnection([]*WakuNode{senderNode, receiverNode})
require.NoError(t, err, "Nodes did not auto-connect within timeout")
Debug("Subscribing ReceiverNode to the default pubsub topic")
defaultPubsubTopic := DefaultPubsubTopic
err = receiverNode.RelaySubscribe(defaultPubsubTopic)
require.NoError(t, err)
Debug("Creating and publishing message")
message := senderNode.CreateMessage()
var msgHash string
err = RetryWithBackOff(func() error {
var err error
msgHashObj, err := senderNode.RelayPublishNoCTX(defaultPubsubTopic, message)
msgHashObj, err := senderNode.RelayPublishNoCTX(DefaultPubsubTopic, message)
if err == nil {
msgHash = msgHashObj.String()
}
@ -147,12 +142,6 @@ func TestRelayMessageBroadcast(t *testing.T) {
nodes[i] = node
}
Debug("Subscribing nodes to the default pubsub topic")
for _, node := range nodes {
err := node.RelaySubscribe(defaultPubsubTopic)
require.NoError(t, err)
}
WaitForAutoConnection(nodes)
senderNode := nodes[0]
@ -198,10 +187,6 @@ func TestSendmsgInvalidPayload(t *testing.T) {
require.NoError(t, err)
defer receiverNode.StopAndDestroy()
Debug("Subscribing SenderNode to the default pubsub topic")
err = senderNode.RelaySubscribe(defaultPubsubTopic)
require.NoError(t, err)
err = WaitForAutoConnection([]*WakuNode{senderNode, receiverNode})
require.NoError(t, err, "Nodes did not auto-connect within timeout")
@ -265,22 +250,13 @@ func TestRelayNodesNotConnectedDirectly(t *testing.T) {
require.NoError(t, err)
defer node3.StopAndDestroy()
Debug("Subscribing Node2 to the default pubsub topic")
defaultPubsubTopic := DefaultPubsubTopic
err = node2.RelaySubscribe(defaultPubsubTopic)
require.NoError(t, err)
Debug("Subscribing Node3 to the default pubsub topic")
err = node3.RelaySubscribe(defaultPubsubTopic)
require.NoError(t, err)
Debug("Waiting for nodes to connect before proceeding")
err = WaitForAutoConnection([]*WakuNode{senderNode, node2, node3})
require.NoError(t, err, "Nodes did not connect within timeout")
Debug("SenderNode is publishing a message")
message := senderNode.CreateMessage()
msgHash, err := senderNode.RelayPublishNoCTX(defaultPubsubTopic, message)
msgHash, err := senderNode.RelayPublishNoCTX(DefaultPubsubTopic, message)
require.NoError(t, err)
require.NotEmpty(t, msgHash)
@ -340,18 +316,6 @@ func TestRelaySubscribeAndPeerCountChange(t *testing.T) {
err = WaitForAutoConnection([]*WakuNode{node1, node2, node3})
require.NoError(t, err, "Nodes did not connect within timeout")
Debug("Subscribing Node1 to the default pubsub topic: %s", defaultPubsubTopic)
err = node1.RelaySubscribe(defaultPubsubTopic)
require.NoError(t, err)
Debug("Subscribing Node2 to the default pubsub topic: %s", defaultPubsubTopic)
err = node2.RelaySubscribe(defaultPubsubTopic)
require.NoError(t, err)
Debug("Subscribing Node3 to the default pubsub topic: %s", defaultPubsubTopic)
err = node3.RelaySubscribe(defaultPubsubTopic)
require.NoError(t, err)
Debug("Waiting for peer connections to stabilize")
options := func(b *backoff.ExponentialBackOff) {
b.MaxElapsedTime = 10 * time.Second // Only set the max wait time