diff --git a/internal/services/event/service.go b/internal/services/event/service.go index 1b31043..5ac621c 100644 --- a/internal/services/event/service.go +++ b/internal/services/event/service.go @@ -101,8 +101,8 @@ func (s *service) FetchUpcomingEvents(ctx context.Context) error { sportIDs := []int{1} var totalPages int = 1 var page int = 0 - // var limit int = 5 - // var count int = 0 + var limit int = 5 + var count int = 0 for _, sportID := range sportIDs { for page != totalPages { page = page + 1 @@ -171,6 +171,11 @@ func (s *service) FetchUpcomingEvents(ctx context.Context) error { _ = s.store.SaveUpcomingEvent(ctx, event) } totalPages = data.Pager.Total + + if count > limit { + break + } + count++ } } @@ -236,4 +241,3 @@ func (s *service) GetUpcomingEventByID(ctx context.Context, ID string) (domain.U // return nil // } - diff --git a/internal/web_server/cron.go b/internal/web_server/cron.go index 0a65022..af66fe7 100644 --- a/internal/web_server/cron.go +++ b/internal/web_server/cron.go @@ -43,7 +43,7 @@ func StartDataFetchingCrons(eventService eventsvc.Service, oddsService oddssvc.S }, }, { - spec: "*/10 * * * * *", + spec: "0 */15 * * * *", task: func() { log.Println("Fetching results for upcoming events...")