diff --git a/nwaku.go b/nwaku.go index 870d0f5..6a00750 100644 --- a/nwaku.go +++ b/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 } diff --git a/nwaku_test.go b/nwaku_test.go index 72124a8..ce89929 100644 --- a/nwaku_test.go +++ b/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