Yimaru/Yimaru-BackEnd
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: minor result fix

Browse Source
This commit is contained in:
Samuel Tariku 2025-09-23 18:43:07 +03:00
parent 34109b6af4
commit a2d75cf114
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
internal/services/result/service.go
View File

@ -94,23 +94,25 @@ func (s *Service) UpdateResultForOutcomes(ctx context.Context, eventID int64, re
if outcome.Expires.After(time.Now()) { if outcome.Expires.After(time.Now()) {
outcomeLogger.Warn("Outcome is not expired yet", zap.Error(err)) outcomeLogger.Warn("Outcome is not expired yet", zap.Error(err))
return fmt.Errorf("Outcome has not expired yet") // return fmt.Errorf("Outcome has not expired yet")
continue
} }
parseResult, err := s.parseResult(resultRes, outcome, sportID) parseResult, err := s.parseResult(resultRes, outcome, sportID)
if err != nil { if err != nil {
outcomeLogger.Error("Failed to parse result", zap.Error(err)) outcomeLogger.Error("Failed to parse result", zap.Error(err))
return err continue
} }
outcome, err = s.betSvc.UpdateBetOutcomeStatus(ctx, outcome.ID, parseResult.Status) outcome, err = s.betSvc.UpdateBetOutcomeStatus(ctx, outcome.ID, parseResult.Status)
if err != nil { if err != nil {
outcomeLogger.Error("Failed to update bet outcome status", zap.Error(err)) outcomeLogger.Error("Failed to update bet outcome status", zap.Error(err))
return err continue
} }
if outcome.Status == domain.OUTCOME_STATUS_ERROR || outcome.Status == domain.OUTCOME_STATUS_PENDING { if outcome.Status == domain.OUTCOME_STATUS_ERROR || outcome.Status == domain.OUTCOME_STATUS_PENDING {
outcomeLogger.Error("Outcome has been updated to pending or error", zap.Error(err)) outcomeLogger.Error("Outcome has been updated to pending or error", zap.Error(err))
return fmt.Errorf("Error while updating outcome") // return fmt.Errorf("Error while updating outcome")
continue
} }
status, err := s.betSvc.CheckBetOutcomeForBet(ctx, outcome.BetID) status, err := s.betSvc.CheckBetOutcomeForBet(ctx, outcome.BetID)
@ -118,14 +120,16 @@ func (s *Service) UpdateResultForOutcomes(ctx context.Context, eventID int64, re
if err != bet.ErrOutcomesNotCompleted { if err != bet.ErrOutcomesNotCompleted {
outcomeLogger.Error("Failed to check bet outcome for bet", zap.Error(err)) outcomeLogger.Error("Failed to check bet outcome for bet", zap.Error(err))
} }
return err // return err
continue
} }
outcomeLogger.Info("Updating bet status", zap.String("status", status.String())) outcomeLogger.Info("Updating bet status", zap.String("status", status.String()))
err = s.betSvc.UpdateStatus(ctx, outcome.BetID, status) err = s.betSvc.UpdateStatus(ctx, outcome.BetID, status)
if err != nil { if err != nil {
outcomeLogger.Error("Failed to update bet status", zap.Error(err)) outcomeLogger.Error("Failed to update bet status", zap.Error(err))
return err // return err
continue
} }
} }
return nil return nil