FranklinWH-Toolbox/service/repositories/api/plane_v1/plane_invitation.go

package plane_v1

import (
	"fmt"

	"go.uber.org/zap"
)

// ==================== Invitation API ====================

// ListInvitations 列出工作空间邀请
func ListInvitations() ([]byte, error) {
	path := fmt.Sprintf("/api/v1/workspaces/%s/invitations/", planeWorkspaceSlug)

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

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

	return resp.Body, nil
}

// CreateInvitation 创建邀请
func CreateInvitation(email string, role int) ([]byte, error) {
	path := fmt.Sprintf("/api/v1/workspaces/%s/invitations/", planeWorkspaceSlug)
	payload := map[string]interface{}{"email": email, "role": role}

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

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

	return resp.Body, nil
}

// GetInvitation 获取邀请详情
func GetInvitation(invitationID string) ([]byte, error) {
	path := fmt.Sprintf("/api/v1/workspaces/%s/invitations/%s/", planeWorkspaceSlug, invitationID)

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

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

	return resp.Body, nil
}

// UpdateInvitation 更新邀请
func UpdateInvitation(invitationID string, data map[string]interface{}) ([]byte, error) {
	path := fmt.Sprintf("/api/v1/workspaces/%s/invitations/%s/", planeWorkspaceSlug, invitationID)

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

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

	return resp.Body, nil
}

// DeleteInvitation 撤销邀请
func DeleteInvitation(invitationID string) error {
	path := fmt.Sprintf("/api/v1/workspaces/%s/invitations/%s/", planeWorkspaceSlug, invitationID)

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

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

	return nil
}