package grpcapi

import (
	"fmt"
	"gitee.com/banyanhouse/distill-infra/apigrpc"
	"gitee.com/banyanhouse/distill-infra/core/ServiceImpl"
	"gitee.com/banyanhouse/distill-infra/core/Services"
	"gitee.com/banyanhouse/distill-infra/register"
	"k8s.io/klog/v2"
)

func init() {
	apigrpc.RegisterGRpcApi(new(GRpcApi))
}

type GRpcApi struct {
}

func (g *GRpcApi) Init(grpcName, grpcPort string) {
	register.GRpcRegister(grpcName, grpcPort)
	grpcService := register.GrpcService()
	err := Services.RegisterGreeterHandler(grpcService.Server(), new(ServiceImpl.GreeterService))
	if err != nil {
		klog.Errorf("GRpc Service impl failed:%s\n", err.Error())
	}
	//go grpcService.Run()

	services, err := register.RegistryCenter().ListServices()
	if err != nil {
		klog.Errorf("get registry service list failed. %s", err.Error())
	}
	for i, service := range services {
		fmt.Printf("%d -----> %s\n", i, service.Name)
	}
}

func (g *GRpcApi) Setup(grpcName, grpcPort string) {

}