pw-protobuf/api/ai/ai_http.pb.go

// Code generated by protoc-gen-go-http. DO NOT EDIT.
// versions:
// protoc-gen-go-http v2.0.0

package ai

import (
	context "context"
	base "git.ikuban.com/server/base-protobuf/kuban/api/base"
	reply "git.ikuban.com/server/kratos-utils/http/reply"
	http "github.com/go-kratos/kratos/v2/transport/http"
	binding "github.com/go-kratos/kratos/v2/transport/http/binding"
	emptypb "google.golang.org/protobuf/types/known/emptypb"
	ioutil "io/ioutil"
	time "time"
)

// This is a compile-time assertion to ensure that this generated file
// is compatible with the kratos package it is being compiled against.
var _ = new(context.Context)
var _ = binding.EncodeURL
var _ = ioutil.Discard
var _ = new(time.Time)
var _ = new(reply.SuccessReply)
var _ = new(base.Html)

const _ = http.SupportPackageIsVersion1

type AiHTTPServer interface {
	CreateAIRobot(context.Context, *CreateAIRobotRequest) (*AIRobotIDReply, error)
	CreateAdditionalService(context.Context, *CreateAdditionalServiceRequest) (*CreateAdditionalServiceReply, error)
	DeleteAIRobot(context.Context, *AIRobotIDRequest) (*emptypb.Empty, error)
	FindAIChatRecordList(context.Context, *FindAIChatRecordListRequest) (*AIRecordListReply, error)
	FindAIRobotList(context.Context, *FindAIRobotListRequest) (*AIRobotList, error)
	FindAITemplate(context.Context, *FindAITemplateRequest) (*FindAITemplateReply, error)
	FindAdditionalServiceTemplateList(context.Context, *emptypb.Empty) (*FindAdditionalServiceTemplateListReply, error)
	GetAIRobot(context.Context, *AIRobotIDRequest) (*AIRobotInfo, error)
	GetAdditionalService(context.Context, *GetAdditionalServiceRequest) (*GetAdditionalServiceReply, error)
	SendAIChat(context.Context, *SendAIChatRequest) (*emptypb.Empty, error)
	UpdateAIRobot(context.Context, *UpdateAIRobotRequest) (*AIRobotIDReply, error)
	UpdateAdditionalService(context.Context, *UpdateAdditionalServiceRequest) (*emptypb.Empty, error)
}

func RegisterAiHTTPServer(s *http.Server, srv AiHTTPServer) {
	r := s.Route("/")
	r.POST("/api/ai/template/list", _Ai_FindAITemplate0_HTTP_Handler(srv))
	r.POST("/api/ai/create", _Ai_CreateAIRobot0_HTTP_Handler(srv))
	r.POST("/api/ai/delete", _Ai_DeleteAIRobot0_HTTP_Handler(srv))
	r.POST("/api/ai/update", _Ai_UpdateAIRobot0_HTTP_Handler(srv))
	r.POST("/api/ai/find/list", _Ai_FindAIRobotList0_HTTP_Handler(srv))
	r.POST("/api/ai/find/info", _Ai_GetAIRobot0_HTTP_Handler(srv))
	r.POST("/api/ai/chat/record", _Ai_FindAIChatRecordList0_HTTP_Handler(srv))
	r.POST("/api/ai/send", _Ai_SendAIChat0_HTTP_Handler(srv))
	r.POST("/api/ai/service/list", _Ai_FindAdditionalServiceTemplateList0_HTTP_Handler(srv))
	r.POST("/api/ai/service/get", _Ai_GetAdditionalService0_HTTP_Handler(srv))
	r.POST("/api/ai/service/create", _Ai_CreateAdditionalService0_HTTP_Handler(srv))
	r.POST("/api/ai/service/update", _Ai_UpdateAdditionalService0_HTTP_Handler(srv))
}

func _Ai_FindAITemplate0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
	return func(ctx http.Context) error {
		var in FindAITemplateRequest
		if err := ctx.Bind(&in); err != nil {
			return err
		}
		if err := ctx.BindQuery(&in); err != nil {
			return err
		}
		http.SetOperation(ctx, "/api.ai.Ai/FindAITemplate")
		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
			return srv.FindAITemplate(ctx, req.(*FindAITemplateRequest))
		})
		out, err := h(ctx, &in)
		if err != nil {
			return err
		}
		success := &reply.SuccessReply{
			Code: 0,
		}
		if out != nil {
			success.Data = out
		}
		return ctx.Result(200, success)
	}
}

func _Ai_CreateAIRobot0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
	return func(ctx http.Context) error {
		var in CreateAIRobotRequest
		if err := ctx.Bind(&in); err != nil {
			return err
		}
		if err := ctx.BindQuery(&in); err != nil {
			return err
		}
		http.SetOperation(ctx, "/api.ai.Ai/CreateAIRobot")
		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
			return srv.CreateAIRobot(ctx, req.(*CreateAIRobotRequest))
		})
		out, err := h(ctx, &in)
		if err != nil {
			return err
		}
		success := &reply.SuccessReply{
			Code: 0,
		}
		if out != nil {
			success.Data = out
		}
		return ctx.Result(200, success)
	}
}

func _Ai_DeleteAIRobot0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
	return func(ctx http.Context) error {
		var in AIRobotIDRequest
		if err := ctx.Bind(&in); err != nil {
			return err
		}
		if err := ctx.BindQuery(&in); err != nil {
			return err
		}
		http.SetOperation(ctx, "/api.ai.Ai/DeleteAIRobot")
		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
			return srv.DeleteAIRobot(ctx, req.(*AIRobotIDRequest))
		})
		out, err := h(ctx, &in)
		if err != nil {
			return err
		}
		success := &reply.SuccessReply{
			Code: 0,
		}
		if out != nil {
			success.Data = out
		}
		return ctx.Result(200, success)
	}
}

func _Ai_UpdateAIRobot0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
	return func(ctx http.Context) error {
		var in UpdateAIRobotRequest
		if err := ctx.Bind(&in); err != nil {
			return err
		}
		if err := ctx.BindQuery(&in); err != nil {
			return err
		}
		http.SetOperation(ctx, "/api.ai.Ai/UpdateAIRobot")
		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
			return srv.UpdateAIRobot(ctx, req.(*UpdateAIRobotRequest))
		})
		out, err := h(ctx, &in)
		if err != nil {
			return err
		}
		success := &reply.SuccessReply{
			Code: 0,
		}
		if out != nil {
			success.Data = out
		}
		return ctx.Result(200, success)
	}
}

func _Ai_FindAIRobotList0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
	return func(ctx http.Context) error {
		var in FindAIRobotListRequest
		if err := ctx.Bind(&in); err != nil {
			return err
		}
		if err := ctx.BindQuery(&in); err != nil {
			return err
		}
		http.SetOperation(ctx, "/api.ai.Ai/FindAIRobotList")
		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
			return srv.FindAIRobotList(ctx, req.(*FindAIRobotListRequest))
		})
		out, err := h(ctx, &in)
		if err != nil {
			return err
		}
		success := &reply.SuccessReply{
			Code: 0,
		}
		if out != nil {
			success.Data = out
		}
		return ctx.Result(200, success)
	}
}

func _Ai_GetAIRobot0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
	return func(ctx http.Context) error {
		var in AIRobotIDRequest
		if err := ctx.Bind(&in); err != nil {
			return err
		}
		if err := ctx.BindQuery(&in); err != nil {
			return err
		}
		http.SetOperation(ctx, "/api.ai.Ai/GetAIRobot")
		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
			return srv.GetAIRobot(ctx, req.(*AIRobotIDRequest))
		})
		out, err := h(ctx, &in)
		if err != nil {
			return err
		}
		success := &reply.SuccessReply{
			Code: 0,
		}
		if out != nil {
			success.Data = out
		}
		return ctx.Result(200, success)
	}
}

func _Ai_FindAIChatRecordList0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
	return func(ctx http.Context) error {
		var in FindAIChatRecordListRequest
		if err := ctx.Bind(&in); err != nil {
			return err
		}
		if err := ctx.BindQuery(&in); err != nil {
			return err
		}
		http.SetOperation(ctx, "/api.ai.Ai/FindAIChatRecordList")
		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
			return srv.FindAIChatRecordList(ctx, req.(*FindAIChatRecordListRequest))
		})
		out, err := h(ctx, &in)
		if err != nil {
			return err
		}
		success := &reply.SuccessReply{
			Code: 0,
		}
		if out != nil {
			success.Data = out
		}
		return ctx.Result(200, success)
	}
}

func _Ai_SendAIChat0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
	return func(ctx http.Context) error {
		var in SendAIChatRequest
		if err := ctx.Bind(&in); err != nil {
			return err
		}
		if err := ctx.BindQuery(&in); err != nil {
			return err
		}
		http.SetOperation(ctx, "/api.ai.Ai/SendAIChat")
		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
			return srv.SendAIChat(ctx, req.(*SendAIChatRequest))
		})
		out, err := h(ctx, &in)
		if err != nil {
			return err
		}
		success := &reply.SuccessReply{
			Code: 0,
		}
		if out != nil {
			success.Data = out
		}
		return ctx.Result(200, success)
	}
}

func _Ai_FindAdditionalServiceTemplateList0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
	return func(ctx http.Context) error {
		var in emptypb.Empty
		if err := ctx.Bind(&in); err != nil {
			return err
		}
		if err := ctx.BindQuery(&in); err != nil {
			return err
		}
		http.SetOperation(ctx, "/api.ai.Ai/FindAdditionalServiceTemplateList")
		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
			return srv.FindAdditionalServiceTemplateList(ctx, req.(*emptypb.Empty))
		})
		out, err := h(ctx, &in)
		if err != nil {
			return err
		}
		success := &reply.SuccessReply{
			Code: 0,
		}
		if out != nil {
			success.Data = out
		}
		return ctx.Result(200, success)
	}
}

func _Ai_GetAdditionalService0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
	return func(ctx http.Context) error {
		var in GetAdditionalServiceRequest
		if err := ctx.Bind(&in); err != nil {
			return err
		}
		if err := ctx.BindQuery(&in); err != nil {
			return err
		}
		http.SetOperation(ctx, "/api.ai.Ai/GetAdditionalService")
		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
			return srv.GetAdditionalService(ctx, req.(*GetAdditionalServiceRequest))
		})
		out, err := h(ctx, &in)
		if err != nil {
			return err
		}
		success := &reply.SuccessReply{
			Code: 0,
		}
		if out != nil {
			success.Data = out
		}
		return ctx.Result(200, success)
	}
}

func _Ai_CreateAdditionalService0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
	return func(ctx http.Context) error {
		var in CreateAdditionalServiceRequest
		if err := ctx.Bind(&in); err != nil {
			return err
		}
		if err := ctx.BindQuery(&in); err != nil {
			return err
		}
		http.SetOperation(ctx, "/api.ai.Ai/CreateAdditionalService")
		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
			return srv.CreateAdditionalService(ctx, req.(*CreateAdditionalServiceRequest))
		})
		out, err := h(ctx, &in)
		if err != nil {
			return err
		}
		success := &reply.SuccessReply{
			Code: 0,
		}
		if out != nil {
			success.Data = out
		}
		return ctx.Result(200, success)
	}
}

func _Ai_UpdateAdditionalService0_HTTP_Handler(srv AiHTTPServer) func(ctx http.Context) error {
	return func(ctx http.Context) error {
		var in UpdateAdditionalServiceRequest
		if err := ctx.Bind(&in); err != nil {
			return err
		}
		if err := ctx.BindQuery(&in); err != nil {
			return err
		}
		http.SetOperation(ctx, "/api.ai.Ai/UpdateAdditionalService")
		h := ctx.Middleware(func(ctx context.Context, req interface{}) (interface{}, error) {
			return srv.UpdateAdditionalService(ctx, req.(*UpdateAdditionalServiceRequest))
		})
		out, err := h(ctx, &in)
		if err != nil {
			return err
		}
		success := &reply.SuccessReply{
			Code: 0,
		}
		if out != nil {
			success.Data = out
		}
		return ctx.Result(200, success)
	}
}

type AiHTTPClient interface {
	CreateAIRobot(ctx context.Context, req *CreateAIRobotRequest, opts ...http.CallOption) (rsp *AIRobotIDReply, err error)
	CreateAdditionalService(ctx context.Context, req *CreateAdditionalServiceRequest, opts ...http.CallOption) (rsp *CreateAdditionalServiceReply, err error)
	DeleteAIRobot(ctx context.Context, req *AIRobotIDRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	FindAIChatRecordList(ctx context.Context, req *FindAIChatRecordListRequest, opts ...http.CallOption) (rsp *AIRecordListReply, err error)
	FindAIRobotList(ctx context.Context, req *FindAIRobotListRequest, opts ...http.CallOption) (rsp *AIRobotList, err error)
	FindAITemplate(ctx context.Context, req *FindAITemplateRequest, opts ...http.CallOption) (rsp *FindAITemplateReply, err error)
	FindAdditionalServiceTemplateList(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *FindAdditionalServiceTemplateListReply, err error)
	GetAIRobot(ctx context.Context, req *AIRobotIDRequest, opts ...http.CallOption) (rsp *AIRobotInfo, err error)
	GetAdditionalService(ctx context.Context, req *GetAdditionalServiceRequest, opts ...http.CallOption) (rsp *GetAdditionalServiceReply, err error)
	SendAIChat(ctx context.Context, req *SendAIChatRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	UpdateAIRobot(ctx context.Context, req *UpdateAIRobotRequest, opts ...http.CallOption) (rsp *AIRobotIDReply, err error)
	UpdateAdditionalService(ctx context.Context, req *UpdateAdditionalServiceRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
}

type AiHTTPClientImpl struct {
	cc *http.Client
}

func NewAiHTTPClient(client *http.Client) AiHTTPClient {
	return &AiHTTPClientImpl{client}
}

func (c *AiHTTPClientImpl) CreateAIRobot(ctx context.Context, in *CreateAIRobotRequest, opts ...http.CallOption) (*AIRobotIDReply, error) {
	var out AIRobotIDReply
	pattern := "/api/ai/create"
	path := binding.EncodeURL(pattern, in, false)
	opts = append(opts, http.Operation("/api.ai.Ai/CreateAIRobot"))
	opts = append(opts, http.PathTemplate(pattern))
	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
	if err != nil {
		return nil, err
	}
	return &out, err
}

func (c *AiHTTPClientImpl) CreateAdditionalService(ctx context.Context, in *CreateAdditionalServiceRequest, opts ...http.CallOption) (*CreateAdditionalServiceReply, error) {
	var out CreateAdditionalServiceReply
	pattern := "/api/ai/service/create"
	path := binding.EncodeURL(pattern, in, false)
	opts = append(opts, http.Operation("/api.ai.Ai/CreateAdditionalService"))
	opts = append(opts, http.PathTemplate(pattern))
	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
	if err != nil {
		return nil, err
	}
	return &out, err
}

func (c *AiHTTPClientImpl) DeleteAIRobot(ctx context.Context, in *AIRobotIDRequest, opts ...http.CallOption) (*emptypb.Empty, error) {
	var out emptypb.Empty
	pattern := "/api/ai/delete"
	path := binding.EncodeURL(pattern, in, false)
	opts = append(opts, http.Operation("/api.ai.Ai/DeleteAIRobot"))
	opts = append(opts, http.PathTemplate(pattern))
	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
	if err != nil {
		return nil, err
	}
	return &out, err
}

func (c *AiHTTPClientImpl) FindAIChatRecordList(ctx context.Context, in *FindAIChatRecordListRequest, opts ...http.CallOption) (*AIRecordListReply, error) {
	var out AIRecordListReply
	pattern := "/api/ai/chat/record"
	path := binding.EncodeURL(pattern, in, false)
	opts = append(opts, http.Operation("/api.ai.Ai/FindAIChatRecordList"))
	opts = append(opts, http.PathTemplate(pattern))
	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
	if err != nil {
		return nil, err
	}
	return &out, err
}

func (c *AiHTTPClientImpl) FindAIRobotList(ctx context.Context, in *FindAIRobotListRequest, opts ...http.CallOption) (*AIRobotList, error) {
	var out AIRobotList
	pattern := "/api/ai/find/list"
	path := binding.EncodeURL(pattern, in, false)
	opts = append(opts, http.Operation("/api.ai.Ai/FindAIRobotList"))
	opts = append(opts, http.PathTemplate(pattern))
	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
	if err != nil {
		return nil, err
	}
	return &out, err
}

func (c *AiHTTPClientImpl) FindAITemplate(ctx context.Context, in *FindAITemplateRequest, opts ...http.CallOption) (*FindAITemplateReply, error) {
	var out FindAITemplateReply
	pattern := "/api/ai/template/list"
	path := binding.EncodeURL(pattern, in, false)
	opts = append(opts, http.Operation("/api.ai.Ai/FindAITemplate"))
	opts = append(opts, http.PathTemplate(pattern))
	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
	if err != nil {
		return nil, err
	}
	return &out, err
}

func (c *AiHTTPClientImpl) FindAdditionalServiceTemplateList(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*FindAdditionalServiceTemplateListReply, error) {
	var out FindAdditionalServiceTemplateListReply
	pattern := "/api/ai/service/list"
	path := binding.EncodeURL(pattern, in, false)
	opts = append(opts, http.Operation("/api.ai.Ai/FindAdditionalServiceTemplateList"))
	opts = append(opts, http.PathTemplate(pattern))
	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
	if err != nil {
		return nil, err
	}
	return &out, err
}

func (c *AiHTTPClientImpl) GetAIRobot(ctx context.Context, in *AIRobotIDRequest, opts ...http.CallOption) (*AIRobotInfo, error) {
	var out AIRobotInfo
	pattern := "/api/ai/find/info"
	path := binding.EncodeURL(pattern, in, false)
	opts = append(opts, http.Operation("/api.ai.Ai/GetAIRobot"))
	opts = append(opts, http.PathTemplate(pattern))
	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
	if err != nil {
		return nil, err
	}
	return &out, err
}

func (c *AiHTTPClientImpl) GetAdditionalService(ctx context.Context, in *GetAdditionalServiceRequest, opts ...http.CallOption) (*GetAdditionalServiceReply, error) {
	var out GetAdditionalServiceReply
	pattern := "/api/ai/service/get"
	path := binding.EncodeURL(pattern, in, false)
	opts = append(opts, http.Operation("/api.ai.Ai/GetAdditionalService"))
	opts = append(opts, http.PathTemplate(pattern))
	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
	if err != nil {
		return nil, err
	}
	return &out, err
}

func (c *AiHTTPClientImpl) SendAIChat(ctx context.Context, in *SendAIChatRequest, opts ...http.CallOption) (*emptypb.Empty, error) {
	var out emptypb.Empty
	pattern := "/api/ai/send"
	path := binding.EncodeURL(pattern, in, false)
	opts = append(opts, http.Operation("/api.ai.Ai/SendAIChat"))
	opts = append(opts, http.PathTemplate(pattern))
	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
	if err != nil {
		return nil, err
	}
	return &out, err
}

func (c *AiHTTPClientImpl) UpdateAIRobot(ctx context.Context, in *UpdateAIRobotRequest, opts ...http.CallOption) (*AIRobotIDReply, error) {
	var out AIRobotIDReply
	pattern := "/api/ai/update"
	path := binding.EncodeURL(pattern, in, false)
	opts = append(opts, http.Operation("/api.ai.Ai/UpdateAIRobot"))
	opts = append(opts, http.PathTemplate(pattern))
	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
	if err != nil {
		return nil, err
	}
	return &out, err
}

func (c *AiHTTPClientImpl) UpdateAdditionalService(ctx context.Context, in *UpdateAdditionalServiceRequest, opts ...http.CallOption) (*emptypb.Empty, error) {
	var out emptypb.Empty
	pattern := "/api/ai/service/update"
	path := binding.EncodeURL(pattern, in, false)
	opts = append(opts, http.Operation("/api.ai.Ai/UpdateAdditionalService"))
	opts = append(opts, http.PathTemplate(pattern))
	err := c.cc.Invoke(ctx, "POST", path, in, &out, opts...)
	if err != nil {
		return nil, err
	}
	return &out, err
}