chore: improved logs

Author: ironman0x7b2

cmd/start.go

@@ -64,6 +64,7 @@ explicitly starts the node, and handles SIGINT/SIGTERM for graceful shutdown.`,
 			eg.Go(func() error {
 				// Wait until signal is received
 				<-ctx.Done()
+				log.Info("Stop signal received, shutting down gracefully")
 
 				if err := n.Stop(); err != nil {
 					log.Error("Failed to stop node", "cause", err)
@@ -89,6 +90,7 @@ explicitly starts the node, and handles SIGINT/SIGTERM for graceful shutdown.`,
 				return err
 			}
 
+			log.Info("Node stopped successfully")
 			return nil
 		},
 	}

node/node.go

@@ -3,6 +3,7 @@ package node
 import (
 	"context"
 	"fmt"
+	"sync"
 
 	"github.com/gin-gonic/gin"
 	"github.com/sentinel-official/sentinel-go-sdk/libs/cmux"
@@ -72,7 +73,12 @@ func (n *Node) Register(ctx context.Context) error {
 		return nil
 	}
 
-	log.Info("Registering node...")
+	log.Info("Registering node",
+		"addr", n.NodeAddr(),
+		"gigabyte_price", n.GigabytePrices(),
+		"hourly_price", n.HourlyPrices(),
+		"remote_addrs", n.APIAddrs(),
+	)
 
 	// Prepare a message to register the node.
 	msg := v3.NewMsgRegisterNodeRequest(
@@ -92,7 +98,12 @@ func (n *Node) Register(ctx context.Context) error {
 
 // UpdateDetails updates the node's pricing and address details on the network.
 func (n *Node) UpdateDetails(ctx context.Context) error {
-	log.Info("Updating node details...")
+	log.Info("Updating node details",
+		"addr", n.NodeAddr(),
+		"gigabyte_prices", n.GigabytePrices(),
+		"hourly_prices", n.HourlyPrices(),
+		"remote_addrs", n.APIAddrs(),
+	)
 
 	// Prepare a message to update the node's details.
 	msg := v3.NewMsgUpdateNodeDetailsRequest(
@@ -125,8 +136,16 @@ func (n *Node) Start(ctx context.Context) error {
 		return fmt.Errorf("failed to update node details: %w", err)
 	}
 
+	var start sync.WaitGroup
+	start.Add(3)
+
 	// Launch the service stack as a background goroutine.
 	n.eg.Go(func() error {
+		log.Info("Starting service routine", "type", n.Service().Type())
+		start.Done()
+
+		defer log.Info("Exiting service routine")
+
 		if err := n.Service().Up(ctx); err != nil {
 			return fmt.Errorf("failed to run service up task: %w", err)
 		}
@@ -142,6 +161,11 @@ func (n *Node) Start(ctx context.Context) error {
 
 	// Launch the cron-based job scheduler in the background.
 	n.eg.Go(func() error {
+		log.Info("Starting scheduler routine")
+		start.Done()
+
+		defer log.Info("Exiting scheduler routine")
+
 		if err := n.Scheduler().Start(ctx); err != nil {
 			return fmt.Errorf("failed to start scheduler: %w", err)
 		}
@@ -154,13 +178,21 @@ func (n *Node) Start(ctx context.Context) error {
 
 	// Launch the API server using the configured TLS certificates and router.
 	n.eg.Go(func() error {
+		log.Info("Starting API server routine", "listen", n.APIListenAddr())
+		start.Done()
+
+		defer log.Info("Exiting API server routine")
+
 		if err := cmux.ListenAndServeTLS(ctx, n.APIListenAddr(), n.TLSCertFile(), n.TLSKeyFile(), n.Router()); err != nil {
 			return fmt.Errorf("failed to listen and serve tls: %w", err)
 		}
 
 		return nil
 	})
 
+	// Wait until all routines started
+	start.Wait()
+
 	log.Info("Node started successfully")
 	return nil
 }
@@ -195,6 +227,5 @@ func (n *Node) Stop() error {
 		return fmt.Errorf("failed to stop scheduler: %w", err)
 	}
 
-	log.Info("Node stopped successfully")
 	return nil
 }