package plane_v2

import (
	"fmt"

	"go.uber.org/zap"
)

// ==================== Module API ====================

// ListModules 列出模块
func ListModules(slug, projectID string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/", slug, projectID)

	resp, err := planeWebGet(url)
	if err != nil {
		zap.L().Error("[PlaneWeb] ListModules 请求失败", zap.Error(err))
		return nil, err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] ListModules 返回错误", zap.String("status", resp.Status))
		return nil, fmt.Errorf("ListModules 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// CreateModule 创建模块
func CreateModule(slug, projectID string, data map[string]interface{}) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/", slug, projectID)

	resp, err := planeWebPost(url, data)
	if err != nil {
		zap.L().Error("[PlaneWeb] CreateModule 请求失败", zap.Error(err))
		return nil, err
	}

	if resp.StatusCode != 201 {
		zap.L().Error("[PlaneWeb] CreateModule 返回错误",
			zap.String("status", resp.Status),
			zap.String("body", string(resp.Body)),
		)
		return nil, fmt.Errorf("CreateModule 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// GetModule 获取模块详情
func GetModule(slug, projectID, moduleID string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/", slug, projectID, moduleID)

	resp, err := planeWebGet(url)
	if err != nil {
		zap.L().Error("[PlaneWeb] GetModule 请求失败", zap.Error(err))
		return nil, err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] GetModule 返回错误", zap.String("status", resp.Status))
		return nil, fmt.Errorf("GetModule 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// UpdateModule 更新模块
func UpdateModule(slug, projectID, moduleID string, data map[string]interface{}) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/", slug, projectID, moduleID)

	resp, err := planeWebPatch(url, data)
	if err != nil {
		zap.L().Error("[PlaneWeb] UpdateModule 请求失败", zap.Error(err))
		return nil, err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] UpdateModule 返回错误",
			zap.String("status", resp.Status),
			zap.String("body", string(resp.Body)),
		)
		return nil, fmt.Errorf("UpdateModule 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// DeleteModule 删除模块
func DeleteModule(slug, projectID, moduleID string) error {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/", slug, projectID, moduleID)

	resp, err := planeWebDelete(url)
	if err != nil {
		zap.L().Error("[PlaneWeb] DeleteModule 请求失败", zap.Error(err))
		return err
	}

	if resp.StatusCode != 204 {
		zap.L().Error("[PlaneWeb] DeleteModule 返回错误", zap.String("status", resp.Status))
		return fmt.Errorf("DeleteModule 失败: %s", resp.Status)
	}

	return nil
}

// ListModuleIssues 列出模块中的工作项
func ListModuleIssues(slug, projectID, moduleID string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/issues/", slug, projectID, moduleID)

	resp, err := planeWebGet(url)
	if err != nil {
		zap.L().Error("[PlaneWeb] ListModuleIssues 请求失败", zap.Error(err))
		return nil, err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] ListModuleIssues 返回错误", zap.String("status", resp.Status))
		return nil, fmt.Errorf("ListModuleIssues 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// AddIssuesToModule 添加工作项到模块
func AddIssuesToModule(slug, projectID, moduleID string, issueIDs []string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/issues/", slug, projectID, moduleID)
	payload := map[string]interface{}{
		"issues": issueIDs,
	}

	resp, err := planeWebPost(url, payload)
	if err != nil {
		zap.L().Error("[PlaneWeb] AddIssuesToModule 请求失败", zap.Error(err))
		return nil, err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] AddIssuesToModule 返回错误",
			zap.String("status", resp.Status),
			zap.String("body", string(resp.Body)),
		)
		return nil, fmt.Errorf("AddIssuesToModule 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// RemoveIssueFromModule 从模块移除工作项
func RemoveIssueFromModule(slug, projectID, moduleID, issueID string) error {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/issues/%s/", slug, projectID, moduleID, issueID)

	resp, err := planeWebDelete(url)
	if err != nil {
		zap.L().Error("[PlaneWeb] RemoveIssueFromModule 请求失败", zap.Error(err))
		return err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] RemoveIssueFromModule 返回错误", zap.String("status", resp.Status))
		return fmt.Errorf("RemoveIssueFromModule 失败: %s", resp.Status)
	}

	return nil
}

// ListModuleLinks 列出模块链接
func ListModuleLinks(slug, projectID, moduleID string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/module-links/", slug, projectID, moduleID)

	resp, err := planeWebGet(url)
	if err != nil {
		zap.L().Error("[PlaneWeb] ListModuleLinks 请求失败", zap.Error(err))
		return nil, err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] ListModuleLinks 返回错误", zap.String("status", resp.Status))
		return nil, fmt.Errorf("ListModuleLinks 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// CreateModuleLink 创建模块链接
func CreateModuleLink(slug, projectID, moduleID string, data map[string]interface{}) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/module-links/", slug, projectID, moduleID)

	resp, err := planeWebPost(url, data)
	if err != nil {
		zap.L().Error("[PlaneWeb] CreateModuleLink 请求失败", zap.Error(err))
		return nil, err
	}

	if resp.StatusCode != 201 {
		zap.L().Error("[PlaneWeb] CreateModuleLink 返回错误",
			zap.String("status", resp.Status),
			zap.String("body", string(resp.Body)),
		)
		return nil, fmt.Errorf("CreateModuleLink 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// UpdateModuleLink 更新模块链接
func UpdateModuleLink(slug, projectID, moduleID, linkID string, data map[string]interface{}) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/module-links/%s/", slug, projectID, moduleID, linkID)

	resp, err := planeWebPatch(url, data)
	if err != nil {
		zap.L().Error("[PlaneWeb] UpdateModuleLink 请求失败", zap.Error(err))
		return nil, err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] UpdateModuleLink 返回错误",
			zap.String("status", resp.Status),
			zap.String("body", string(resp.Body)),
		)
		return nil, fmt.Errorf("UpdateModuleLink 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// DeleteModuleLink 删除模块链接
func DeleteModuleLink(slug, projectID, moduleID, linkID string) error {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/module-links/%s/", slug, projectID, moduleID, linkID)

	resp, err := planeWebDelete(url)
	if err != nil {
		zap.L().Error("[PlaneWeb] DeleteModuleLink 请求失败", zap.Error(err))
		return err
	}

	if resp.StatusCode != 204 {
		zap.L().Error("[PlaneWeb] DeleteModuleLink 返回错误", zap.String("status", resp.Status))
		return fmt.Errorf("DeleteModuleLink 失败: %s", resp.Status)
	}

	return nil
}

// ArchiveModule 归档模块
func ArchiveModule(slug, projectID, moduleID string) error {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/modules/%s/archive/", slug, projectID, moduleID)

	resp, err := planeWebPost(url, map[string]interface{}{})
	if err != nil {
		zap.L().Error("[PlaneWeb] ArchiveModule 请求失败", zap.Error(err))
		return err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] ArchiveModule 返回错误", zap.String("status", resp.Status))
		return fmt.Errorf("ArchiveModule 失败: %s", resp.Status)
	}

	return nil
}

// ListArchivedModules 列出已归档模块
func ListArchivedModules(slug, projectID string) ([]byte, error) {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/archived-modules/", slug, projectID)

	resp, err := planeWebGet(url)
	if err != nil {
		zap.L().Error("[PlaneWeb] ListArchivedModules 请求失败", zap.Error(err))
		return nil, err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] ListArchivedModules 返回错误", zap.String("status", resp.Status))
		return nil, fmt.Errorf("ListArchivedModules 失败: %s", resp.Status)
	}

	return resp.Body, nil
}

// UnarchiveModule 取消归档模块
func UnarchiveModule(slug, projectID, moduleID string) error {
	url := fmt.Sprintf("/api/workspaces/%s/projects/%s/archived-modules/%s/", slug, projectID, moduleID)

	resp, err := planeWebDelete(url)
	if err != nil {
		zap.L().Error("[PlaneWeb] UnarchiveModule 请求失败", zap.Error(err))
		return err
	}

	if !isWebSuccess(resp.StatusCode) {
		zap.L().Error("[PlaneWeb] UnarchiveModule 返回错误", zap.String("status", resp.Status))
		return fmt.Errorf("UnarchiveModule 失败: %s", resp.Status)
	}

	return nil
}