From 83b0c3e07f59d41d18d2c6c952a464c5359e487f Mon Sep 17 00:00:00 2001 From: Samuel Tariku Date: Mon, 28 Apr 2025 21:03:06 +0300 Subject: [PATCH] updating the cron --- internal/services/event/service.go | 10 +++++++--- internal/web_server/cron.go | 2 +- 2 files changed, 8 insertions(+), 4 deletions(-) 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...")