// main.go
package main

import (
    "fmt"
    "log"
    "net/http"
    "os"
    "os/signal"
    "syscall"
    "time"
)

// This is the function you want to run every hour
func CheckFlights() {
    // Replace this with your actual logic
    fmt.Println("CheckFlights executed at:", time.Now().Format(time.RFC3339))
}

// This function starts a scheduler in a goroutine
func StartScheduler(interval time.Duration, stopChan <-chan struct{}) {
    ticker := time.NewTicker(interval)
    defer ticker.Stop()

    for {
        select {
        case <-ticker.C:
            // Run the job concurrently
            go CheckFlights()
        case <-stopChan:
            fmt.Println("Scheduler stopped.")
            return
        }
    }
}

func main() {
    // Channel to gracefully stop the scheduler
    stopChan := make(chan struct{})

    // Start the scheduler in the background (every 1 hour)
    go StartScheduler(1*time.Hour, stopChan)
    // For demo/testing, you can use a shorter interval, e.g. 10 seconds:
    // go StartScheduler(10*time.Second, stopChan)

    // HTTP endpoint to trigger the job manually
    http.HandleFunc("/alerts/run", func(w http.ResponseWriter, r *http.Request) {
        CheckFlights()
        w.Write([]byte("CheckFlights executed manually"))
    })

    // Graceful shutdown: catch Ctrl+C (SIGINT/SIGTERM)
    go func() {
        sigChan := make(chan os.Signal, 1)
        signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
        <-sigChan
        close(stopChan)
        os.Exit(0)
    }()

    fmt.Println("Server running at :8080")
    log.Fatal(http.ListenAndServe(":8080", nil))
}