From 050fe16f5414b7bddead0910a5a2c09607e49407 Mon Sep 17 00:00:00 2001 From: Samuel Tariku Date: Thu, 19 Jun 2025 19:58:37 +0300 Subject: [PATCH] fix: mongo cfg --- cmd/main.go | 2 +- internal/logger/mongoLogger/init.go | 4 +++- internal/logger/mongoLogger/logger.go | 3 ++- internal/services/ticket/service.go | 4 ++-- 4 files changed, 8 insertions(+), 5 deletions(-) diff --git a/cmd/main.go b/cmd/main.go index c430131..1035672 100644 --- a/cmd/main.go +++ b/cmd/main.go @@ -86,7 +86,7 @@ func main() { logger := customlogger.NewLogger(cfg.Env, cfg.LogLevel) - domain.MongoDBLogger, err = mongoLogger.InitLogger() + domain.MongoDBLogger, err = mongoLogger.InitLogger(cfg) if err != nil { log.Fatalf("Logger initialization failed: %v", err) } diff --git a/internal/logger/mongoLogger/init.go b/internal/logger/mongoLogger/init.go index f5ec3a0..6784c04 100644 --- a/internal/logger/mongoLogger/init.go +++ b/internal/logger/mongoLogger/init.go @@ -4,16 +4,18 @@ import ( "fmt" "os" + "github.com/SamuelTariku/FortuneBet-Backend/internal/config" "go.uber.org/zap" "go.uber.org/zap/zapcore" ) -func InitLogger() (*zap.Logger, error) { +func InitLogger(cfg *config.Config) (*zap.Logger, error) { mongoCore, err := NewMongoCore( os.Getenv("MONGODB_URL"), "logdb", "applogs", zapcore.InfoLevel, + cfg, ) if err != nil { return nil, fmt.Errorf("failed to create MongoDB core: %w", err) diff --git a/internal/logger/mongoLogger/logger.go b/internal/logger/mongoLogger/logger.go index 378b928..55197df 100644 --- a/internal/logger/mongoLogger/logger.go +++ b/internal/logger/mongoLogger/logger.go @@ -21,7 +21,7 @@ type MongoCore struct { cfg *config.Config } -func NewMongoCore(uri, dbName, collectionName string, level zapcore.Level) (zapcore.Core, error) { +func NewMongoCore(uri, dbName, collectionName string, level zapcore.Level, cfg *config.Config) (zapcore.Core, error) { ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel() @@ -38,6 +38,7 @@ func NewMongoCore(uri, dbName, collectionName string, level zapcore.Level) (zapc return &MongoCore{ collection: coll, level: level, + cfg: cfg, }, nil } diff --git a/internal/services/ticket/service.go b/internal/services/ticket/service.go index 35d807c..2f36e88 100644 --- a/internal/services/ticket/service.go +++ b/internal/services/ticket/service.go @@ -152,7 +152,7 @@ func (s *Service) GenerateTicketOutcome(ctx context.Context, eventID int64, mark func (s *Service) CreateTicket(ctx context.Context, req domain.CreateTicketReq, clientIP string) (domain.Ticket, int64, error) { - s.mongoLogger.Info("Creating ticket") + // s.mongoLogger.Info("Creating ticket") // TODO Validate Outcomes Here and make sure they didn't expire // Validation for creating tickets if len(req.Outcomes) > 30 { @@ -176,7 +176,7 @@ func (s *Service) CreateTicket(ctx context.Context, req domain.CreateTicketReq, if count > 50 { // return response.WriteJSON(c, fiber.StatusBadRequest, "Ticket Limit reached", nil, nil) return domain.Ticket{}, 0, ErrTicketLimitForSingleUser - } + } var outcomes []domain.CreateTicketOutcome = make([]domain.CreateTicketOutcome, 0, len(req.Outcomes)) var totalOdds float32 = 1 for _, outcomeReq := range req.Outcomes {