package pub

import (
	"context"

	"perms-system-server/internal/response"
	"perms-system-server/internal/svc"
	"perms-system-server/internal/types"

	"github.com/zeromicro/go-zero/core/logx"
)

type SyncPermsLogic struct {
	logx.Logger
	ctx    context.Context
	svcCtx *svc.ServiceContext
}

func NewSyncPermsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SyncPermsLogic {
	return &SyncPermsLogic{
		Logger: logx.WithContext(ctx),
		ctx:    ctx,
		svcCtx: svcCtx,
	}
}

// SyncPerms 同步权限声明。产品服务端通过 appKey/appSecret 认证后，批量同步权限定义（新增/更新/禁用不在列表中的权限）。
func (l *SyncPermsLogic) SyncPerms(req *types.SyncPermsReq) (resp *types.SyncPermsResp, err error) {
	items := make([]SyncPermItem, len(req.Perms))
	for i, p := range req.Perms {
		items[i] = SyncPermItem{Code: p.Code, Name: p.Name, Remark: p.Remark}
	}

	result, err := ExecuteSyncPerms(l.ctx, l.svcCtx, req.AppKey, req.AppSecret, items)
	if err != nil {
		if se, ok := err.(*SyncPermsError); ok {
			switch se.Code {
			case 400:
				return nil, response.ErrBadRequest(se.Message)
			case 401:
				return nil, response.ErrUnauthorized(se.Message)
			case 403:
				return nil, response.ErrForbidden(se.Message)
			default:
				return nil, err
			}
		}
		return nil, err
	}

	return &types.SyncPermsResp{
		Added:    result.Added,
		Updated:  result.Updated,
		Disabled: result.Disabled,
	}, nil
}