package apigrpc

import (
	"context"
	"gitee.com/banyanhouse/distill-infra"
	"k8s.io/klog/v2"
	"reflect"
	"strconv"
)

var apiInitializerRegister *GRpcInitializeRegister = new(GRpcInitializeRegister)

//注册WEB API初始化对象
func RegisterGRpcApi(ai GRpcInitializer) {
	apiInitializerRegister.Register(ai)
}

func SetupGRpcApi(ai GRpcInitializer) {
	apiInitializerRegister.Setup(ai)
}

// 获取注册的web api初始化对象
func GetGRpcApiInitializers() []GRpcInitializer {
	return apiInitializerRegister.Initializers
}

func GetGRpcSetupApis() []GRpcInitializer {
	return apiInitializerRegister.SetupApis
}

type GRpcApiStarter struct {
	infra.BaseStarter
}

//func (i *GRpcApiStarter) StartBlocking() bool {
//	return true
//}

func (w *GRpcApiStarter) Start(ctx context.Context) {

	//grpcName := ctx.Props().App.Name
	grpcName := infra.Props(ctx).App.Name
	//grpcPort := ":" + strconv.Itoa(ctx.Props().App.Port)
	grpcPort := ":" + strconv.Itoa(infra.Props(ctx).App.Port)

	for _, v := range GetGRpcApiInitializers() {
		of := reflect.TypeOf(v)
		klog.Info("Init Api:%v", of.String())
		v.Init(grpcName, grpcPort)
	}
	for _, v := range GetGRpcSetupApis() {
		klog.Info("Setup Api:%v", v)
		v.Setup(grpcName, grpcPort)
	}
}