package main

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

type Payload struct {
	TaskID    int64    `json:"task_id"`
	Title     string   `json:"title"`
	Body      string   `json:"body"`
	State     string   `json:"state"`
	Author    string   `json:"author"`
	Assignees []string `json:"assignees"`
	Labels    []string `json:"labels"`
	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
	issueNumber := os.Getenv("ISSUE_NUMBER")
	issueTitle := os.Getenv("ISSUE_TITLE")
	issueBody := os.Getenv("ISSUE_BODY")
	issueState := os.Getenv("ISSUE_STATE")
	issueAuthor := os.Getenv("ISSUE_AUTHOR")
	issueAssignees := splitCSV(os.Getenv("ISSUE_ASSIGNEES"))
	issueLabels := splitCSV(os.Getenv("ISSUE_LABELS"))
	issueDueDate := os.Getenv("ISSUE_DUE_DATE")

	var taskID int64
	if issueNumber != "" {
		// Best-effort parse; if it fails, taskID remains 0
		fmt.Sscanf(issueNumber, "%d", &taskID)
	}

	payload := Payload{
		TaskID:    taskID,
		Title:     issueTitle,
		Body:      issueBody,
		State:     issueState,
		Author:    issueAuthor,
		Assignees: issueAssignees,
		Labels:    issueLabels,
		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")

	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 < 200 || resp.StatusCode >= 300 {
		os.Exit(1)
	}
}