mirror of
https://github.com/logos-messaging/logos-messaging-go-bindings.git
synced 2026-08-25 09:51:16 +00:00
Igor Sirotin
c3768ff3fc
Move the Messaging API back out of pkg/kernel: ffi.Handle becomes a defined type in the internal package, so kernel can hand the context to pkg/messaging through kernel.Handle without the kernel layer knowing the tier exists, and without the type being nameable outside this module. Split Discovery into DiscV5, PeerExchange and DNSDiscovery, group the node's identity and health under Debug(), and give every facade a pointer receiver. Drop the node name, the per-operation logging that duplicates what the library already writes, and GetFreePortIfNeeded — port 0 already means "let the OS pick". Heavy kernel tests now mark themselves with requiresNode and skip under -short, so the gate runs `go test -short ./...` instead of naming tests in a regexp.
482 lines
18 KiB
Go
482 lines
18 KiB
Go
package kernel
|
|
|
|
import (
|
|
"context"
|
|
"slices"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/logos-messaging/logos-delivery-go-bindings/pkg/kernel/common"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
// Test node connect & disconnect peers
|
|
func TestDisconnectPeerNodes(t *testing.T) {
|
|
requiresNode(t)
|
|
logDebug("Starting TestDisconnectPeerNodes")
|
|
|
|
nodeA, err := StartWakuNode(nil)
|
|
require.NoError(t, err, "Failed to start Node A")
|
|
defer func() { _ = nodeA.Close() }()
|
|
|
|
nodeB, err := StartWakuNode(nil)
|
|
require.NoError(t, err, "Failed to start Node B")
|
|
defer func() { _ = nodeB.Close() }()
|
|
|
|
logDebug("Connecting Node A to Node B")
|
|
err = nodeA.Peers().ConnectTo(context.Background(), nodeB)
|
|
require.NoError(t, err, "Failed to connect nodes")
|
|
|
|
logDebug("Verifying connection between Node A and Node B")
|
|
connectedPeers, err := nodeA.Peers().Connected()
|
|
require.NoError(t, err, "Failed to get connected peers for Node A")
|
|
nodeBPeerID, err := nodeB.Debug().PeerID()
|
|
require.NoError(t, err, "Failed to get PeerID for Node B")
|
|
require.True(t, slices.Contains(connectedPeers, nodeBPeerID), "Node B should be a peer of Node A before disconnection")
|
|
|
|
logDebug("Disconnecting Node A from Node B")
|
|
err = nodeA.Peers().DisconnectFrom(nodeB)
|
|
require.NoError(t, err, "Failed to disconnect nodes")
|
|
|
|
logDebug("Verifying disconnection between Node A and Node B")
|
|
connectedPeers, err = nodeA.Peers().Connected()
|
|
require.NoError(t, err, "Failed to get connected peers for Node A after disconnection")
|
|
require.False(t, slices.Contains(connectedPeers, nodeBPeerID), "Node B should no longer be a peer of Node A after disconnection")
|
|
logDebug("Test completed successfully: Node B was disconnected from Node A")
|
|
}
|
|
|
|
func TestConnectMultipleNodesToSingleNode(t *testing.T) {
|
|
requiresNode(t)
|
|
logDebug("Starting TestConnectMultipleNodesToSingleNode")
|
|
|
|
logDebug("Creating 3 nodes with automatically assigned ports")
|
|
|
|
node1, err := StartWakuNode(nil)
|
|
require.NoError(t, err, "Failed to start Node 1")
|
|
defer func() {
|
|
logDebug("Stopping and destroying Node 1")
|
|
_ = node1.Close()
|
|
}()
|
|
|
|
node2, err := StartWakuNode(nil)
|
|
require.NoError(t, err, "Failed to start Node 2")
|
|
defer func() {
|
|
logDebug("Stopping and destroying Node 2")
|
|
_ = node2.Close()
|
|
}()
|
|
|
|
node3, err := StartWakuNode(nil)
|
|
require.NoError(t, err, "Failed to start Node 3")
|
|
defer func() {
|
|
logDebug("Stopping and destroying Node 3")
|
|
_ = node3.Close()
|
|
}()
|
|
|
|
logDebug("Connecting Node 2 to Node 1")
|
|
err = node2.Peers().ConnectTo(context.Background(), node1)
|
|
require.NoError(t, err, "Failed to connect Node 2 to Node 1")
|
|
|
|
logDebug("Connecting Node 3 to Node 1")
|
|
err = node3.Peers().ConnectTo(context.Background(), node1)
|
|
require.NoError(t, err, "Failed to connect Node 3 to Node 1")
|
|
|
|
logDebug("Verifying connected peers for Node 1")
|
|
connectedPeers, err := node1.Peers().Connected()
|
|
require.NoError(t, err, "Failed to get connected peers for Node 1")
|
|
node3PeerID, err := node3.Debug().PeerID()
|
|
require.NoError(t, err, "Failed to get PeerID for Node 1")
|
|
node2PeerID, err := node2.Debug().PeerID()
|
|
require.NoError(t, err, "Failed to get PeerID for Node 2")
|
|
|
|
require.True(t, slices.Contains(connectedPeers, node3PeerID), "Node 3 should be a peer of Node 1")
|
|
require.True(t, slices.Contains(connectedPeers, node2PeerID), "Node 2 should be a peer of Node 1")
|
|
|
|
logDebug("Test completed successfully: multiple nodes connected to a single node and verified peers")
|
|
}
|
|
|
|
func TestConnectUsingMultipleStaticPeers(t *testing.T) {
|
|
requiresNode(t)
|
|
logDebug("Starting TestConnectUsingMultipleStaticPeers")
|
|
|
|
node1, err := StartWakuNode(nil)
|
|
require.NoError(t, err, "Failed to start Node 1")
|
|
|
|
node2, err := StartWakuNode(nil)
|
|
require.NoError(t, err, "Failed to start Node 2")
|
|
|
|
node3, err := StartWakuNode(nil)
|
|
require.NoError(t, err, "Failed to start Node 3")
|
|
|
|
addr1, err := node1.Debug().ListenAddresses()
|
|
require.NoError(t, err, "Failed to get listen addresses for Node 1")
|
|
|
|
addr2, err := node2.Debug().ListenAddresses()
|
|
require.NoError(t, err, "Failed to get listen addresses for Node 2")
|
|
|
|
addr3, err := node3.Debug().ListenAddresses()
|
|
require.NoError(t, err, "Failed to get listen addresses for Node 3")
|
|
|
|
node4Config := DefaultWakuConfig
|
|
node4Config.Discv5Discovery = false
|
|
node4Config.Staticnodes = []string{addr1[0].String(), addr2[0].String(), addr3[0].String()}
|
|
|
|
node4, err := StartWakuNode(&node4Config)
|
|
require.NoError(t, err, "Failed to start Node 4")
|
|
|
|
defer func() {
|
|
logDebug("Stopping and destroying all Waku nodes")
|
|
_ = node1.Close()
|
|
_ = node2.Close()
|
|
_ = node3.Close()
|
|
_ = node4.Close()
|
|
}()
|
|
|
|
logDebug("Verifying connected peers for Node 4")
|
|
connectedPeers, err := node4.Peers().Connected()
|
|
require.NoError(t, err, "Failed to get connected peers for Node 4")
|
|
|
|
node1PeerID, err := node1.Debug().PeerID()
|
|
require.NoError(t, err, "Failed to get PeerID for Node 1")
|
|
node2PeerID, err := node2.Debug().PeerID()
|
|
require.NoError(t, err, "Failed to get PeerID for Node 2")
|
|
node3PeerID, err := node3.Debug().PeerID()
|
|
require.NoError(t, err, "Failed to get PeerID for Node 3")
|
|
|
|
require.True(t, slices.Contains(connectedPeers, node1PeerID), "Node 1 should be a peer of Node 4")
|
|
require.True(t, slices.Contains(connectedPeers, node2PeerID), "Node 2 should be a peer of Node 4")
|
|
require.True(t, slices.Contains(connectedPeers, node3PeerID), "Node 3 should be a peer of Node 4")
|
|
|
|
logDebug("Test passed: multiple nodes connected to a single node using Static Peers")
|
|
}
|
|
|
|
func TestConnectedPeersInfo(t *testing.T) {
|
|
requiresNode(t)
|
|
logDebug("Starting TestPeerData")
|
|
|
|
node1, err := StartWakuNode(nil)
|
|
require.NoError(t, err, "Failed to start Node 1")
|
|
|
|
node2, err := StartWakuNode(nil)
|
|
require.NoError(t, err, "Failed to start Node 2")
|
|
|
|
node3, err := StartWakuNode(nil)
|
|
require.NoError(t, err, "Failed to start Node 3")
|
|
|
|
addr1, err := node1.Debug().ListenAddresses()
|
|
require.NoError(t, err, "Failed to get listen addresses for Node 1")
|
|
|
|
addr2, err := node2.Debug().ListenAddresses()
|
|
require.NoError(t, err, "Failed to get listen addresses for Node 2")
|
|
|
|
addr3, err := node3.Debug().ListenAddresses()
|
|
require.NoError(t, err, "Failed to get listen addresses for Node 3")
|
|
|
|
node4Config := DefaultWakuConfig
|
|
node4Config.Discv5Discovery = false
|
|
node4Config.Staticnodes = []string{addr1[0].String(), addr2[0].String(), addr3[0].String()}
|
|
|
|
node4, err := StartWakuNode(&node4Config)
|
|
require.NoError(t, err, "Failed to start Node 4")
|
|
|
|
defer func() {
|
|
logDebug("Stopping and destroying all Waku nodes")
|
|
_ = node1.Close()
|
|
_ = node2.Close()
|
|
_ = node3.Close()
|
|
_ = node4.Close()
|
|
}()
|
|
|
|
logDebug("Verifying connected peers for Node 4")
|
|
connectedPeers, err := node4.Peers().Connected()
|
|
require.NoError(t, err, "Failed to get connected peers for Node 4")
|
|
|
|
node1PeerID, err := node1.Debug().PeerID()
|
|
require.NoError(t, err, "Failed to get PeerID for Node 1")
|
|
node2PeerID, err := node2.Debug().PeerID()
|
|
require.NoError(t, err, "Failed to get PeerID for Node 2")
|
|
node3PeerID, err := node3.Debug().PeerID()
|
|
require.NoError(t, err, "Failed to get PeerID for Node 3")
|
|
|
|
require.True(t, slices.Contains(connectedPeers, node1PeerID), "Node 1 should be a peer of Node 4")
|
|
require.True(t, slices.Contains(connectedPeers, node2PeerID), "Node 2 should be a peer of Node 4")
|
|
require.True(t, slices.Contains(connectedPeers, node3PeerID), "Node 3 should be a peer of Node 4")
|
|
|
|
time.Sleep(1 * time.Second)
|
|
|
|
peersInfo, err := node4.Peers().ConnectedInfo()
|
|
require.NoError(t, err, "Failed to get node 4's connected peers info")
|
|
|
|
require.Equal(t, 3, len(peersInfo), "Expected Node 4's connected peers info to have 3 entries")
|
|
|
|
// Verify the addresses contain the expected peer IDs when encapsulated
|
|
node1DerivedAddr := common.EncapsulatePeerID(node1PeerID, peersInfo[node1PeerID].Addresses...)
|
|
require.NotEmpty(t, node1DerivedAddr, "Node1's derived address should not be empty")
|
|
require.Contains(t, node1DerivedAddr[0].String(), node1PeerID.String(), "Node1's derived address should contain its peer ID")
|
|
|
|
node2DerivedAddr := common.EncapsulatePeerID(node2PeerID, peersInfo[node2PeerID].Addresses...)
|
|
require.NotEmpty(t, node2DerivedAddr, "Node2's derived address should not be empty")
|
|
require.Contains(t, node2DerivedAddr[0].String(), node2PeerID.String(), "Node2's derived address should contain its peer ID")
|
|
|
|
node3DerivedAddr := common.EncapsulatePeerID(node3PeerID, peersInfo[node3PeerID].Addresses...)
|
|
require.NotEmpty(t, node3DerivedAddr, "Node3's derived address should not be empty")
|
|
require.Contains(t, node3DerivedAddr[0].String(), node3PeerID.String(), "Node3's derived address should contain its peer ID")
|
|
|
|
logDebug("Test passed: peersInfoData is correct")
|
|
}
|
|
|
|
func TestDiscv5PeerMeshCount(t *testing.T) {
|
|
requiresNode(t)
|
|
logDebug("Starting test to verify peer count in mesh using Discv5 after topic subscription")
|
|
|
|
node1Config := DefaultWakuConfig
|
|
node1Config.Relay = true
|
|
logDebug("Creating Node1")
|
|
node1, err := StartWakuNode(&node1Config)
|
|
require.NoError(t, err, "Failed to start Node1")
|
|
|
|
enrNode1, err := node1.Debug().ENR()
|
|
require.NoError(t, err, "Failed to get ENR for Node1")
|
|
|
|
node2Config := DefaultWakuConfig
|
|
node2Config.Discv5BootstrapNodes = []string{enrNode1.String()}
|
|
node2Config.Relay = true
|
|
logDebug("Creating Node2 with Node1 as Discv5 bootstrap")
|
|
node2, err := StartWakuNode(&node2Config)
|
|
require.NoError(t, err, "Failed to start Node2")
|
|
|
|
node3Config := DefaultWakuConfig
|
|
node3Config.Discv5BootstrapNodes = []string{enrNode1.String()}
|
|
node3Config.Relay = true
|
|
|
|
logDebug("Creating Node3 with Node2 as Discv5 bootstrap")
|
|
node3, err := StartWakuNode(&node3Config)
|
|
require.NoError(t, err, "Failed to start Node3")
|
|
|
|
defer func() {
|
|
logDebug("Stopping and destroying all Waku nodes")
|
|
_ = node1.Close()
|
|
_ = node2.Close()
|
|
}()
|
|
|
|
defaultPubsubTopic := DefaultPubsubTopic
|
|
logDebug("Default pubsub topic retrieved: %s", defaultPubsubTopic)
|
|
|
|
err = SubscribeNodesToTopic([]*Node{node1, node2, node3}, defaultPubsubTopic)
|
|
require.NoError(t, err, "Failed to subscribe all nodes to the topic")
|
|
|
|
logDebug("Waiting for nodes to auto-connect via Discv5")
|
|
err = WaitForAutoConnection([]*Node{node1, node2, node3})
|
|
require.NoError(t, err, "Nodes did not auto-connect within timeout")
|
|
time.Sleep(time.Second * 5)
|
|
|
|
logDebug("Fetching number of peers in mesh for Node1 before stopping Node3")
|
|
peerCountBefore, err := node1.Relay().NumPeersInMesh(defaultPubsubTopic)
|
|
require.NoError(t, err, "Failed to get number of peers in mesh for Node1 before stopping Node3")
|
|
|
|
logDebug("Total number of peers in mesh for Node1 before stopping Node3: %d", peerCountBefore)
|
|
require.Equal(t, 2, peerCountBefore, "Expected Node1 to have exactly 2 peers in the mesh before stopping Node3")
|
|
|
|
logDebug("Stopping Node3")
|
|
_ = node3.Close()
|
|
|
|
logDebug("Waiting for network update after Node3 stops")
|
|
time.Sleep(10 * time.Second)
|
|
|
|
logDebug("Fetching number of peers in mesh for Node1 after stopping Node3")
|
|
peerCountAfter, err := node1.Relay().NumPeersInMesh(defaultPubsubTopic)
|
|
require.NoError(t, err, "Failed to get number of peers in mesh for Node1 after stopping Node3")
|
|
|
|
logDebug("Total number of peers in mesh for Node1 after stopping Node3: %d", peerCountAfter)
|
|
require.Equal(t, 1, peerCountAfter, "Expected Node1 to have exactly 1 peer in the mesh after stopping Node3")
|
|
|
|
logDebug("Test successfully verified peer count change after stopping Node3")
|
|
}
|
|
|
|
func TestDiscv5PeerMeshIds(t *testing.T) {
|
|
requiresNode(t)
|
|
logDebug("Starting test to verify peers in mesh using Discv5 after topic subscription")
|
|
|
|
node1Config := DefaultWakuConfig
|
|
node1Config.Relay = true
|
|
logDebug("Creating Node1")
|
|
node1, err := StartWakuNode(&node1Config)
|
|
require.NoError(t, err, "Failed to start Node1")
|
|
|
|
enrNode1, err := node1.Debug().ENR()
|
|
require.NoError(t, err, "Failed to get ENR for Node1")
|
|
|
|
node2Config := DefaultWakuConfig
|
|
node2Config.Discv5BootstrapNodes = []string{enrNode1.String()}
|
|
node2Config.Relay = true
|
|
logDebug("Creating Node2 with Node1 as Discv5 bootstrap")
|
|
node2, err := StartWakuNode(&node2Config)
|
|
require.NoError(t, err, "Failed to start Node2")
|
|
|
|
node2PeerID, err := node2.Debug().PeerID()
|
|
require.NoError(t, err, "Failed to get PeerID for Node 2")
|
|
|
|
node3Config := DefaultWakuConfig
|
|
node3Config.Discv5BootstrapNodes = []string{enrNode1.String()}
|
|
node3Config.Relay = true
|
|
|
|
logDebug("Creating Node3 with Node2 as Discv5 bootstrap")
|
|
node3, err := StartWakuNode(&node3Config)
|
|
require.NoError(t, err, "Failed to start Node3")
|
|
|
|
node3PeerID, err := node3.Debug().PeerID()
|
|
require.NoError(t, err, "Failed to get PeerID for Node 3")
|
|
|
|
defer func() {
|
|
logDebug("Stopping and destroying all Waku nodes")
|
|
_ = node1.Close()
|
|
_ = node2.Close()
|
|
}()
|
|
|
|
defaultPubsubTopic := DefaultPubsubTopic
|
|
logDebug("Default pubsub topic retrieved: %s", defaultPubsubTopic)
|
|
|
|
err = SubscribeNodesToTopic([]*Node{node1, node2, node3}, defaultPubsubTopic)
|
|
require.NoError(t, err, "Failed to subscribe all nodes to the topic")
|
|
|
|
logDebug("Waiting for nodes to auto-connect via Discv5")
|
|
err = WaitForAutoConnection([]*Node{node1, node2, node3})
|
|
require.NoError(t, err, "Nodes did not auto-connect within timeout")
|
|
|
|
logDebug("Fetching number of peers in mesh for Node1 before stopping Node3")
|
|
peersBefore, err := node1.Relay().PeersInMesh(defaultPubsubTopic)
|
|
require.NoError(t, err, "Failed to get number of peers in mesh for Node1 before stopping Node3")
|
|
|
|
logDebug("Total number of peers in mesh for Node1 before stopping Node3: %d", len(peersBefore))
|
|
require.Equal(t, 2, len(peersBefore), "Expected Node1 to have exactly 2 peers in the mesh before stopping Node3")
|
|
require.True(t, slices.Contains(peersBefore, node2PeerID), "Node 2 should be included in node 1's mesh")
|
|
require.True(t, slices.Contains(peersBefore, node3PeerID), "Node 3 should be included in node 1's mesh")
|
|
|
|
logDebug("Stopping Node3")
|
|
_ = node3.Close()
|
|
|
|
logDebug("Waiting for network update after Node3 stops")
|
|
time.Sleep(10 * time.Second)
|
|
|
|
logDebug("Fetching number of peers in mesh for Node1 after stopping Node3")
|
|
peersAfter, err := node1.Relay().PeersInMesh(defaultPubsubTopic)
|
|
require.NoError(t, err, "Failed to get number of peers in mesh for Node1 after stopping Node3")
|
|
|
|
logDebug("Total number of peers in mesh for Node1 after stopping Node3: %d", len(peersAfter))
|
|
require.Equal(t, 1, len(peersAfter), "Expected Node1 to have exactly 1 peer in the mesh after stopping Node3")
|
|
require.True(t, slices.Contains(peersBefore, node2PeerID), "Node 2 should be included in node 1's mesh")
|
|
|
|
logDebug("Test successfully verified peer count change after stopping Node3")
|
|
}
|
|
|
|
func TestDiscv5DisabledNoPeersConnected(t *testing.T) {
|
|
requiresNode(t)
|
|
logDebug("Starting TestDiscv5DisabledNoPeersConnected")
|
|
|
|
nodeConfig := DefaultWakuConfig
|
|
nodeConfig.Discv5Discovery = false
|
|
nodeConfig.Relay = true
|
|
|
|
logDebug("Creating Node1")
|
|
node1, err := StartWakuNode(&nodeConfig)
|
|
require.NoError(t, err, "Failed to start Node1")
|
|
|
|
enrNode1, err := node1.Debug().ENR()
|
|
require.NoError(t, err, "Failed to get ENR for Node1")
|
|
nodeConfig.Discv5BootstrapNodes = []string{enrNode1.String()}
|
|
|
|
logDebug("Creating Node2 with Node1 as Discv5 bootstrap")
|
|
node2, err := StartWakuNode(&nodeConfig)
|
|
require.NoError(t, err, "Failed to start Node2")
|
|
|
|
defer func() {
|
|
logDebug("Stopping and destroying all Waku nodes")
|
|
_ = node1.Close()
|
|
_ = node2.Close()
|
|
}()
|
|
|
|
logDebug("Waiting to ensure no auto-connection")
|
|
time.Sleep(15 * time.Second)
|
|
|
|
logDebug("Verifying number of peers connected to Nodes")
|
|
peerCount, err := node1.Peers().NumConnected()
|
|
require.NoError(t, err, "Failed to get number of peers in mesh for Node1")
|
|
logDebug("Total number of connected peers for Node1: %d", peerCount)
|
|
require.Equal(t, 0, peerCount, "Expected Node1 to have exactly 0 peers in the mesh")
|
|
|
|
peerCount, err = node2.Peers().NumConnected()
|
|
require.NoError(t, err, "Failed to get number of peers in mesh for Node2")
|
|
logDebug("Total number of connected peers for Node2: %d", peerCount)
|
|
require.Equal(t, 0, peerCount, "Expected Node2 to have exactly 0 peers in the mesh")
|
|
|
|
logDebug("Test passed: all the nodes have 0 peers")
|
|
}
|
|
|
|
// this test commented as it will fail will be changed to have external ip in future task
|
|
/*
|
|
func TestDiscv5GetPeersConnected(t *testing.T) {
|
|
requiresNode(t)
|
|
logDebug("Starting test to verify peer count in mesh with 4 nodes using Discv5 (Chained Connection)")
|
|
|
|
node1Config := DefaultWakuConfig
|
|
node1Config.Relay = true
|
|
|
|
logDebug("Creating Node1")
|
|
node1, err := StartWakuNode(&node1Config)
|
|
require.NoError(t, err, "Failed to start Node1")
|
|
|
|
enrNode1, err := node1.Debug().ENR()
|
|
require.NoError(t, err, "Failed to get ENR for Node1")
|
|
|
|
node2Config := DefaultWakuConfig
|
|
node2Config.Relay = true
|
|
node2Config.Discv5BootstrapNodes = []string{enrNode1.String()}
|
|
|
|
logDebug("Creating Node2 with Node1 as Discv5 bootstrap")
|
|
node2, err := StartWakuNode(&node2Config)
|
|
require.NoError(t, err, "Failed to start Node2")
|
|
|
|
enrNode2, err := node2.Debug().ENR()
|
|
require.NoError(t, err, "Failed to get ENR for Node2")
|
|
|
|
node3Config := DefaultWakuConfig
|
|
node3Config.Relay = true
|
|
node3Config.Discv5BootstrapNodes = []string{enrNode2.String()}
|
|
|
|
logDebug("Creating Node3 with Node2 as Discv5 bootstrap")
|
|
node3, err := StartWakuNode(&node3Config)
|
|
require.NoError(t, err, "Failed to start Node3")
|
|
|
|
enrNode3, err := node3.Debug().ENR()
|
|
require.NoError(t, err, "Failed to get ENR for Node3")
|
|
|
|
node4Config := DefaultWakuConfig
|
|
node4Config.Relay = true
|
|
node4Config.Discv5BootstrapNodes = []string{enrNode3.String()}
|
|
|
|
logDebug("Creating Node4 with Node3 as Discv5 bootstrap")
|
|
node4, err := StartWakuNode(&node4Config)
|
|
require.NoError(t, err, "Failed to start Node4")
|
|
|
|
defer func() {
|
|
logDebug("Stopping and destroying all Waku nodes")
|
|
node1.Close()
|
|
node2.Close()
|
|
node3.Close()
|
|
node4.Close()
|
|
}()
|
|
|
|
logDebug("Waiting for nodes to auto-connect via Discv5")
|
|
err = WaitForAutoConnection([]*Node{node1, node2, node3, node4})
|
|
require.NoError(t, err, "Nodes did not auto-connect within timeout")
|
|
|
|
logDebug("Fetching number of peers in connected to Node1")
|
|
peerCount, err := node1.Peers().NumConnected()
|
|
require.NoError(t, err, "Failed to get number of peers in mesh for Node1")
|
|
|
|
logDebug("Total number of peers connected to Node1: %d", peerCount)
|
|
require.Equal(t, 3, peerCount, "Expected Node1 to have exactly 3 peers in the mesh")
|
|
|
|
logDebug("Test successfully verified peer count in mesh with 4 nodes using Discv5 (Chained Connection)")
|
|
}
|
|
*/
|