From 0bab186a8fd70d27df555112ee0c9a41cd0a72a8 Mon Sep 17 00:00:00 2001
From: Samuel Tariku <cybersamt@gmail.com>
Date: Wed, 8 Oct 2025 12:54:11 +0300
Subject: [PATCH] fix: uncommenting out crons

---
 internal/web_server/cron.go | 132 ++++++++++++++++++------------------
 1 file changed, 66 insertions(+), 66 deletions(-)

diff --git a/internal/web_server/cron.go b/internal/web_server/cron.go
index bcdce17..6119670 100644
--- a/internal/web_server/cron.go
+++ b/internal/web_server/cron.go
@@ -28,75 +28,75 @@ func StartDataFetchingCrons(eventService eventsvc.Service, oddsService oddssvc.S
 		spec string
 		task func()
 	}{
-		// {
-		// 	spec: "0 0 * * * *", // Every 1 hour
-		// 	task: func() {
-		// 		mongoLogger.Info("Began fetching upcoming events cron task")
-		// 		if err := eventService.FetchUpcomingEvents(context.Background()); err != nil {
-		// 			mongoLogger.Error("Failed to fetch upcoming events",
-		// 				zap.Error(err),
-		// 			)
-		// 		} else {
-		// 			mongoLogger.Info("Completed  fetching upcoming events without errors")
-		// 		}
-		// 	},
-		// },
-		// {
-		// 	spec: "0 0 * * * *", // Every 1 hour (since its takes that long to fetch all the events)
-		// 	task: func() {
-		// 		mongoLogger.Info("Began fetching non live odds cron task")
-		// 		if err := oddsService.FetchNonLiveOdds(context.Background()); err != nil {
-		// 			mongoLogger.Error("Failed to fetch non live odds",
-		// 				zap.Error(err),
-		// 			)
-		// 		} else {
-		// 			mongoLogger.Info("Completed fetching non live odds without errors")
-		// 		}
-		// 	},
-		// },
-		// {
-		// 	spec: "0 */5 * * * *", // Every 5 Minutes
-		// 	task: func() {
-		// 		mongoLogger.Info("Began update all expired events status cron task")
-		// 		if _, err := resultService.CheckAndUpdateExpiredB365Events(context.Background()); err != nil {
-		// 			mongoLogger.Error("Failed to update expired events status",
-		// 				zap.Error(err),
-		// 			)
-		// 		} else {
-		// 			mongoLogger.Info("Completed expired events without errors")
-		// 		}
-		// 	},
-		// },
-		// {
-		// 	spec: "0 */15 * * * *", // Every 15 Minutes
-		// 	task: func() {
-		// 		mongoLogger.Info("Began updating bets based on event results cron task")
-		// 		if err := resultService.FetchB365ResultAndUpdateBets(context.Background()); err != nil {
-		// 			mongoLogger.Error("Failed to process result",
-		// 				zap.Error(err),
-		// 			)
-		// 		} else {
-		// 			mongoLogger.Info("Completed processing all event result outcomes without errors")
-		// 		}
-		// 	},
-		// },
-		// {
-		// 	spec: "0 0 0 * * 1", // Every Monday
-		// 	task: func() {
-		// 		mongoLogger.Info("Began Send weekly result notification cron task")
-		// 		if err := resultService.CheckAndSendResultNotifications(context.Background(), time.Now().Add(-7*24*time.Hour)); err != nil {
-		// 			mongoLogger.Error("Failed to process result",
-		// 				zap.Error(err),
-		// 			)
-		// 		} else {
-		// 			mongoLogger.Info("Completed sending weekly result notification without errors")
-		// 		}
-		// 	},
-		// },
+		{
+			spec: "0 0 * * * *", // Every 1 hour
+			task: func() {
+				mongoLogger.Info("Began fetching upcoming events cron task")
+				if err := eventService.FetchUpcomingEvents(context.Background()); err != nil {
+					mongoLogger.Error("Failed to fetch upcoming events",
+						zap.Error(err),
+					)
+				} else {
+					mongoLogger.Info("Completed  fetching upcoming events without errors")
+				}
+			},
+		},
+		{
+			spec: "0 0 * * * *", // Every 1 hour (since its takes that long to fetch all the events)
+			task: func() {
+				mongoLogger.Info("Began fetching non live odds cron task")
+				if err := oddsService.FetchNonLiveOdds(context.Background()); err != nil {
+					mongoLogger.Error("Failed to fetch non live odds",
+						zap.Error(err),
+					)
+				} else {
+					mongoLogger.Info("Completed fetching non live odds without errors")
+				}
+			},
+		},
+		{
+			spec: "0 */5 * * * *", // Every 5 Minutes
+			task: func() {
+				mongoLogger.Info("Began update all expired events status cron task")
+				if _, err := resultService.CheckAndUpdateExpiredB365Events(context.Background()); err != nil {
+					mongoLogger.Error("Failed to update expired events status",
+						zap.Error(err),
+					)
+				} else {
+					mongoLogger.Info("Completed expired events without errors")
+				}
+			},
+		},
+		{
+			spec: "0 */15 * * * *", // Every 15 Minutes
+			task: func() {
+				mongoLogger.Info("Began updating bets based on event results cron task")
+				if err := resultService.FetchB365ResultAndUpdateBets(context.Background()); err != nil {
+					mongoLogger.Error("Failed to process result",
+						zap.Error(err),
+					)
+				} else {
+					mongoLogger.Info("Completed processing all event result outcomes without errors")
+				}
+			},
+		},
+		{
+			spec: "0 0 0 * * 1", // Every Monday
+			task: func() {
+				mongoLogger.Info("Began Send weekly result notification cron task")
+				if err := resultService.CheckAndSendResultNotifications(context.Background(), time.Now().Add(-7*24*time.Hour)); err != nil {
+					mongoLogger.Error("Failed to process result",
+						zap.Error(err),
+					)
+				} else {
+					mongoLogger.Info("Completed sending weekly result notification without errors")
+				}
+			},
+		},
 	}
 
 	for _, job := range schedule {
-		job.task()
+		// job.task()
 		if _, err := c.AddFunc(job.spec, job.task); err != nil {
 			mongoLogger.Error("Failed to schedule data fetching cron job",
 				zap.Error(err),