integrating waku_get_connected_peers and fixing test

wakuv2/nwaku.go

@@ -238,6 +238,10 @@ package wakuv2
 		WAKU_CALL (waku_get_peerids_from_peerstore(wakuCtx, (WakuCallBack) callback, resp) );
 	}
 
+	static void cGoWakuGetConnectedPeers(void* wakuCtx, void* resp) {
+		WAKU_CALL (waku_get_connected_peers(wakuCtx, (WakuCallBack) callback, resp) );
+	}
+
 	static void cGoWakuLightpushPublish(void* wakuCtx,
 					const char* pubSubTopic,
 					const char* jsonWakuMessage,
@@ -2818,6 +2822,42 @@ func (self *Waku) GetNumConnectedRelayPeers(paramPubsubTopic ...string) (int, er
 	return 0, errors.New(errMsg)
 }
 
+func (self *Waku) GetConnectedPeers() (peer.IDSlice, error) {
+	var resp = C.allocResp()
+	defer C.freeResp(resp)
+	C.cGoWakuGetConnectedPeers(self.wakuCtx, resp)
+
+	if C.getRet(resp) == C.RET_OK {
+		peersStr := C.GoStringN(C.getMyCharPtr(resp), C.int(C.getMyCharLen(resp)))
+		if peersStr == "" {
+			return peer.IDSlice{}, nil
+		}
+		// peersStr contains a comma-separated list of peer ids
+		itemsPeerIds := strings.Split(peersStr, ",")
+
+		var peers peer.IDSlice
+		for _, peerId := range itemsPeerIds {
+			id, err := peer.Decode(peerId)
+			if err != nil {
+				return nil, fmt.Errorf("GetConnectedPeers - decoding peerId: %w", err)
+			}
+			peers = append(peers, id)
+		}
+
+		return peers, nil
+	}
+	errMsg := C.GoStringN(C.getMyCharPtr(resp), C.int(C.getMyCharLen(resp)))
+	return nil, fmt.Errorf("GetConnectedPeers: %s", errMsg)
+}
+
+func (self *Waku) GetNumConnectedPeers() (int, error) {
+	connecterPeers, err := self.GetConnectedPeers()
+	if err != nil {
+		return 0, err
+	}
+	return len(connecterPeers), nil
+}
+
 func (self *Waku) GetPeerIdsFromPeerStore() (peer.IDSlice, error) {
 	var resp = C.allocResp()
 	defer C.freeResp(resp)

wakuv2/nwaku_test.go

@@ -6,7 +6,6 @@ package wakuv2
 import (
 	"context"
 	"errors"
-	"fmt"
 	"slices"
 	"testing"
 	"time"
@@ -613,12 +612,10 @@ func TestDial(t *testing.T) {
 
 	// Check that both nodes now have one connected peer
 	dialerPeerCount = dialerNode.PeerCount()
-	peerIds, _ := dialerNode.GetPeerIdsFromPeerStore()
-	fmt.Println("------------- dialerNode.GetPeerIdsFromPeerStore(): ", peerIds)
 	require.True(t, dialerPeerCount == 1, "Dialer node should have 1 peer")
 
 	receiverPeerCount = receiverNode.PeerCount()
-	require.True(t, receiverPeerCount == 0, "Receiver node should have 1 peer")
+	require.True(t, receiverPeerCount == 1, "Receiver node should have 1 peer")
 
 	// Stop nodes
 	require.NoError(t, dialerNode.Stop())