chore: add logs to debug

Author: siddhanta-rath

services/mqtt/client/pubsub.go

@@ -3,11 +3,10 @@ package client
 import (
 	"context"
 	"fmt"
-
 	"github.com/gojek/courier-go"
 	"github.com/gojek/courier-go/consul"
-	"github.com/goto/raccoon/clients/go/log"
 	"github.com/goto/raccoon/config"
+	"github.com/goto/raccoon/logger"
 )
 
 // MqttPubSubClient wraps a courier MQTT client with start/stop lifecycle management.
@@ -52,7 +51,7 @@ func NewMqttPubSubClient(ctx context.Context, handler courier.MessageHandler, cl
 		return nil, fmt.Errorf("failed to initialize MQTT client: %w", err)
 	}
 
-	log.Infof("MQTT client initialized successfully for clientID=%s", clientID)
+	logger.Infof("MQTT client initialized successfully for clientID=%s and client %v", clientID, client)
 	return &MqttPubSubClient{client: client}, nil
 }
 
@@ -61,26 +60,27 @@ func registerHandler(ctx context.Context, handler courier.MessageHandler) func(c
 	return func(ps courier.PubSub) {
 		topic := config.ServerMQTT.ConsumerConfig.TopicFormat
 		if err := ps.Subscribe(ctx, topic, handler, courier.QOSZero); err != nil {
-			log.Errorf("failed to register MQTT handler for topic %q: %v", topic, err)
+			logger.Errorf("failed to register MQTT handler for topic %q: %v", topic, err)
 		} else {
-			log.Infof("successfully registered MQTT handler for topic %q", topic)
+			logger.Infof("successfully registered MQTT handler for topic %q", topic)
 		}
 	}
 }
 
 // Start begins the MQTT client operation.
 func (m *MqttPubSubClient) Start() error {
 	if err := m.client.Start(); err != nil {
+		logger.Infof("MQTT client start failed due to %v", err)
 		return fmt.Errorf("failed to start MQTT client: %w", err)
 	}
-	log.Infof("MQTT client started successfully")
+	logger.Infof("MQTT client started successfully")
 	return nil
 }
 
 // Stop gracefully stops the MQTT client.
 func (m *MqttPubSubClient) Stop() error {
 	m.client.Stop()
-	log.Infof("MQTT client stopped successfully")
+	logger.Infof("MQTT client stopped successfully")
 	return nil
 }
 

services/mqtt/consumer.go

@@ -2,6 +2,7 @@ package mqtt
 
 import (
 	"fmt"
+	"github.com/goto/raccoon/logger"
 )
 
 // Consumer wraps a PubSubClient and provides lifecycle control.
@@ -21,23 +22,27 @@ func NewConsumer(client PubSubClient) *Consumer {
 	return &Consumer{client: client}
 }
 
-// Start initializes and starts the underlying PubSubClient.
-func (c *Consumer) Start() error {
+// Init initializes and starts the underlying PubSubClient.
+func (c *Consumer) Init() error {
 	if err := c.client.Start(); err != nil {
 		return fmt.Errorf("failed to start consumer: %w", err)
+	} else {
+		logger.Info("[consumer:] client started sucessfully !!")
 	}
 	return nil
 }
 
-// Stop gracefully shuts down the underlying PubSubClient.
-func (c *Consumer) Stop() error {
+// Shutdown gracefully shuts down the underlying PubSubClient.
+func (c *Consumer) Shutdown() error {
 	if err := c.client.Stop(); err != nil {
 		return fmt.Errorf("failed to stop consumer: %w", err)
+	} else {
+		logger.Info("[consumer:] client stopped sucessfully !!")
 	}
 	return nil
 }
 
-// IsConnected checks the connection health of underlying PubSubClient.
-func (c *Consumer) IsConnected() bool {
+// IsHealthy checks the connection health of underlying PubSubClient.
+func (c *Consumer) IsHealthy() bool {
 	return c.client.IsConnected()
 }

services/mqtt/service.go

@@ -5,6 +5,7 @@ import (
 	"errors"
 	"fmt"
 	"github.com/goto/raccoon/health"
+	"github.com/goto/raccoon/logger"
 	"os"
 
 	"github.com/goto/raccoon/collection"
@@ -38,7 +39,7 @@ func NewMQTTService(collector collection.Collector, ctx context.Context) *Servic
 				startupErr: fmt.Errorf("failed to create MQTT client for %s: %w", clientID, err),
 			}
 		}
-
+		logger.Infof("[service:] MQTT client created with ID %v", clientID)
 		consumers = append(consumers, NewConsumer(mqttClient))
 	}
 	s := &Service{Collector: collector, consumers: consumers}
@@ -50,13 +51,16 @@ func NewMQTTService(collector collection.Collector, ctx context.Context) *Servic
 
 // Init starts all consumers.
 func (s *Service) Init(ctx context.Context) error {
+	logger.Infof("[service]: MQTT service init called")
 	if s.startupErr != nil {
 		return fmt.Errorf("mqtt service startup failed: %w", s.startupErr)
 	}
 
 	for _, con := range s.consumers {
-		if err := con.Start(); err != nil {
+		if err := con.Init(); err != nil {
 			return fmt.Errorf("failed to start consumer: %w", err)
+		} else {
+			logger.Info("[service:] MQTT consumer started")
 		}
 	}
 
@@ -71,8 +75,10 @@ func (*Service) Name() string {
 // Shutdown stops all consumers gracefully.
 func (s *Service) Shutdown(ctx context.Context) error {
 	for _, con := range s.consumers {
-		if err := con.Stop(); err != nil {
+		if err := con.Shutdown(); err != nil {
 			return fmt.Errorf("failed to stop consumer: %w", err)
+		} else {
+			logger.Info("[service:] MQTT consumer stopped")
 		}
 	}
 	return nil
@@ -81,8 +87,10 @@ func (s *Service) Shutdown(ctx context.Context) error {
 // HealthCheck checks the health all consumers.
 func (s *Service) HealthCheck() error {
 	for _, con := range s.consumers {
-		if status := con.IsConnected(); !status {
+		if status := con.IsHealthy(); !status {
 			return errors.New("consumer connection is broken")
+		} else {
+			logger.Info("[service:] Health check pass")
 		}
 	}
 	return nil

services/services.go

@@ -30,6 +30,7 @@ func (s *Services) Start(ctx context.Context, cancel context.CancelFunc) {
 		go func() {
 			logger.Infof("%s Server --> startServers", i.Name())
 			err := i.Init(ctx)
+			logger.Errorf("service start up error %v", err)
 			if err != nil && err != http.ErrServerClosed {
 				cancel()
 			}