status-im/status-go
2
0
Fork 0
mirror of https://github.com/status-im/status-go.git synced 2025-02-16 08:50:09 +00:00
Code Issues Projects Releases Wiki Activity

check for connection

Browse Source
This commit is contained in:
Gabriel mermelstein 2024-10-11 12:15:34 +03:00
parent 675bb28b8c
commit 56e51d79d9
No known key found for this signature in database
GPG Key ID: 82B8134785FEAE0D
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
wakuv2/nwaku_test.go
View File

@ -7,10 +7,13 @@ import (
"context"
"errors"
"fmt"
"slices"
"testing"
"time"
"github.com/cenkalti/backoff/v3"
"github.com/libp2p/go-libp2p/core/peer"
"github.com/waku-org/go-waku/waku/v2/protocol/store"
"github.com/ethereum/go-ethereum/common/hexutil"
"github.com/ethereum/go-ethereum/crypto"
@ -203,6 +206,16 @@ func TestBasicWakuV2(t *testing.T) {
}, options)
require.NoError(t, err)
storeNode, err :=peer.AddrInfoFromString(storeNodeInfo.ListenAddresses[0])
require.NoError(t, err)
require.NoError(t, err)
connectedStoreNodes, err := w.GetPeerIdsByProtocol(string(store.StoreQueryID_v300))
require.True(t, slices.Contains(connectedStoreNodes, storeNode.ID), "nwaku should be connected to the store node")
err = w.DropPeer(storeNode.ID)
require.NoError(t, err)
/* // Dropping Peer
err = w.DropPeer(storeNode.PeerID)
require.NoError(t, err)