package main

import (
	"encoding/json"
	"fmt"
	"io"
	"log"
	"net/http"
	"os"
	"os/exec"
	"path"
	"runtime"
	"strings"

	"gitea.urkob.com/urko/gitea-webhook-listener/internal"
	"gitea.urkob.com/urko/gitea-webhook-listener/kit/config"
)

func main() {
	cfgFile := os.Getenv("CONFIG_FILE")
	if cfgFile == "" {
		// Get root path
		_, filename, _, _ := runtime.Caller(0)
		cfgFile = path.Join(path.Dir(filename), "configs", "app.yml")
	}
	cfg, err := config.LoadConfig(cfgFile)
	if err != nil {
		log.Fatalf("Error loading config: %v", err)
	}
	log.Println("GOOO")
	http.HandleFunc("/", handlePayload(cfg.Secret, cfg.Projects))
	http.ListenAndServe(fmt.Sprintf(":%d", cfg.Port), nil)
}

func handlePayload(secret string, projects map[string][]config.ConfigScript) func(w http.ResponseWriter, r *http.Request) {
	return (func(w http.ResponseWriter, r *http.Request) {
		// Read the request body
		body, err := io.ReadAll(r.Body)
		if err != nil {
			http.Error(w, "Failed to read request body", http.StatusBadRequest)
			return
		}
		defer r.Body.Close()

		authHeader := r.Header.Get("Authorization")
		if authHeader != secret {
			http.Error(w, "Signatures didn't match", http.StatusUnauthorized)
			return
		}

		if !r.URL.Query().Has("project") {
			http.Error(w, "", http.StatusBadRequest)
			return
		}

		project := r.URL.Query().Get("project")
		proj, found := projects[project]
		if !found {
			http.Error(w, "not found", http.StatusNotFound)
			return
		}
		var payload internal.WebhookPayload
		if err = json.Unmarshal(body, &payload); err != nil {
			http.Error(w, "Failed to parse JSON payload", http.StatusBadRequest)
			return
		}
		branchName := strings.Split(payload.Ref, "/")[len(strings.Split(payload.Ref, "/"))-1]
		found = false
		var scr config.ConfigScript
		for i := range proj {
			if proj[i].Environment == branchName {
				found = true
				scr = proj[i]
				break
			}

		}
		if !found {
			http.Error(w, "not found", http.StatusNotFound)
			return
		}

		go func() {
			if err := execute(scr.Command, scr.Arguments...); err != nil {
				log.Println(err)
			}
		}()
	})
}

func execute(command string, args ...string) error {
	cmd := exec.Command(command, args...)
	cmd.Stdout = os.Stdout
	cmd.Stderr = os.Stderr

	if err := cmd.Run(); err != nil {
		return fmt.Errorf("cmd.Run %w", err)
	}

	return nil
}