func InitProjectClient() {
	addr := fmt.Sprintf("%s:%s", os.Getenv("CONSUL_HOST"), os.Getenv("CONSUL_PORT"))
	r, err := consul1.NewConsulResolver(addr)
	if err != nil {
		panic(err)
	}
	serviceName := "ops.cicd.client"
	c, err := projectsrv.NewClient(
		"ops.eco.cicd",
		client.WithMuxConnection(1),                       // mux
		client.WithRPCTimeout(5*time.Second),              // rpc timeout
		client.WithConnectTimeout(5*time.Second),          // conn timeout
		client.WithFailureRetry(retry.NewFailurePolicy()), // retry
		client.WithSuite(trace.NewDefaultClientSuite()),   // tracer
		client.WithResolver(r),                            // resolver
		client.WithSuite(tracing.NewClientSuite()),
		client.WithClientBasicInfo(&rpcinfo.EndpointBasicInfo{ServiceName: serviceName}),
	)
	if err != nil {
		panic(err)
	}
	ProjectClient = c
}

// Resolve a service info by desc.
func (c *consulResolver) Resolve(_ context.Context, desc string) (discovery.Result, error) {
	var eps []discovery.Instance
	agentServiceList, _, err := c.consulClient.Health().Service(desc, "", true, nil)
	if err != nil {
		return discovery.Result{}, err
	}
	if len(agentServiceList) == 0 {
		return discovery.Result{}, errors.New(fmt.Sprintf("no service found: %s", desc))
	}

	for _, i := range agentServiceList {
		svc := i.Service
		if svc == nil || svc.Address == "" {
			continue
		}

		eps = append(eps, discovery.NewInstance(
			defaultNetwork,
			fmt.Sprint(svc.Address, ":", svc.Port),
			svc.Weights.Passing,
			splitTags(svc.Tags),
		))
	}

	blog.Debugf("before %v", c)
	blog.Debugf("before %v", eps)
	eps = c.filterService(eps)
	blog.Debugf("after %v", eps)
	for _, ep := range eps {
		blog.Debugf("ep: %v", ep)
	}

	return discovery.Result{
		Cacheable: true,
		CacheKey:  desc,
		Instances: eps,
	}, nil
} 

func GetCallee(ctx context.Context) (string, bool) {
	defer func() { recover() }()

	ri := rpcinfo.GetRPCInfo(ctx)
	if ri == nil {
		return "", false
	}
	return ri.To().ServiceName(), true
}