/**
 * @Author: Echo
 * @Author:1711788888@qq.com
 * @Date: 2021/5/27 20:44
 * @Desc: 资料管理
 */

package profile

import (
	"git.echol.cn/loser/tencent-im/internal/core"
	"git.echol.cn/loser/tencent-im/internal/enum"
	"git.echol.cn/loser/tencent-im/internal/types"
)

const (
	service            = "profile"
	commandSetProfile  = "portrait_set"
	commandGetProfiles = "portrait_get"
)

type API interface {
	// SetProfile 设置资料
	// 支持 标配资料字段 和 自定义资料字段 的设置
	// 点击查看详细文档:
	// https://cloud.tencent.com/document/product/269/1640
	SetProfile(profile *Profile) (err error)

	// GetProfiles 拉取资料
	// 支持拉取好友和非好友的资料字段。
	// 支持拉取 标配资料字段 和 自定义资料字段。
	// 建议每次拉取的用户数不超过100，避免因回包数据量太大导致回包失败。
	// 请确保请求中的所有帐号都已导入即时通信 IM，如果请求中含有未导入即时通信 IM 的帐号，即时通信 IM 后台将会提示错误。
	// 点击查看详细文档:
	// https://cloud.tencent.com/document/product/269/1639
	GetProfiles(userIds []string, attrs []string) (profiles []*Profile, err error)
}

type api struct {
	client core.Client
}

func NewAPI(client core.Client) API {
	return &api{client: client}
}

// SetProfile 设置资料
// 支持 标配资料字段 和 自定义资料字段 的设置
// 点击查看详细文档:
// https://cloud.tencent.com/document/product/269/1640
func (a *api) SetProfile(profile *Profile) (err error) {
	if err = profile.CheckError(); err != nil {
		return
	}

	userId := profile.GetUserId()

	attrs := profile.GetAttrs()

	if len(attrs) == 0 {
		err = core.NewError(enum.InvalidParamsCode, "the attributes is not set")
		return
	}

	req := &setProfileReq{UserId: userId, Attrs: make([]*types.TagPair, 0, len(attrs))}

	for tag, value := range attrs {
		req.Attrs = append(req.Attrs, &types.TagPair{
			Tag:   tag,
			Value: value,
		})
	}

	if err = a.client.Post(service, commandSetProfile, req, &types.ActionBaseResp{}); err != nil {
		return
	}

	return
}

// GetProfiles 拉取资料
// 支持拉取好友和非好友的资料字段。
// 支持拉取 标配资料字段 和 自定义资料字段。
// 建议每次拉取的用户数不超过100，避免因回包数据量太大导致回包失败。
// 请确保请求中的所有帐号都已导入即时通信 IM，如果请求中含有未导入即时通信 IM 的帐号，即时通信 IM 后台将会提示错误。
// 点击查看详细文档:
// https://cloud.tencent.com/document/product/269/1639
func (a *api) GetProfiles(userIds []string, attrs []string) (profiles []*Profile, err error) {
	req := &getProfileReq{UserIds: userIds, TagList: attrs}
	resp := &getProfileResp{}

	if err = a.client.Post(service, commandGetProfiles, req, resp); err != nil {
		return
	}

	for _, account := range resp.UserProfiles {
		p := NewProfile(account.UserId)
		p.SetError(account.ResultCode, account.ResultInfo)
		for _, item := range account.Profile {
			p.SetAttr(item.Tag, item.Value)
		}
		profiles = append(profiles, p)
	}

	return
}