TPS
/
turkmentv_sms_transmitter
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

proper logging

This commit is contained in:
merdan 2024-10-09 15:42:33 +05:00
parent 343a02c0e0
commit 8f9bafef28
2 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cmd/consumer/cs.go
View File

@ -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
}
}

5
pkg/logger/logger.go
View File

@ -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 {