package service

import (
	"context"
	"fmt"

	"github.com/cloudwego/hertz/pkg/app"
	"github.com/cloudwego/kitex/client"
	consul "github.com/kitex-contrib/registry-consul"
	facade "github.com/suyiiyii/hertz101/app/facade/hertz_gen/facade"
	user1 "github.com/suyiiyii/hertz101/rpc_gen/kitex_gen/user"
	"github.com/suyiiyii/hertz101/rpc_gen/rpc/user"
)

type RegisterService struct {
	RequestContext *app.RequestContext
	Context        context.Context
}

func NewRegisterService(Context context.Context, RequestContext *app.RequestContext) *RegisterService {
	return &RegisterService{RequestContext: RequestContext, Context: Context}
}

func (h *RegisterService) Run(req *facade.RegisterReq) (resp *facade.RegisterResp, err error) {
	//defer func() {
	// hlog.CtxInfof(h.Context, "req = %+v", req)
	// hlog.CtxInfof(h.Context, "resp = %+v", resp)
	//}()
	// todo edit your code
	r, err := consul.NewConsulResolver("10.21.22.53:8500")
	if err != nil {
		return nil, err
	}
	rpcClient, err := user.NewRPCClient("user", client.WithResolver(r))
	if err != nil {
		return nil, err
	}
	loginResp, err := rpcClient.Login(h.Context, &user1.LoginReq{
		Email:    "11",
		Password: "22",
	})
	if err != nil {
		return nil, err
	}
	fmt.Println(loginResp)

	resp = &facade.RegisterResp{
		UserId: loginResp.UserId,
	}
	return
}