package main

import (
	"bytes"
	"encoding/json"
	"fmt"
	"io"
	"log"
	"net/http"
	"os"
	"strings"
)

type Payload struct {
	TaskID  int64    `json:"task_id"`
	State   string   `json:"state"`
	UserIDs []string `json:"user_ids"`
	DueDate string   `json:"date_deadline,omitempty"`
}

func splitCSV(value string) []string {
	if strings.TrimSpace(value) == "" {
		return []string{}
	}
	parts := strings.Split(value, ",")
	result := make([]string, 0, len(parts))
	for _, p := range parts {
		p = strings.TrimSpace(p)
		if p != "" {
			result = append(result, p)
		}
	}
	return result
}

func main() {
	baseURL := os.Getenv("BASE_URL")
	if baseURL == "" {
		fmt.Println("BASE_URL not provided.")
		os.Exit(1)
	}

	// Logger
	logFile, err := os.OpenFile("action.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666)
	if err != nil {
		fmt.Printf("Error creating log file: %v\n", err)
		os.Exit(1)
	}
	defer logFile.Close()
	logger := log.New(io.MultiWriter(os.Stdout, logFile), "", log.LstdFlags)

	// Build payload from env
	issueState := os.Getenv("ISSUE_STATE")
	issueAssignees := splitCSV(os.Getenv("ISSUE_ASSIGNEES"))
	issueDueDate := os.Getenv("ISSUE_DUE_DATE")
	branchRef := os.Getenv("BRANCH_REF")
	authToken := os.Getenv("AUTH_TOKEN")
	if strings.TrimSpace(authToken) == "" {
		logger.Println("AUTH_TOKEN not provided. Please pass 'auth_token' input mapped to a secret.")
		os.Exit(1)
	}

	var odooTicketNumber int64
	if branchRef != "" {
		// Expect format: <prefix>/ticket-OdooTicketNumber
		parts := strings.Split(branchRef, "/")
		for _, part := range parts {
			if strings.HasPrefix(part, "ticket-") {
				ticketStr := strings.TrimPrefix(part, "ticket-")
				fmt.Sscanf(ticketStr, "%d", &odooTicketNumber)
				break
			}
		}
	}

	payload := Payload{
		TaskID:  odooTicketNumber,
		State:   issueState,
		UserIDs: issueAssignees,
		DueDate: issueDueDate,
	}

	payloadBytes, err := json.Marshal([]Payload{payload})
	if err != nil {
		logger.Printf("Error marshalling JSON: %v\n", err)
		os.Exit(1)
	}

	endpoint := strings.TrimRight(baseURL, "/") + "/api/v1/patch_gitea_odoo"
	req, err := http.NewRequest(http.MethodPatch, endpoint, bytes.NewBuffer(payloadBytes))
	if err != nil {
		logger.Printf("Error creating HTTP request: %v\n", err)
		os.Exit(1)
	}
	req.Header.Set("Content-Type", "application/json")
	req.Header.Set("Authorization", "Bearer "+authToken)

	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		logger.Printf("HTTP request failed: %v\n", err)
		os.Exit(1)
	}
	defer resp.Body.Close()
	body, _ := io.ReadAll(resp.Body)
	logger.Printf("Status: %s\nResponse: %s\n", resp.Status, string(body))
	if resp.StatusCode == http.StatusUnauthorized || resp.StatusCode == http.StatusForbidden {
		logger.Println("Authentication to FastAPI failed. Check FASTAPI token.")
	}
	if resp.StatusCode < 200 || resp.StatusCode >= 300 {
		os.Exit(1)
	}
}