From 61bd5abd00dd87a5cda0bfb1aa2d4f703ea89726 Mon Sep 17 00:00:00 2001
From: Samuel Tariku <cybersamt@gmail.com>
Date: Fri, 23 May 2025 22:12:52 +0300
Subject: [PATCH 1/2] fix: increase event fetch limit and restore cron job
 scheduling

---
 internal/services/event/service.go |  2 +-
 internal/web_server/cron.go        | 34 +++++++++++++++---------------
 internal/web_server/routes.go      |  2 +-
 3 files changed, 19 insertions(+), 19 deletions(-)

diff --git a/internal/services/event/service.go b/internal/services/event/service.go
index fe51aa7..6a2176d 100644
--- a/internal/services/event/service.go
+++ b/internal/services/event/service.go
@@ -104,7 +104,7 @@ func (s *service) FetchUpcomingEvents(ctx context.Context) error {
 	for _, sportID := range sportIDs {
 		var totalPages int = 1
 		var page int = 0
-		var limit int = 10
+		var limit int = 200
 		var count int = 0
 		for page <= totalPages {
 			page = page + 1
diff --git a/internal/web_server/cron.go b/internal/web_server/cron.go
index 8e0bfdd..769d0b3 100644
--- a/internal/web_server/cron.go
+++ b/internal/web_server/cron.go
@@ -21,22 +21,22 @@ func StartDataFetchingCrons(eventService eventsvc.Service, oddsService oddssvc.S
 		spec string
 		task func()
 	}{
-		// {
-		// 	spec: "0 0 * * * *", // Every 1 hour
-		// 	task: func() {
-		// 		if err := eventService.FetchUpcomingEvents(context.Background()); err != nil {
-		// 			log.Printf("FetchUpcomingEvents error: %v", err)
-		// 		}
-		// 	},
-		// },
-		// {
-		// 	spec: "0 */15 * * * *", // Every 15 minutes
-		// 	task: func() {
-		// 		if err := oddsService.FetchNonLiveOdds(context.Background()); err != nil {
-		// 			log.Printf("FetchNonLiveOdds error: %v", err)
-		// 		}
-		// 	},
-		// },
+		{
+			spec: "0 0 * * * *", // Every 1 hour
+			task: func() {
+				if err := eventService.FetchUpcomingEvents(context.Background()); err != nil {
+					log.Printf("FetchUpcomingEvents error: %v", err)
+				}
+			},
+		},
+		{
+			spec: "0 */15 * * * *", // Every 15 minutes
+			task: func() {
+				if err := oddsService.FetchNonLiveOdds(context.Background()); err != nil {
+					log.Printf("FetchNonLiveOdds error: %v", err)
+				}
+			},
+		},
 		{
 			spec: "0 */15 * * * *", // Every 15 Minutes
 			task: func() {
@@ -52,7 +52,7 @@ func StartDataFetchingCrons(eventService eventsvc.Service, oddsService oddssvc.S
 	}
 
 	for _, job := range schedule {
-		job.task()
+		// job.task()
 		if _, err := c.AddFunc(job.spec, job.task); err != nil {
 			log.Fatalf("Failed to schedule cron job: %v", err)
 		}
diff --git a/internal/web_server/routes.go b/internal/web_server/routes.go
index 51a9d1c..7874ef7 100644
--- a/internal/web_server/routes.go
+++ b/internal/web_server/routes.go
@@ -35,7 +35,7 @@ func (a *App) initAppRoutes() {
 	a.fiber.Get("/", func(c *fiber.Ctx) error {
 		return c.JSON(fiber.Map{
 			"message": "Welcome to the FortuneBet API",
-			"version": "1.0dev2",
+			"version": "1.0dev3",
 		})
 	})
 

From d04198e08a254c1119317f0bbd78d85ec2c4a991 Mon Sep 17 00:00:00 2001
From: Samuel Tariku <cybersamt@gmail.com>
Date: Mon, 26 May 2025 12:48:51 +0300
Subject: [PATCH 2/2] fix: remove redundant unique constraint from
 customer_wallets table

---
 db/migrations/000001_fortune.up.sql | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/db/migrations/000001_fortune.up.sql b/db/migrations/000001_fortune.up.sql
index 64f3c2d..17b5e49 100644
--- a/db/migrations/000001_fortune.up.sql
+++ b/db/migrations/000001_fortune.up.sql
@@ -117,8 +117,7 @@ CREATE TABLE IF NOT EXISTS customer_wallets (
     regular_wallet_id BIGINT NOT NULL,
     static_wallet_id BIGINT NOT NULL,
     created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
-    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
-    UNIQUE (customer_id, company_id)
+    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
 );
 CREATE TABLE IF NOT EXISTS wallet_transfer (
     id BIGSERIAL PRIMARY KEY,