package plane_v1

import (
	"fmt"

	"go.uber.org/zap"
)

// ==================== Member API ====================

// ListWorkspaceMembers 列出工作空间成员
func ListWorkspaceMembers() ([]byte, error) {
	path := fmt.Sprintf("/api/v1/workspaces/%s/members/", planeWorkspaceSlug)

	resp, err := planeHttpGet(path)
	if err != nil {
		zap.L().Error("[Plane] ListWorkspaceMembers 请求失败", zap.Error(err))
		return nil, err
	}

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

	return resp.Body, nil
}

// ListProjectMembers 列出项目成员
func ListProjectMembers() ([]byte, error) {
	path := fmt.Sprintf("/api/v1/workspaces/%s/projects/%s/members/", planeWorkspaceSlug, planeProjectId)

	resp, err := planeHttpGet(path)
	if err != nil {
		zap.L().Error("[Plane] ListProjectMembers 请求失败", zap.Error(err))
		return nil, err
	}

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

	return resp.Body, nil
}

// AddProjectMember 添加项目成员
func AddProjectMember(memberID string, role int) ([]byte, error) {
	path := fmt.Sprintf("/api/v1/workspaces/%s/projects/%s/members/", planeWorkspaceSlug, planeProjectId)
	payload := map[string]interface{}{"member": memberID, "role": role}

	resp, err := planeHttpPost(path, payload)
	if err != nil {
		zap.L().Error("[Plane] AddProjectMember 请求失败", zap.Error(err))
		return nil, err
	}

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

	return resp.Body, nil
}

// GetProjectMember 获取项目成员详情
func GetProjectMember(memberRecordID string) ([]byte, error) {
	path := fmt.Sprintf("/api/v1/workspaces/%s/projects/%s/members/%s/", planeWorkspaceSlug, planeProjectId, memberRecordID)

	resp, err := planeHttpGet(path)
	if err != nil {
		zap.L().Error("[Plane] GetProjectMember 请求失败", zap.Error(err))
		return nil, err
	}

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

	return resp.Body, nil
}

// UpdateProjectMemberRole 更新项目成员角色
func UpdateProjectMemberRole(memberRecordID string, role int) ([]byte, error) {
	path := fmt.Sprintf("/api/v1/workspaces/%s/projects/%s/members/%s/", planeWorkspaceSlug, planeProjectId, memberRecordID)
	payload := map[string]interface{}{"role": role}

	resp, err := planeHttpPatch(path, payload)
	if err != nil {
		zap.L().Error("[Plane] UpdateProjectMemberRole 请求失败", zap.Error(err))
		return nil, err
	}

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

	return resp.Body, nil
}

// RemoveProjectMember 移除项目成员
func RemoveProjectMember(memberRecordID string) error {
	path := fmt.Sprintf("/api/v1/workspaces/%s/projects/%s/members/%s/", planeWorkspaceSlug, planeProjectId, memberRecordID)

	resp, err := planeHttpDelete(path)
	if err != nil {
		zap.L().Error("[Plane] RemoveProjectMember 请求失败", zap.Error(err))
		return err
	}

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

	return nil
}