package rpc

import (
	"context"
	"sync"

	"github.com/infraboard/mcube/logger"
	"github.com/infraboard/mcube/logger/zap"
	"google.golang.org/grpc"
	"google.golang.org/grpc/credentials/insecure"

	"gitee.com/go-course/go8/projects/devcloud/mcenter/apps/code"
	"gitee.com/go-course/go8/projects/devcloud/mcenter/apps/endpoint"
	"gitee.com/go-course/go8/projects/devcloud/mcenter/apps/permission"
	"gitee.com/go-course/go8/projects/devcloud/mcenter/apps/service"
	"gitee.com/go-course/go8/projects/devcloud/mcenter/apps/token"
)

// NewClient todo
func NewClient(conf *Config) (*ClientSet, error) {
	zap.DevelopmentSetup()
	log := zap.L()

	conn, err := grpc.Dial(
		conf.Address,
		grpc.WithTransportCredentials(insecure.NewCredentials()),
		grpc.WithPerRPCCredentials(conf.Credentials()),
	)
	if err != nil {
		return nil, err
	}

	return &ClientSet{
		conn: conn,
		log:  log,
		conf: conf,
	}, nil
}

// Client 客户端
type ClientSet struct {
	conn *grpc.ClientConn
	log  logger.Logger
	conf *Config
	svr  *service.Service
	lock sync.Mutex
}

// Token服务SDK
func (c *ClientSet) Token() token.RPCClient {
	return token.NewRPCClient(c.conn)
}

// Endpoint服务的SDK
func (c *ClientSet) Endpoint() endpoint.RPCClient {
	return endpoint.NewRPCClient(c.conn)
}

// Endpoint服务的SDK
func (c *ClientSet) Permission() permission.RPCClient {
	return permission.NewRPCClient(c.conn)
}

// Code服务的SDK
func (c *ClientSet) Code() code.RPCClient {
	return code.NewRPCClient(c.conn)
}

// 返回客户端服务信息
func (c *ClientSet) ClientInfo(ctx context.Context) (*service.Service, error) {
	c.lock.Lock()
	defer c.lock.Unlock()

	if c.svr != nil {
		return c.svr, nil
	}

	req := service.NewValidateCredentialRequest(c.conf.ClientID, c.conf.ClientSecret)
	svc, err := c.Service().ValidateCredential(ctx, req)
	if err != nil {
		return nil, err
	}
	c.svr = svc
	return c.svr, nil
}

// 如何注册, 获取到当前所有的路由定义, 把这些路由定义转化为Endpoint, 然后进行注册
// Gin 不支持
// GoRestful 支持

// Service 内部服务管理
func (c *ClientSet) Service() service.RPCClient {
	return service.NewRPCClient(c.conn)
}

// 这个地方有安全风险
func (c *ClientSet) Config() Config {
	// c.conf.ClientSecret 是有风险的
	// ? 什么情况下 client secret会泄露
	return *c.conf
}