gh workflow pricing

Signed-off-by: pranjalg1331 <[email protected]>

Author: pranjalg1331

.github/workflows/pricing.yaml

@@ -0,0 +1,26 @@
+name: Dynamic Pricing
+
+on:
+  schedule:
+    - cron: "0 */6 * * *"   # every 6 hours
+  workflow_dispatch:
+
+jobs:
+  run-pricing:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout repo
+        uses: actions/checkout@v3
+
+      - name: Set up Go
+        uses: actions/setup-go@v5
+        with:
+          go-version: "1.22"
+
+      - name: Build pricing service
+        run: go build -o pricing ./cmd/pricing
+
+      - name: Run pricing adjustment
+        env:
+          DATABASE_URL: ${{ secrets.DATABASE_URL }}
+        run: ./pricing

cmd/api/main.go

@@ -10,7 +10,6 @@ import (
 	"github.com/pranjalg1331/event-management/handlers"
 	"github.com/pranjalg1331/event-management/middleware"
 	"github.com/pranjalg1331/event-management/models"
-	"github.com/pranjalg1331/event-management/services"
 	redisclient "github.com/pranjalg1331/event-management/services/redis"
 	"gorm.io/driver/postgres"
 	"gorm.io/gorm"
@@ -53,8 +52,6 @@ func main() {
 	redisclient.InitRedis(redisURL, redisPassword)
 	log.Println("Redis connected!")
 
-	services.StartPriceScheduler(db)
-
 	// ------------------------
 	// 3️⃣ Setup Gin routes
 	// ------------------------

cmd/pricing/pricing.go

@@ -0,0 +1,36 @@
+package main
+
+import (
+	"log"
+	"os"
+
+	"github.com/pranjalg1331/event-management/services"
+	"gorm.io/driver/postgres"
+	"gorm.io/gorm"
+)
+
+func main() {
+	// ------------------------
+	// 1️⃣ Load DB connection
+	// ------------------------
+	dsn := os.Getenv("DATABASE_URL")
+	if dsn == "" {
+		log.Fatal("DATABASE_URL is not set")
+	}
+
+	db, err := gorm.Open(postgres.Open(dsn), &gorm.Config{})
+	if err != nil {
+		log.Fatalf("Failed to connect to database: %v", err)
+	}
+
+	log.Println("Database connected! Running pricing adjustment...")
+
+	// ------------------------
+	// 2️⃣ Run pricing logic
+	// ------------------------
+	if err := services.AdjustEventPrices(db); err != nil {
+		log.Fatalf("Pricing adjustment failed: %v", err)
+	}
+
+	log.Println("✅ Pricing adjustment completed successfully")
+}

services/dynamic-pricing.go

@@ -3,7 +3,6 @@ package services
 
 import (
 	"fmt"
-	"log"
 	"time"
 
 	"github.com/pranjalg1331/event-management/models"
@@ -90,16 +89,3 @@ func applyPricingRules(e models.Event, utilization float64,isPopular bool) float
 }
 
 
-// services/pricing.go
-func StartPriceScheduler(db *gorm.DB) {
-    ticker := time.NewTicker(6 * time.Hour)
-    go func() {
-        for {
-            <-ticker.C
-            log.Println("Running dynamic pricing update...")
-            if err := AdjustEventPrices(db); err != nil {
-                log.Printf("Dynamic pricing failed: %v", err)
-            }
-        }
-    }()
-}