package dns

import (
	"fmt"
	"io"
	"log"
	"net/http"
	"net/url"
	"strconv"
	"strings"

	"github.com/MartinWilkerson/cert-manager-webhook-nearlyfreespeech/auth"
)

var (
	baseUrl        = "https://api.nearlyfreespeech.net"
	authHeaderName = "X-NFSN-Authentication"
)

func SetTXTRecord(domain string, dnsName string, key string, login string, apiKey string) error {
	urlPath := fmt.Sprintf("/dns/%s/addRR", domain)
	requestUrl := fmt.Sprintf("%s%s", baseUrl, urlPath)
	log.Printf("Request URL: %v", requestUrl)

	values := url.Values{"name": {dnsName}, "type": {"TXT"}, "data": {key}}
	body := values.Encode()
	return send(login, apiKey, urlPath, body, requestUrl)
}

func ClearTXTRecord(domain string, dnsName string, key string, login string, apiKey string) error {
	urlPath := fmt.Sprintf("/dns/%s/removeRR", domain)
	requestUrl := fmt.Sprintf("%s%s", baseUrl, urlPath)

	values := url.Values{"name": {dnsName}, "type": {"TXT"}, "data": {key}}
	body := values.Encode()
	return send(login, apiKey, urlPath, body, requestUrl)
}

func SetARecord(domain string, subdomain string, data string, ttl uint32, login string, apiKey string) error {
	urlPath := fmt.Sprintf("/dns/%s/addRR", domain)
	requestUrl := fmt.Sprintf("%s%s", baseUrl, urlPath)
	log.Printf("Request URL: %v", requestUrl)

	values := url.Values{"name": {subdomain}, "type": {"A"}, "data": {data}, "ttl": {strconv.FormatUint(uint64(ttl), 10)}}
	log.Printf("Body values: %v", values)

	body := values.Encode()
	return send(login, apiKey, urlPath, body, requestUrl)
}

func ClearARecord(domain string, subdomain string, data string, ttl uint32, login string, apiKey string) error {
	urlPath := fmt.Sprintf("/dns/%s/removeRR", domain)
	requestUrl := fmt.Sprintf("%s%s", baseUrl, urlPath)
	log.Printf("Request URL: %v", requestUrl)

	values := url.Values{"name": {subdomain}, "type": {"A"}, "data": {data}}
	log.Printf("Body values: %v", values)

	body := values.Encode()
	return send(login, apiKey, urlPath, body, requestUrl)
}

func send(login string, apiKey string, urlPath string, body string, requestUrl string) error {
	authHeader, err := auth.GetAuthHeader(login, apiKey, urlPath, body)
	if err != nil {
		return err
	}

	bodyReader := strings.NewReader(body)
	req, err := http.NewRequest("POST", requestUrl, bodyReader)
	if err != nil {
		return err
	}

	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
	req.Header.Set(authHeaderName, authHeader)

	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		return err
	}
	defer resp.Body.Close()

	if resp.StatusCode < 200 || resp.StatusCode >= 300 {
		bytes, err := io.ReadAll(resp.Body)
		if err != nil {
			return err
		}
		return fmt.Errorf("HTTP error code %v: %v", resp.StatusCode, string(bytes))
	}

	return nil
}