errors

nwaku.go

@@ -369,16 +369,20 @@ type Waku struct {
 // Start implements node.Service, starting the background data propagation thread
 // of the Waku protocol.
 func (w *Waku) Start() error {
+	fmt.Println("---------------- Start 1 -------------")
 	err := w.node.Start()
+	fmt.Println("---------------- Start 2 -------------")
 	if err != nil {
 		return fmt.Errorf("failed to start nwaku node: %v", err)
 	}
 
 	peerID, err := w.node.PeerID()
+	fmt.Println("---------------- Start 3 -------------")
 	if err != nil {
 		return err
 	}
 
+	fmt.Println("---------------- Start 4 -------------")
 	w.logger.Info("WakuV2 PeerID", zap.Stringer("id", peerID))
 
 	return nil
@@ -526,6 +530,7 @@ func New(nwakuCfg *WakuConfig, logger *zap.Logger) (*Waku, error) {
 	return &Waku{
 		node:    wakunode,
 		wakuCfg: nwakuCfg,
+		logger:  logger,
 	}, nil
 }
 

nwaku_test.go

@@ -4,6 +4,7 @@
 package wakuv2
 
 import (
+	"fmt"
 	"testing"
 	"time"
 
@@ -26,9 +27,13 @@ func TestDial(t *testing.T) {
 		Discv5UdpPort:   9020,
 		TcpPort:         60020,
 	}
+
+	fmt.Println("------------ 1 -------------")
 	dialerNode, err := New(&dialerNodeWakuConfig, logger.Named("dialerNode"))
 	require.NoError(t, err)
+	fmt.Println("------------ 2 -------------")
 	require.NoError(t, dialerNode.Start())
+	fmt.Println("------------ 3 -------------")
 	time.Sleep(1 * time.Second)
 
 	// start node that will receive the dial
@@ -42,10 +47,14 @@ func TestDial(t *testing.T) {
 		TcpPort:         60021,
 	}
 	receiverNode, err := New(&receiverNodeWakuConfig, logger.Named("receiverNode"))
+	fmt.Println("------------ 4 -------------")
 	require.NoError(t, err)
 	require.NoError(t, receiverNode.Start())
+	fmt.Println("------------ 5 -------------")
 	time.Sleep(1 * time.Second)
+	fmt.Println("------------ 6 -------------")
 	receiverMultiaddr, err := receiverNode.node.ListenAddresses()
+	fmt.Println("------------ 7 -------------")
 	require.NoError(t, err)
 	require.NotNil(t, receiverMultiaddr)
 	// Check that both nodes start with no connected peers