From 7415eb1d7ac08237660d18450243aad5118d10d5 Mon Sep 17 00:00:00 2001
From: Samuel Tariku <cybersamt@gmail.com>
Date: Wed, 17 Sep 2025 21:19:06 +0300
Subject: [PATCH] fix: cron

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

diff --git a/internal/web_server/cron.go b/internal/web_server/cron.go
index 5a3edba..2e5c8dc 100644
--- a/internal/web_server/cron.go
+++ b/internal/web_server/cron.go
@@ -26,68 +26,68 @@ 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 * * * *", // Every 1 hour
+			spec: "0 0 0 * * 1", // Every Monday
 			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.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 processing all event result outcomes without errors")
-				}
-			},
-		},
-		{
-			spec: "0 0 0 * * *", // Every Day
-			task: func() {
-				mongoLogger.Info("Began Send daily result notification cron task")
-				if err := resultService.CheckAndSendResultNotifications(context.Background(), time.Now().Add(-24*time.Hour)); err != nil {
-					mongoLogger.Error("Failed to process result",
-						zap.Error(err),
-					)
-				} else {
-					mongoLogger.Info("Completed sending daily result notification without errors")
+					mongoLogger.Info("Completed sending weekly result notification without errors")
 				}
 			},
 		},