From 8f9bafef281f03876a62623378060b695e3ffa59 Mon Sep 17 00:00:00 2001
From: merdan <merdan.m@gmail.com>
Date: Wed, 9 Oct 2024 15:42:33 +0500
Subject: [PATCH] proper logging

---
 cmd/consumer/cs.go   | 10 +++++-----
 pkg/logger/logger.go |  5 ++---
 2 files changed, 7 insertions(+), 8 deletions(-)

diff --git a/cmd/consumer/cs.go b/cmd/consumer/cs.go
index 4e9c6a7..85745fa 100644
--- a/cmd/consumer/cs.go
+++ b/cmd/consumer/cs.go
@@ -39,14 +39,14 @@ func run() error {
 	// Initialize database
 	db, err := database.InitMYSQL(cfg.MysqlDSN)
 	if err != nil {
-		logger.Error("Failed to connect to MySQL:", err)
+		logger.Error("Failed to connect to MySQL:", "err", err)
 		return err
 	}
 
 	// Initialize RabbitMQ consumer
 	consumer, err := initRabbitMQConsumer(cfg)
 	if err != nil {
-		logger.Error("Failed to initialize RabbitMQ consumer:", err)
+		logger.Error("Failed to initialize RabbitMQ consumer:", "err", err)
 		return err
 	}
 
@@ -87,14 +87,14 @@ func handleMessage(ctx context.Context, body []byte, db *gorm.DB, logger fl.LogS
 	message := &models.Message{}
 
 	if err := message.Convert(body); err != nil {
-		logger.Error("Message cannot be converted", err)
+		logger.Error("Message cannot be converted", "err", err)
 		return
 	}
 
-	logger.Info("Received message", message.Src, message.Dst, message.Msg)
+	logger.Info("Message", "src", message.Src, "dst", message.Dst, "msg", message.Msg)
 
 	if err := message.Insert(ctx, db); err != nil {
-		logger.Error("Message cannot be Inserted", err)
+		logger.Error("Message cannot be Inserted", "err", err)
 		return
 	}
 }
diff --git a/pkg/logger/logger.go b/pkg/logger/logger.go
index 9ad5d0d..82f0b20 100644
--- a/pkg/logger/logger.go
+++ b/pkg/logger/logger.go
@@ -1,7 +1,6 @@
 package logger
 
 import (
-	"io"
 	"log/slog"
 	"os"
 )
@@ -21,8 +20,8 @@ func SetupLogger(env string) (LogService, error) {
 	var errorHandler slog.Handler
 
 	if env == "test" {
-		infoHandler = slog.NewTextHandler(io.Discard, &slog.HandlerOptions{Level: slog.LevelInfo})
-		errorHandler = slog.NewTextHandler(io.Discard, &slog.HandlerOptions{Level: slog.LevelError})
+		infoHandler = slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{Level: slog.LevelInfo})
+		errorHandler = slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{Level: slog.LevelError})
 	} else {
 		err := os.MkdirAll("logs", 0755)
 		if err != nil {