package controller

import (
	"errors"
	"fmt"
	"net/http"
	"strconv"
	"strings"

	"github.com/gin-gonic/gin"
	"golang.org/x/net/idna"

	"github.com/naiba/nezha/model"
	"github.com/naiba/nezha/service/singleton"
)

// Add DDNS profile
// @Summary Add DDNS profile
// @Security BearerAuth
// @Schemes
// @Description Add DDNS profile
// @Tags auth required
// @Accept json
// @param request body model.DDNSForm true "DDNS Request"
// @Produce json
// @Success 200 {object} model.CommonResponse[any]
// @Router /ddns [post]
func createDDNS(c *gin.Context) error {
	var df model.DDNSForm
	var p model.DDNSProfile

	if err := c.ShouldBindJSON(&df); err != nil {
		return err
	}

	if df.MaxRetries < 1 || df.MaxRetries > 10 {
		return errors.New("重试次数必须为大于 1 且不超过 10 的整数")
	}

	p.Name = df.Name
	enableIPv4 := df.EnableIPv4 == "on"
	enableIPv6 := df.EnableIPv6 == "on"
	p.EnableIPv4 = &enableIPv4
	p.EnableIPv6 = &enableIPv6
	p.MaxRetries = df.MaxRetries
	p.Provider = df.Provider
	p.DomainsRaw = df.DomainsRaw
	p.Domains = strings.Split(p.DomainsRaw, ",")
	p.AccessID = df.AccessID
	p.AccessSecret = df.AccessSecret
	p.WebhookURL = df.WebhookURL
	p.WebhookMethod = df.WebhookMethod
	p.WebhookRequestType = df.WebhookRequestType
	p.WebhookRequestBody = df.WebhookRequestBody
	p.WebhookHeaders = df.WebhookHeaders

	for n, domain := range p.Domains {
		// IDN to ASCII
		domainValid, domainErr := idna.Lookup.ToASCII(domain)
		if domainErr != nil {
			return fmt.Errorf("域名 %s 解析错误: %v", domain, domainErr)
		}
		p.Domains[n] = domainValid
	}

	if err := singleton.DB.Create(&p).Error; err != nil {
		return newGormError("%v", err)
	}

	singleton.OnDDNSUpdate()
	c.JSON(http.StatusOK, model.CommonResponse[any]{
		Success: true,
	})
	return nil
}

// Edit DDNS profile
// @Summary Edit DDNS profile
// @Security BearerAuth
// @Schemes
// @Description Edit DDNS profile
// @Tags auth required
// @Accept json
// @param id path string true "Profile ID"
// @param request body model.DDNSForm true "DDNS Request"
// @Produce json
// @Success 200 {object} model.CommonResponse[any]
// @Router /ddns/{id} [patch]
func updateDDNS(c *gin.Context) error {
	idStr := c.Param("id")

	id, err := strconv.ParseUint(idStr, 10, 64)
	if err != nil {
		return err
	}

	var df model.DDNSForm
	if err := c.ShouldBindJSON(&df); err != nil {
		return err
	}

	if df.MaxRetries < 1 || df.MaxRetries > 10 {
		return errors.New("重试次数必须为大于 1 且不超过 10 的整数")
	}

	var p model.DDNSProfile
	if err = singleton.DB.First(&p, id).Error; err != nil {
		return fmt.Errorf("profile id %d does not exist", id)
	}

	p.Name = df.Name
	p.ID = id
	enableIPv4 := df.EnableIPv4 == "on"
	enableIPv6 := df.EnableIPv6 == "on"
	p.EnableIPv4 = &enableIPv4
	p.EnableIPv6 = &enableIPv6
	p.MaxRetries = df.MaxRetries
	p.Provider = df.Provider
	p.DomainsRaw = df.DomainsRaw
	p.Domains = strings.Split(p.DomainsRaw, ",")
	p.AccessID = df.AccessID
	p.AccessSecret = df.AccessSecret
	p.WebhookURL = df.WebhookURL
	p.WebhookMethod = df.WebhookMethod
	p.WebhookRequestType = df.WebhookRequestType
	p.WebhookRequestBody = df.WebhookRequestBody
	p.WebhookHeaders = df.WebhookHeaders

	for n, domain := range p.Domains {
		// IDN to ASCII
		domainValid, domainErr := idna.Lookup.ToASCII(domain)
		if domainErr != nil {
			return fmt.Errorf("域名 %s 解析错误: %v", domain, domainErr)
		}
		p.Domains[n] = domainValid
	}

	if err = singleton.DB.Save(&p).Error; err != nil {
		return newGormError("%v", err)
	}

	singleton.OnDDNSUpdate()
	c.JSON(http.StatusOK, model.CommonResponse[any]{
		Success: true,
	})
	return nil
}

// Batch delete DDNS configurations
// @Summary Batch delete DDNS configurations
// @Security BearerAuth
// @Schemes
// @Description Batch delete DDNS configurations
// @Tags auth required
// @Accept json
// @param request body []uint64 true "id list"
// @Produce json
// @Success 200 {object} model.CommonResponse[any]
// @Router /batch-delete/ddns [post]
func batchDeleteDDNS(c *gin.Context) error {
	var ddnsConfigs []uint64

	if err := c.ShouldBindJSON(&ddnsConfigs); err != nil {
		return err
	}

	if err := singleton.DB.Unscoped().Delete(&model.DDNSProfile{}, "id in (?)", ddnsConfigs).Error; err != nil {
		return newGormError("%v", err)
	}

	singleton.OnDDNSUpdate()
	c.JSON(http.StatusOK, model.CommonResponse[any]{
		Success: true,
	})
	return nil
}

// List DDNS Profiles
// @Summary List DDNS profiles
// @Schemes
// @Description List DDNS profiles
// @Security BearerAuth
// @Tags auth required
// @param id query string false "Profile ID"
// @Produce json
// @Success 200 {object} model.CommonResponse[[]model.DDNSProfile]
// @Router /ddns [get]
func listDDNS(c *gin.Context) error {
	var idList []uint64
	idQuery := c.Query("id")

	if idQuery != "" {
		idListStr := strings.Split(idQuery, ",")
		idList = make([]uint64, 0, len(idListStr))
		for _, v := range idListStr {
			id, err := strconv.ParseUint(v, 10, 64)
			if err != nil {
				return err
			}
			idList = append(idList, id)
		}
	}

	var ddnsProfiles []model.DDNSProfile

	singleton.DDNSCacheLock.RLock()
	if len(idList) > 0 {
		ddnsProfiles = make([]model.DDNSProfile, 0, len(idList))
		for _, id := range idList {
			if profile, ok := singleton.DDNSCache[id]; ok {
				ddnsProfiles = append(ddnsProfiles, *profile)
			} else {
				return fmt.Errorf("profile id %d not found", id)
			}
		}
	} else {
		ddnsProfiles = make([]model.DDNSProfile, 0, len(singleton.DDNSCache))
		for _, profile := range singleton.DDNSCache {
			ddnsProfiles = append(ddnsProfiles, *profile)
		}
	}

	singleton.DDNSCacheLock.RUnlock()
	c.JSON(http.StatusOK, model.CommonResponse[[]model.DDNSProfile]{
		Success: true,
		Data:    ddnsProfiles,
	})
	return nil
}

// List DDNS Providers
// @Summary List DDNS providers
// @Schemes
// @Description List DDNS providers
// @Security BearerAuth
// @Tags auth required
// @Produce json
// @Success 200 {object} model.CommonResponse[[]string]
// @Router /ddns/providers [get]
func listProviders(c *gin.Context) error {
	c.JSON(http.StatusOK, model.CommonResponse[[]string]{
		Success: true,
		Data:    model.ProviderList,
	})
	return nil
}