package management

import (
	"net/http"
	"time"

	"gitee.com/carlmax_my/authing-golang-sdk/v3/constant"
	"gitee.com/carlmax_my/authing-golang-sdk/v3/util"
)

type ManagementClient struct {
	HttpClient *http.Client
	options    *ManagementClientOptions
	userPoolId string
	eventHub   *util.WebSocketEventHub
}

type ManagementClientOptions struct {
	AccessKeyId     string
	AccessKeySecret string
	TenantId        string
	//Deprecated: Use ReadTimeout instead
	Timeout     int
	ReadTimeout time.Duration
	Lang        string
	Host        string
	/**
	是否跳过 HTTPS 证书检测，默认为 false；如果是私有化部署的场景且证书不被信任，可以设置为 true
	*/
	InsecureSkipVerify bool
	WssHost            string
}

func NewManagementClient(options *ManagementClientOptions) (*ManagementClient, error) {
	if options.Host == "" {
		options.Host = constant.ApiServiceUrl
	}
	if options.WssHost == "" {
		options.WssHost = constant.WebSocketHost
	}
	if options.ReadTimeout == 0 {
		options.ReadTimeout = 10 * time.Second
	}
	c := &ManagementClient{
		options: options,
	}

	if c.HttpClient == nil {
		c.HttpClient = &http.Client{}
		_, err := GetAccessToken(c)
		if err != nil {
			return nil, err
		}
		/*src := oauth2.StaticTokenSource(
			&oauth2.Token{AccessToken: accessToken},
		)
		c.HttpClient = oauth2.NewManagementClient(context.Background(), src)*/
	}
	c.eventHub = util.NewWebSocketEvent()
	return c, nil
}