code.lug.pb.go

// Code generated by protoc-gen-lug. DO NOT EDIT.
// versions:
// - protoc-gen-lug v0.1.0
// - protoc         v3.17.3
// source: proto/login/code.proto

package login

import (
	fiber "github.com/pubgo/lug/pkg/builder/fiber"
	grpcc "github.com/pubgo/lug/plugins/grpcc"
	xgen "github.com/pubgo/lug/xgen"
	xerror "github.com/pubgo/xerror"
	grpc "google.golang.org/grpc"
	reflect "reflect"
)

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7

func GetCodeClient(srv string, opts ...func(cfg *grpcc.Cfg)) func(func(cli CodeClient)) error {
	client := grpcc.GetClient(srv, opts...)
	return func(fn func(cli CodeClient)) (err error) {
		defer xerror.RespErr(&err)

		c, err := client.Get()
		if err != nil {
			return xerror.WrapF(err, "srv: %s", srv)
		}

		fn(&codeClient{c})
		return
	}
}
func init() {
	var mthList []xgen.GrpcRestHandler
	mthList = append(mthList, xgen.GrpcRestHandler{
		Input:        &SendCodeRequest{},
		Output:       &SendCodeResponse{},
		Service:      "login.Code",
		Name:         "SendCode",
		Method:       "POST",
		Path:         "/user/code/send-code",
		DefaultUrl:   false,
		ClientStream: false,
		ServerStream: false,
	})
	mthList = append(mthList, xgen.GrpcRestHandler{
		Input:        &VerifyRequest{},
		Output:       &VerifyResponse{},
		Service:      "login.Code",
		Name:         "Verify",
		Method:       "POST",
		Path:         "/user/code/verify",
		DefaultUrl:   false,
		ClientStream: false,
		ServerStream: false,
	})
	mthList = append(mthList, xgen.GrpcRestHandler{
		Input:        &IsCheckImageCodeRequest{},
		Output:       &IsCheckImageCodeResponse{},
		Service:      "login.Code",
		Name:         "IsCheckImageCode",
		Method:       "POST",
		Path:         "/user/code/is-check-image-code",
		DefaultUrl:   false,
		ClientStream: false,
		ServerStream: false,
	})
	mthList = append(mthList, xgen.GrpcRestHandler{
		Input:        &VerifyImageCodeRequest{},
		Output:       &VerifyImageCodeResponse{},
		Service:      "login.Code",
		Name:         "VerifyImageCode",
		Method:       "POST",
		Path:         "/user/code/verify-image-code",
		DefaultUrl:   false,
		ClientStream: false,
		ServerStream: false,
	})
	mthList = append(mthList, xgen.GrpcRestHandler{
		Input:        &GetSendStatusRequest{},
		Output:       &GetSendStatusResponse{},
		Service:      "login.Code",
		Name:         "GetSendStatus",
		Method:       "POST",
		Path:         "/user/code/get-send-status",
		DefaultUrl:   false,
		ClientStream: false,
		ServerStream: false,
	})
	xgen.Add(reflect.ValueOf(RegisterCodeServer), mthList)
	xgen.Add(reflect.ValueOf(RegisterCodeHandlerServer), nil)
}
func RegisterCodeRestServer(app fiber.Router, server CodeServer) {
	xerror.Assert(app == nil || server == nil, "app is nil or server is nil")
	app.Add("POST", "/user/code/send-code", func(ctx *fiber.Ctx) error {
		var req = new(SendCodeRequest)
		xerror.Panic(ctx.BodyParser(req))
		var resp, err = server.SendCode(ctx.UserContext(), req)
		xerror.Panic(err)
		return xerror.Wrap(ctx.JSON(resp))
	})
	app.Add("POST", "/user/code/verify", func(ctx *fiber.Ctx) error {
		var req = new(VerifyRequest)
		xerror.Panic(ctx.BodyParser(req))
		var resp, err = server.Verify(ctx.UserContext(), req)
		xerror.Panic(err)
		return xerror.Wrap(ctx.JSON(resp))
	})
	app.Add("POST", "/user/code/is-check-image-code", func(ctx *fiber.Ctx) error {
		var req = new(IsCheckImageCodeRequest)
		xerror.Panic(ctx.BodyParser(req))
		var resp, err = server.IsCheckImageCode(ctx.UserContext(), req)
		xerror.Panic(err)
		return xerror.Wrap(ctx.JSON(resp))
	})
	app.Add("POST", "/user/code/verify-image-code", func(ctx *fiber.Ctx) error {
		var req = new(VerifyImageCodeRequest)
		xerror.Panic(ctx.BodyParser(req))
		var resp, err = server.VerifyImageCode(ctx.UserContext(), req)
		xerror.Panic(err)
		return xerror.Wrap(ctx.JSON(resp))
	})
	app.Add("POST", "/user/code/get-send-status", func(ctx *fiber.Ctx) error {
		var req = new(GetSendStatusRequest)
		xerror.Panic(ctx.BodyParser(req))
		var resp, err = server.GetSendStatus(ctx.UserContext(), req)
		xerror.Panic(err)
		return xerror.Wrap(ctx.JSON(resp))
	})
}