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

exporting listenAddresses to Waku

Browse Source
This commit is contained in:
Gabriel mermelstein 2024-11-29 13:02:32 +02:00
parent c8617505e3
commit fc1b6a931d
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
wakuv2/nwaku.go
View File

@ -402,6 +402,10 @@ func (w *Waku) PeerCount() (int, error) {
return w.node.GetNumConnectedPeers()
}
func (w *Waku) ListenAddresses() ([]multiaddr.Multiaddr, error) {
return w.node.ListenAddresses()
}
func (w *Waku) DialPeer(address multiaddr.Multiaddr) error {
// Using WakuConnect so it matches the go-waku's behavior and terminology
ctx, cancel := context.WithTimeout(w.ctx, requestTimeout)

4
wakuv2/nwaku_test.go
View File

@ -225,7 +225,7 @@ func TestPeerExchange(t *testing.T) {
// Adding an extra second to make sure PX cache is not empty
time.Sleep(2 * time.Second)
serverNodeMa, err := pxServerNode.node.ListenAddresses()
serverNodeMa, err := pxServerNode.ListenAddresses()
require.NoError(t, err)
require.NotNil(t, serverNodeMa)
@ -369,7 +369,7 @@ func TestDial(t *testing.T) {
require.NoError(t, err)
require.NoError(t, receiverNode.Start())
time.Sleep(1 * time.Second)
receiverMultiaddr, err := receiverNode.node.ListenAddresses()
receiverMultiaddr, err := receiverNode.ListenAddresses()
require.NoError(t, err)
require.NotNil(t, receiverMultiaddr)
// Check that both nodes start with no connected peers