// Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.3.0 // - protoc v4.22.3 // source: ai.proto package ai import ( context "context" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" emptypb "google.golang.org/protobuf/types/known/emptypb" ) // 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 const ( Ai_FindAITemplate_FullMethodName = "/api.ai.Ai/FindAITemplate" Ai_CreateAIRobot_FullMethodName = "/api.ai.Ai/CreateAIRobot" Ai_DeleteAIRobot_FullMethodName = "/api.ai.Ai/DeleteAIRobot" Ai_UpdateAIRobot_FullMethodName = "/api.ai.Ai/UpdateAIRobot" Ai_FindAIRobotList_FullMethodName = "/api.ai.Ai/FindAIRobotList" Ai_GetAIRobot_FullMethodName = "/api.ai.Ai/GetAIRobot" Ai_FindAIChatRecordList_FullMethodName = "/api.ai.Ai/FindAIChatRecordList" Ai_SendAIChat_FullMethodName = "/api.ai.Ai/SendAIChat" Ai_FindAdditionalServiceTemplateList_FullMethodName = "/api.ai.Ai/FindAdditionalServiceTemplateList" Ai_GetAdditionalService_FullMethodName = "/api.ai.Ai/GetAdditionalService" Ai_UpdateAdditionalService_FullMethodName = "/api.ai.Ai/UpdateAdditionalService" Ai_FindUserAIMessage_FullMethodName = "/api.ai.Ai/FindUserAIMessage" Ai_CronAdditionalService_FullMethodName = "/api.ai.Ai/CronAdditionalService" Ai_GetIsRead_FullMethodName = "/api.ai.Ai/GetIsRead" Ai_GetAIShareMessage_FullMethodName = "/api.ai.Ai/GetAIShareMessage" Ai_GetShareQrcode_FullMethodName = "/api.ai.Ai/GetShareQrcode" Ai_SetVideoLink_FullMethodName = "/api.ai.Ai/SetVideoLink" Ai_VipUpAI_FullMethodName = "/api.ai.Ai/VipUpAI" Ai_ShareUserInto_FullMethodName = "/api.ai.Ai/ShareUserInto" Ai_GetMiniProgramConf_FullMethodName = "/api.ai.Ai/GetMiniProgramConf" Ai_GetAISubscribeMessage_FullMethodName = "/api.ai.Ai/GetAISubscribeMessage" Ai_CronSendAIMessage_FullMethodName = "/api.ai.Ai/CronSendAIMessage" ) // AiClient is the client API for Ai service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type AiClient interface { // 查询AI模板 FindAITemplate(ctx context.Context, in *FindAITemplateRequest, opts ...grpc.CallOption) (*FindAITemplateReply, error) // 创建AI CreateAIRobot(ctx context.Context, in *CreateAIRobotRequest, opts ...grpc.CallOption) (*AIRobotIDReply, error) // 销毁AI DeleteAIRobot(ctx context.Context, in *AIRobotIDRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // 更新AI UpdateAIRobot(ctx context.Context, in *UpdateAIRobotRequest, opts ...grpc.CallOption) (*AIRobotIDReply, error) // 查询AI机器人列表 FindAIRobotList(ctx context.Context, in *FindAIRobotListRequest, opts ...grpc.CallOption) (*AIRobotList, error) // 查询AI机器人 GetAIRobot(ctx context.Context, in *AIRobotIDRequest, opts ...grpc.CallOption) (*AIRobotInfo, error) // 查询AI聊天记录 FindAIChatRecordList(ctx context.Context, in *FindAIChatRecordListRequest, opts ...grpc.CallOption) (*AIRecordListReply, error) // 发送消息给ai SendAIChat(ctx context.Context, in *SendAIChatRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // 查询额外服务列表 FindAdditionalServiceTemplateList(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FindAdditionalServiceTemplateListReply, error) // 获取额外服务 GetAdditionalService(ctx context.Context, in *GetAdditionalServiceRequest, opts ...grpc.CallOption) (*GetAdditionalServiceReply, error) // 更新并创建额外服务 UpdateAdditionalService(ctx context.Context, in *UpdateAdditionalServiceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // 查询用户的ai信息 FindUserAIMessage(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FindUserAIMessageReply, error) // 定时执行服务 CronAdditionalService(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) // 用户已读 GetIsRead(ctx context.Context, in *GetIsReadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // 获取AI升级信息 GetAIShareMessage(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*GetAIShareMessageReply, error) // 获取二维码 GetShareQrcode(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*GetShareQrcodeReply, error) // 保存视频链接 SetVideoLink(ctx context.Context, in *SetVideoLinkRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // vip直接升级 VipUpAI(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // 用户受到邀请 ShareUserInto(ctx context.Context, in *ShareUserIntoRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // vip直接升级 GetMiniProgramConf(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetMiniProgramConfReply, error) // 获取ai订阅消息模板 GetAISubscribeMessage(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetAISubscribeMessageReply, error) CronSendAIMessage(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) } type aiClient struct { cc grpc.ClientConnInterface } func NewAiClient(cc grpc.ClientConnInterface) AiClient { return &aiClient{cc} } func (c *aiClient) FindAITemplate(ctx context.Context, in *FindAITemplateRequest, opts ...grpc.CallOption) (*FindAITemplateReply, error) { out := new(FindAITemplateReply) err := c.cc.Invoke(ctx, Ai_FindAITemplate_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) CreateAIRobot(ctx context.Context, in *CreateAIRobotRequest, opts ...grpc.CallOption) (*AIRobotIDReply, error) { out := new(AIRobotIDReply) err := c.cc.Invoke(ctx, Ai_CreateAIRobot_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) DeleteAIRobot(ctx context.Context, in *AIRobotIDRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Ai_DeleteAIRobot_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) UpdateAIRobot(ctx context.Context, in *UpdateAIRobotRequest, opts ...grpc.CallOption) (*AIRobotIDReply, error) { out := new(AIRobotIDReply) err := c.cc.Invoke(ctx, Ai_UpdateAIRobot_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) FindAIRobotList(ctx context.Context, in *FindAIRobotListRequest, opts ...grpc.CallOption) (*AIRobotList, error) { out := new(AIRobotList) err := c.cc.Invoke(ctx, Ai_FindAIRobotList_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) GetAIRobot(ctx context.Context, in *AIRobotIDRequest, opts ...grpc.CallOption) (*AIRobotInfo, error) { out := new(AIRobotInfo) err := c.cc.Invoke(ctx, Ai_GetAIRobot_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) FindAIChatRecordList(ctx context.Context, in *FindAIChatRecordListRequest, opts ...grpc.CallOption) (*AIRecordListReply, error) { out := new(AIRecordListReply) err := c.cc.Invoke(ctx, Ai_FindAIChatRecordList_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) SendAIChat(ctx context.Context, in *SendAIChatRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Ai_SendAIChat_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) FindAdditionalServiceTemplateList(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FindAdditionalServiceTemplateListReply, error) { out := new(FindAdditionalServiceTemplateListReply) err := c.cc.Invoke(ctx, Ai_FindAdditionalServiceTemplateList_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) GetAdditionalService(ctx context.Context, in *GetAdditionalServiceRequest, opts ...grpc.CallOption) (*GetAdditionalServiceReply, error) { out := new(GetAdditionalServiceReply) err := c.cc.Invoke(ctx, Ai_GetAdditionalService_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) UpdateAdditionalService(ctx context.Context, in *UpdateAdditionalServiceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Ai_UpdateAdditionalService_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) FindUserAIMessage(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FindUserAIMessageReply, error) { out := new(FindUserAIMessageReply) err := c.cc.Invoke(ctx, Ai_FindUserAIMessage_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) CronAdditionalService(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Ai_CronAdditionalService_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) GetIsRead(ctx context.Context, in *GetIsReadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Ai_GetIsRead_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) GetAIShareMessage(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*GetAIShareMessageReply, error) { out := new(GetAIShareMessageReply) err := c.cc.Invoke(ctx, Ai_GetAIShareMessage_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) GetShareQrcode(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*GetShareQrcodeReply, error) { out := new(GetShareQrcodeReply) err := c.cc.Invoke(ctx, Ai_GetShareQrcode_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) SetVideoLink(ctx context.Context, in *SetVideoLinkRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Ai_SetVideoLink_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) VipUpAI(ctx context.Context, in *GetAIShareMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Ai_VipUpAI_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) ShareUserInto(ctx context.Context, in *ShareUserIntoRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Ai_ShareUserInto_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) GetMiniProgramConf(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetMiniProgramConfReply, error) { out := new(GetMiniProgramConfReply) err := c.cc.Invoke(ctx, Ai_GetMiniProgramConf_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) GetAISubscribeMessage(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetAISubscribeMessageReply, error) { out := new(GetAISubscribeMessageReply) err := c.cc.Invoke(ctx, Ai_GetAISubscribeMessage_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *aiClient) CronSendAIMessage(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, Ai_CronSendAIMessage_FullMethodName, in, out, opts...) if err != nil { return nil, err } return out, nil } // AiServer is the server API for Ai service. // All implementations must embed UnimplementedAiServer // for forward compatibility type AiServer interface { // 查询AI模板 FindAITemplate(context.Context, *FindAITemplateRequest) (*FindAITemplateReply, error) // 创建AI CreateAIRobot(context.Context, *CreateAIRobotRequest) (*AIRobotIDReply, error) // 销毁AI DeleteAIRobot(context.Context, *AIRobotIDRequest) (*emptypb.Empty, error) // 更新AI UpdateAIRobot(context.Context, *UpdateAIRobotRequest) (*AIRobotIDReply, error) // 查询AI机器人列表 FindAIRobotList(context.Context, *FindAIRobotListRequest) (*AIRobotList, error) // 查询AI机器人 GetAIRobot(context.Context, *AIRobotIDRequest) (*AIRobotInfo, error) // 查询AI聊天记录 FindAIChatRecordList(context.Context, *FindAIChatRecordListRequest) (*AIRecordListReply, error) // 发送消息给ai SendAIChat(context.Context, *SendAIChatRequest) (*emptypb.Empty, error) // 查询额外服务列表 FindAdditionalServiceTemplateList(context.Context, *emptypb.Empty) (*FindAdditionalServiceTemplateListReply, error) // 获取额外服务 GetAdditionalService(context.Context, *GetAdditionalServiceRequest) (*GetAdditionalServiceReply, error) // 更新并创建额外服务 UpdateAdditionalService(context.Context, *UpdateAdditionalServiceRequest) (*emptypb.Empty, error) // 查询用户的ai信息 FindUserAIMessage(context.Context, *emptypb.Empty) (*FindUserAIMessageReply, error) // 定时执行服务 CronAdditionalService(context.Context, *emptypb.Empty) (*emptypb.Empty, error) // 用户已读 GetIsRead(context.Context, *GetIsReadRequest) (*emptypb.Empty, error) // 获取AI升级信息 GetAIShareMessage(context.Context, *GetAIShareMessageRequest) (*GetAIShareMessageReply, error) // 获取二维码 GetShareQrcode(context.Context, *GetAIShareMessageRequest) (*GetShareQrcodeReply, error) // 保存视频链接 SetVideoLink(context.Context, *SetVideoLinkRequest) (*emptypb.Empty, error) // vip直接升级 VipUpAI(context.Context, *GetAIShareMessageRequest) (*emptypb.Empty, error) // 用户受到邀请 ShareUserInto(context.Context, *ShareUserIntoRequest) (*emptypb.Empty, error) // vip直接升级 GetMiniProgramConf(context.Context, *emptypb.Empty) (*GetMiniProgramConfReply, error) // 获取ai订阅消息模板 GetAISubscribeMessage(context.Context, *emptypb.Empty) (*GetAISubscribeMessageReply, error) CronSendAIMessage(context.Context, *emptypb.Empty) (*emptypb.Empty, error) mustEmbedUnimplementedAiServer() } // UnimplementedAiServer must be embedded to have forward compatible implementations. type UnimplementedAiServer struct { } func (UnimplementedAiServer) FindAITemplate(context.Context, *FindAITemplateRequest) (*FindAITemplateReply, error) { return nil, status.Errorf(codes.Unimplemented, "method FindAITemplate not implemented") } func (UnimplementedAiServer) CreateAIRobot(context.Context, *CreateAIRobotRequest) (*AIRobotIDReply, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateAIRobot not implemented") } func (UnimplementedAiServer) DeleteAIRobot(context.Context, *AIRobotIDRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteAIRobot not implemented") } func (UnimplementedAiServer) UpdateAIRobot(context.Context, *UpdateAIRobotRequest) (*AIRobotIDReply, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateAIRobot not implemented") } func (UnimplementedAiServer) FindAIRobotList(context.Context, *FindAIRobotListRequest) (*AIRobotList, error) { return nil, status.Errorf(codes.Unimplemented, "method FindAIRobotList not implemented") } func (UnimplementedAiServer) GetAIRobot(context.Context, *AIRobotIDRequest) (*AIRobotInfo, error) { return nil, status.Errorf(codes.Unimplemented, "method GetAIRobot not implemented") } func (UnimplementedAiServer) FindAIChatRecordList(context.Context, *FindAIChatRecordListRequest) (*AIRecordListReply, error) { return nil, status.Errorf(codes.Unimplemented, "method FindAIChatRecordList not implemented") } func (UnimplementedAiServer) SendAIChat(context.Context, *SendAIChatRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method SendAIChat not implemented") } func (UnimplementedAiServer) FindAdditionalServiceTemplateList(context.Context, *emptypb.Empty) (*FindAdditionalServiceTemplateListReply, error) { return nil, status.Errorf(codes.Unimplemented, "method FindAdditionalServiceTemplateList not implemented") } func (UnimplementedAiServer) GetAdditionalService(context.Context, *GetAdditionalServiceRequest) (*GetAdditionalServiceReply, error) { return nil, status.Errorf(codes.Unimplemented, "method GetAdditionalService not implemented") } func (UnimplementedAiServer) UpdateAdditionalService(context.Context, *UpdateAdditionalServiceRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateAdditionalService not implemented") } func (UnimplementedAiServer) FindUserAIMessage(context.Context, *emptypb.Empty) (*FindUserAIMessageReply, error) { return nil, status.Errorf(codes.Unimplemented, "method FindUserAIMessage not implemented") } func (UnimplementedAiServer) CronAdditionalService(context.Context, *emptypb.Empty) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CronAdditionalService not implemented") } func (UnimplementedAiServer) GetIsRead(context.Context, *GetIsReadRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method GetIsRead not implemented") } func (UnimplementedAiServer) GetAIShareMessage(context.Context, *GetAIShareMessageRequest) (*GetAIShareMessageReply, error) { return nil, status.Errorf(codes.Unimplemented, "method GetAIShareMessage not implemented") } func (UnimplementedAiServer) GetShareQrcode(context.Context, *GetAIShareMessageRequest) (*GetShareQrcodeReply, error) { return nil, status.Errorf(codes.Unimplemented, "method GetShareQrcode not implemented") } func (UnimplementedAiServer) SetVideoLink(context.Context, *SetVideoLinkRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method SetVideoLink not implemented") } func (UnimplementedAiServer) VipUpAI(context.Context, *GetAIShareMessageRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method VipUpAI not implemented") } func (UnimplementedAiServer) ShareUserInto(context.Context, *ShareUserIntoRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method ShareUserInto not implemented") } func (UnimplementedAiServer) GetMiniProgramConf(context.Context, *emptypb.Empty) (*GetMiniProgramConfReply, error) { return nil, status.Errorf(codes.Unimplemented, "method GetMiniProgramConf not implemented") } func (UnimplementedAiServer) GetAISubscribeMessage(context.Context, *emptypb.Empty) (*GetAISubscribeMessageReply, error) { return nil, status.Errorf(codes.Unimplemented, "method GetAISubscribeMessage not implemented") } func (UnimplementedAiServer) CronSendAIMessage(context.Context, *emptypb.Empty) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CronSendAIMessage not implemented") } func (UnimplementedAiServer) mustEmbedUnimplementedAiServer() {} // UnsafeAiServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to AiServer will // result in compilation errors. type UnsafeAiServer interface { mustEmbedUnimplementedAiServer() } func RegisterAiServer(s grpc.ServiceRegistrar, srv AiServer) { s.RegisterService(&Ai_ServiceDesc, srv) } func _Ai_FindAITemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(FindAITemplateRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).FindAITemplate(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_FindAITemplate_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).FindAITemplate(ctx, req.(*FindAITemplateRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_CreateAIRobot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CreateAIRobotRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).CreateAIRobot(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_CreateAIRobot_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).CreateAIRobot(ctx, req.(*CreateAIRobotRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_DeleteAIRobot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(AIRobotIDRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).DeleteAIRobot(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_DeleteAIRobot_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).DeleteAIRobot(ctx, req.(*AIRobotIDRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_UpdateAIRobot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateAIRobotRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).UpdateAIRobot(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_UpdateAIRobot_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).UpdateAIRobot(ctx, req.(*UpdateAIRobotRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_FindAIRobotList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(FindAIRobotListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).FindAIRobotList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_FindAIRobotList_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).FindAIRobotList(ctx, req.(*FindAIRobotListRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_GetAIRobot_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(AIRobotIDRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).GetAIRobot(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_GetAIRobot_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).GetAIRobot(ctx, req.(*AIRobotIDRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_FindAIChatRecordList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(FindAIChatRecordListRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).FindAIChatRecordList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_FindAIChatRecordList_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).FindAIChatRecordList(ctx, req.(*FindAIChatRecordListRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_SendAIChat_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SendAIChatRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).SendAIChat(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_SendAIChat_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).SendAIChat(ctx, req.(*SendAIChatRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_FindAdditionalServiceTemplateList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).FindAdditionalServiceTemplateList(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_FindAdditionalServiceTemplateList_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).FindAdditionalServiceTemplateList(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } func _Ai_GetAdditionalService_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetAdditionalServiceRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).GetAdditionalService(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_GetAdditionalService_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).GetAdditionalService(ctx, req.(*GetAdditionalServiceRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_UpdateAdditionalService_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateAdditionalServiceRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).UpdateAdditionalService(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_UpdateAdditionalService_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).UpdateAdditionalService(ctx, req.(*UpdateAdditionalServiceRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_FindUserAIMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).FindUserAIMessage(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_FindUserAIMessage_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).FindUserAIMessage(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } func _Ai_CronAdditionalService_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).CronAdditionalService(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_CronAdditionalService_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).CronAdditionalService(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } func _Ai_GetIsRead_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetIsReadRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).GetIsRead(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_GetIsRead_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).GetIsRead(ctx, req.(*GetIsReadRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_GetAIShareMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetAIShareMessageRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).GetAIShareMessage(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_GetAIShareMessage_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).GetAIShareMessage(ctx, req.(*GetAIShareMessageRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_GetShareQrcode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetAIShareMessageRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).GetShareQrcode(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_GetShareQrcode_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).GetShareQrcode(ctx, req.(*GetAIShareMessageRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_SetVideoLink_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SetVideoLinkRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).SetVideoLink(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_SetVideoLink_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).SetVideoLink(ctx, req.(*SetVideoLinkRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_VipUpAI_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetAIShareMessageRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).VipUpAI(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_VipUpAI_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).VipUpAI(ctx, req.(*GetAIShareMessageRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_ShareUserInto_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ShareUserIntoRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).ShareUserInto(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_ShareUserInto_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).ShareUserInto(ctx, req.(*ShareUserIntoRequest)) } return interceptor(ctx, in, info, handler) } func _Ai_GetMiniProgramConf_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).GetMiniProgramConf(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_GetMiniProgramConf_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).GetMiniProgramConf(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } func _Ai_GetAISubscribeMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).GetAISubscribeMessage(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_GetAISubscribeMessage_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).GetAISubscribeMessage(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } func _Ai_CronSendAIMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(emptypb.Empty) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(AiServer).CronSendAIMessage(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: Ai_CronSendAIMessage_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AiServer).CronSendAIMessage(ctx, req.(*emptypb.Empty)) } return interceptor(ctx, in, info, handler) } // Ai_ServiceDesc is the grpc.ServiceDesc for Ai service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var Ai_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.ai.Ai", HandlerType: (*AiServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "FindAITemplate", Handler: _Ai_FindAITemplate_Handler, }, { MethodName: "CreateAIRobot", Handler: _Ai_CreateAIRobot_Handler, }, { MethodName: "DeleteAIRobot", Handler: _Ai_DeleteAIRobot_Handler, }, { MethodName: "UpdateAIRobot", Handler: _Ai_UpdateAIRobot_Handler, }, { MethodName: "FindAIRobotList", Handler: _Ai_FindAIRobotList_Handler, }, { MethodName: "GetAIRobot", Handler: _Ai_GetAIRobot_Handler, }, { MethodName: "FindAIChatRecordList", Handler: _Ai_FindAIChatRecordList_Handler, }, { MethodName: "SendAIChat", Handler: _Ai_SendAIChat_Handler, }, { MethodName: "FindAdditionalServiceTemplateList", Handler: _Ai_FindAdditionalServiceTemplateList_Handler, }, { MethodName: "GetAdditionalService", Handler: _Ai_GetAdditionalService_Handler, }, { MethodName: "UpdateAdditionalService", Handler: _Ai_UpdateAdditionalService_Handler, }, { MethodName: "FindUserAIMessage", Handler: _Ai_FindUserAIMessage_Handler, }, { MethodName: "CronAdditionalService", Handler: _Ai_CronAdditionalService_Handler, }, { MethodName: "GetIsRead", Handler: _Ai_GetIsRead_Handler, }, { MethodName: "GetAIShareMessage", Handler: _Ai_GetAIShareMessage_Handler, }, { MethodName: "GetShareQrcode", Handler: _Ai_GetShareQrcode_Handler, }, { MethodName: "SetVideoLink", Handler: _Ai_SetVideoLink_Handler, }, { MethodName: "VipUpAI", Handler: _Ai_VipUpAI_Handler, }, { MethodName: "ShareUserInto", Handler: _Ai_ShareUserInto_Handler, }, { MethodName: "GetMiniProgramConf", Handler: _Ai_GetMiniProgramConf_Handler, }, { MethodName: "GetAISubscribeMessage", Handler: _Ai_GetAISubscribeMessage_Handler, }, { MethodName: "CronSendAIMessage", Handler: _Ai_CronSendAIMessage_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ai.proto", }