diff --git a/internal/services/result/service.go b/internal/services/result/service.go index cb19963..245ff89 100644 --- a/internal/services/result/service.go +++ b/internal/services/result/service.go @@ -94,23 +94,25 @@ func (s *Service) UpdateResultForOutcomes(ctx context.Context, eventID int64, re if outcome.Expires.After(time.Now()) { 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) if err != nil { outcomeLogger.Error("Failed to parse result", zap.Error(err)) - return err + continue } outcome, err = s.betSvc.UpdateBetOutcomeStatus(ctx, outcome.ID, parseResult.Status) if err != nil { 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 { 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) @@ -118,14 +120,16 @@ func (s *Service) UpdateResultForOutcomes(ctx context.Context, eventID int64, re if err != bet.ErrOutcomesNotCompleted { 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())) err = s.betSvc.UpdateStatus(ctx, outcome.BetID, status) if err != nil { outcomeLogger.Error("Failed to update bet status", zap.Error(err)) - return err + // return err + continue } } return nil