messagecenter_grpc.pb.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563
  1. // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
  2. // versions:
  3. // - protoc-gen-go-grpc v1.2.0
  4. // - protoc v3.19.4
  5. // source: messagecenter.proto
  6. package messagecenter
  7. import (
  8. context "context"
  9. grpc "google.golang.org/grpc"
  10. codes "google.golang.org/grpc/codes"
  11. status "google.golang.org/grpc/status"
  12. )
  13. // This is a compile-time assertion to ensure that this generated file
  14. // is compatible with the grpc package it is being compiled against.
  15. // Requires gRPC-Go v1.32.0 or later.
  16. const _ = grpc.SupportPackageIsVersion7
  17. // MessageCenterClient is the client API for MessageCenter service.
  18. //
  19. // 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.
  20. type MessageCenterClient interface {
  21. // 查询数量
  22. Count(ctx context.Context, in *CountReq, opts ...grpc.CallOption) (*CountResp, error)
  23. // 用户列表查询
  24. UserList(ctx context.Context, in *UserReq, opts ...grpc.CallOption) (*UserResp, error)
  25. // 聊天内容查询
  26. FindMessage(ctx context.Context, in *MessageReq, opts ...grpc.CallOption) (*MessageResp, error)
  27. // 聊天保存
  28. SaveMessage(ctx context.Context, in *MessageEntity, opts ...grpc.CallOption) (*SaveMessageResp, error)
  29. // 会话创建
  30. CreateChatSession(ctx context.Context, in *ChatSessionReq, opts ...grpc.CallOption) (*ChatSessionResp, error)
  31. // 会话关闭
  32. CloseChatSession(ctx context.Context, in *CloseSessionReq, opts ...grpc.CallOption) (*ChatSessionResp, error)
  33. // 创建会话并且保存信息
  34. SaveAutoReplyMsg(ctx context.Context, in *SaveAutoReplyReq, opts ...grpc.CallOption) (*MessageResp, error)
  35. // 根据消息修改已读状态
  36. UpdateReadById(ctx context.Context, in *ReadStateReq, opts ...grpc.CallOption) (*CurrencyResp, error)
  37. // 用户撤回消息
  38. WithdrawMessage(ctx context.Context, in *ReadWithdrawReq, opts ...grpc.CallOption) (*CurrencyResp, error)
  39. // 用户评价回复
  40. AppraiseMessage(ctx context.Context, in *AppraiseReq, opts ...grpc.CallOption) (*CurrencyResp, error)
  41. // 客服列表查询
  42. ConversationList(ctx context.Context, in *ConversationReq, opts ...grpc.CallOption) (*UserResp, error)
  43. // 群聊
  44. GroupChat(ctx context.Context, in *MessageSaveReq, opts ...grpc.CallOption) (*CommonReq, error)
  45. // 1v1会话职位
  46. OneUserPosition(ctx context.Context, in *OneUserPositionReq, opts ...grpc.CallOption) (*OneUserPositionResp, error)
  47. }
  48. type messageCenterClient struct {
  49. cc grpc.ClientConnInterface
  50. }
  51. func NewMessageCenterClient(cc grpc.ClientConnInterface) MessageCenterClient {
  52. return &messageCenterClient{cc}
  53. }
  54. func (c *messageCenterClient) Count(ctx context.Context, in *CountReq, opts ...grpc.CallOption) (*CountResp, error) {
  55. out := new(CountResp)
  56. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/Count", in, out, opts...)
  57. if err != nil {
  58. return nil, err
  59. }
  60. return out, nil
  61. }
  62. func (c *messageCenterClient) UserList(ctx context.Context, in *UserReq, opts ...grpc.CallOption) (*UserResp, error) {
  63. out := new(UserResp)
  64. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/UserList", in, out, opts...)
  65. if err != nil {
  66. return nil, err
  67. }
  68. return out, nil
  69. }
  70. func (c *messageCenterClient) FindMessage(ctx context.Context, in *MessageReq, opts ...grpc.CallOption) (*MessageResp, error) {
  71. out := new(MessageResp)
  72. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/FindMessage", in, out, opts...)
  73. if err != nil {
  74. return nil, err
  75. }
  76. return out, nil
  77. }
  78. func (c *messageCenterClient) SaveMessage(ctx context.Context, in *MessageEntity, opts ...grpc.CallOption) (*SaveMessageResp, error) {
  79. out := new(SaveMessageResp)
  80. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/SaveMessage", in, out, opts...)
  81. if err != nil {
  82. return nil, err
  83. }
  84. return out, nil
  85. }
  86. func (c *messageCenterClient) CreateChatSession(ctx context.Context, in *ChatSessionReq, opts ...grpc.CallOption) (*ChatSessionResp, error) {
  87. out := new(ChatSessionResp)
  88. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/CreateChatSession", in, out, opts...)
  89. if err != nil {
  90. return nil, err
  91. }
  92. return out, nil
  93. }
  94. func (c *messageCenterClient) CloseChatSession(ctx context.Context, in *CloseSessionReq, opts ...grpc.CallOption) (*ChatSessionResp, error) {
  95. out := new(ChatSessionResp)
  96. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/CloseChatSession", in, out, opts...)
  97. if err != nil {
  98. return nil, err
  99. }
  100. return out, nil
  101. }
  102. func (c *messageCenterClient) SaveAutoReplyMsg(ctx context.Context, in *SaveAutoReplyReq, opts ...grpc.CallOption) (*MessageResp, error) {
  103. out := new(MessageResp)
  104. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/SaveAutoReplyMsg", in, out, opts...)
  105. if err != nil {
  106. return nil, err
  107. }
  108. return out, nil
  109. }
  110. func (c *messageCenterClient) UpdateReadById(ctx context.Context, in *ReadStateReq, opts ...grpc.CallOption) (*CurrencyResp, error) {
  111. out := new(CurrencyResp)
  112. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/UpdateReadById", in, out, opts...)
  113. if err != nil {
  114. return nil, err
  115. }
  116. return out, nil
  117. }
  118. func (c *messageCenterClient) WithdrawMessage(ctx context.Context, in *ReadWithdrawReq, opts ...grpc.CallOption) (*CurrencyResp, error) {
  119. out := new(CurrencyResp)
  120. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/WithdrawMessage", in, out, opts...)
  121. if err != nil {
  122. return nil, err
  123. }
  124. return out, nil
  125. }
  126. func (c *messageCenterClient) AppraiseMessage(ctx context.Context, in *AppraiseReq, opts ...grpc.CallOption) (*CurrencyResp, error) {
  127. out := new(CurrencyResp)
  128. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/AppraiseMessage", in, out, opts...)
  129. if err != nil {
  130. return nil, err
  131. }
  132. return out, nil
  133. }
  134. func (c *messageCenterClient) ConversationList(ctx context.Context, in *ConversationReq, opts ...grpc.CallOption) (*UserResp, error) {
  135. out := new(UserResp)
  136. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/ConversationList", in, out, opts...)
  137. if err != nil {
  138. return nil, err
  139. }
  140. return out, nil
  141. }
  142. func (c *messageCenterClient) GroupChat(ctx context.Context, in *MessageSaveReq, opts ...grpc.CallOption) (*CommonReq, error) {
  143. out := new(CommonReq)
  144. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/GroupChat", in, out, opts...)
  145. if err != nil {
  146. return nil, err
  147. }
  148. return out, nil
  149. }
  150. func (c *messageCenterClient) OneUserPosition(ctx context.Context, in *OneUserPositionReq, opts ...grpc.CallOption) (*OneUserPositionResp, error) {
  151. out := new(OneUserPositionResp)
  152. err := c.cc.Invoke(ctx, "/messagecenter.messageCenter/OneUserPosition", in, out, opts...)
  153. if err != nil {
  154. return nil, err
  155. }
  156. return out, nil
  157. }
  158. // MessageCenterServer is the server API for MessageCenter service.
  159. // All implementations must embed UnimplementedMessageCenterServer
  160. // for forward compatibility
  161. type MessageCenterServer interface {
  162. // 查询数量
  163. Count(context.Context, *CountReq) (*CountResp, error)
  164. // 用户列表查询
  165. UserList(context.Context, *UserReq) (*UserResp, error)
  166. // 聊天内容查询
  167. FindMessage(context.Context, *MessageReq) (*MessageResp, error)
  168. // 聊天保存
  169. SaveMessage(context.Context, *MessageEntity) (*SaveMessageResp, error)
  170. // 会话创建
  171. CreateChatSession(context.Context, *ChatSessionReq) (*ChatSessionResp, error)
  172. // 会话关闭
  173. CloseChatSession(context.Context, *CloseSessionReq) (*ChatSessionResp, error)
  174. // 创建会话并且保存信息
  175. SaveAutoReplyMsg(context.Context, *SaveAutoReplyReq) (*MessageResp, error)
  176. // 根据消息修改已读状态
  177. UpdateReadById(context.Context, *ReadStateReq) (*CurrencyResp, error)
  178. // 用户撤回消息
  179. WithdrawMessage(context.Context, *ReadWithdrawReq) (*CurrencyResp, error)
  180. // 用户评价回复
  181. AppraiseMessage(context.Context, *AppraiseReq) (*CurrencyResp, error)
  182. // 客服列表查询
  183. ConversationList(context.Context, *ConversationReq) (*UserResp, error)
  184. // 群聊
  185. GroupChat(context.Context, *MessageSaveReq) (*CommonReq, error)
  186. // 1v1会话职位
  187. OneUserPosition(context.Context, *OneUserPositionReq) (*OneUserPositionResp, error)
  188. mustEmbedUnimplementedMessageCenterServer()
  189. }
  190. // UnimplementedMessageCenterServer must be embedded to have forward compatible implementations.
  191. type UnimplementedMessageCenterServer struct {
  192. }
  193. func (UnimplementedMessageCenterServer) Count(context.Context, *CountReq) (*CountResp, error) {
  194. return nil, status.Errorf(codes.Unimplemented, "method Count not implemented")
  195. }
  196. func (UnimplementedMessageCenterServer) UserList(context.Context, *UserReq) (*UserResp, error) {
  197. return nil, status.Errorf(codes.Unimplemented, "method UserList not implemented")
  198. }
  199. func (UnimplementedMessageCenterServer) FindMessage(context.Context, *MessageReq) (*MessageResp, error) {
  200. return nil, status.Errorf(codes.Unimplemented, "method FindMessage not implemented")
  201. }
  202. func (UnimplementedMessageCenterServer) SaveMessage(context.Context, *MessageEntity) (*SaveMessageResp, error) {
  203. return nil, status.Errorf(codes.Unimplemented, "method SaveMessage not implemented")
  204. }
  205. func (UnimplementedMessageCenterServer) CreateChatSession(context.Context, *ChatSessionReq) (*ChatSessionResp, error) {
  206. return nil, status.Errorf(codes.Unimplemented, "method CreateChatSession not implemented")
  207. }
  208. func (UnimplementedMessageCenterServer) CloseChatSession(context.Context, *CloseSessionReq) (*ChatSessionResp, error) {
  209. return nil, status.Errorf(codes.Unimplemented, "method CloseChatSession not implemented")
  210. }
  211. func (UnimplementedMessageCenterServer) SaveAutoReplyMsg(context.Context, *SaveAutoReplyReq) (*MessageResp, error) {
  212. return nil, status.Errorf(codes.Unimplemented, "method SaveAutoReplyMsg not implemented")
  213. }
  214. func (UnimplementedMessageCenterServer) UpdateReadById(context.Context, *ReadStateReq) (*CurrencyResp, error) {
  215. return nil, status.Errorf(codes.Unimplemented, "method UpdateReadById not implemented")
  216. }
  217. func (UnimplementedMessageCenterServer) WithdrawMessage(context.Context, *ReadWithdrawReq) (*CurrencyResp, error) {
  218. return nil, status.Errorf(codes.Unimplemented, "method WithdrawMessage not implemented")
  219. }
  220. func (UnimplementedMessageCenterServer) AppraiseMessage(context.Context, *AppraiseReq) (*CurrencyResp, error) {
  221. return nil, status.Errorf(codes.Unimplemented, "method AppraiseMessage not implemented")
  222. }
  223. func (UnimplementedMessageCenterServer) ConversationList(context.Context, *ConversationReq) (*UserResp, error) {
  224. return nil, status.Errorf(codes.Unimplemented, "method ConversationList not implemented")
  225. }
  226. func (UnimplementedMessageCenterServer) GroupChat(context.Context, *MessageSaveReq) (*CommonReq, error) {
  227. return nil, status.Errorf(codes.Unimplemented, "method GroupChat not implemented")
  228. }
  229. func (UnimplementedMessageCenterServer) OneUserPosition(context.Context, *OneUserPositionReq) (*OneUserPositionResp, error) {
  230. return nil, status.Errorf(codes.Unimplemented, "method OneUserPosition not implemented")
  231. }
  232. func (UnimplementedMessageCenterServer) mustEmbedUnimplementedMessageCenterServer() {}
  233. // UnsafeMessageCenterServer may be embedded to opt out of forward compatibility for this service.
  234. // Use of this interface is not recommended, as added methods to MessageCenterServer will
  235. // result in compilation errors.
  236. type UnsafeMessageCenterServer interface {
  237. mustEmbedUnimplementedMessageCenterServer()
  238. }
  239. func RegisterMessageCenterServer(s grpc.ServiceRegistrar, srv MessageCenterServer) {
  240. s.RegisterService(&MessageCenter_ServiceDesc, srv)
  241. }
  242. func _MessageCenter_Count_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  243. in := new(CountReq)
  244. if err := dec(in); err != nil {
  245. return nil, err
  246. }
  247. if interceptor == nil {
  248. return srv.(MessageCenterServer).Count(ctx, in)
  249. }
  250. info := &grpc.UnaryServerInfo{
  251. Server: srv,
  252. FullMethod: "/messagecenter.messageCenter/Count",
  253. }
  254. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  255. return srv.(MessageCenterServer).Count(ctx, req.(*CountReq))
  256. }
  257. return interceptor(ctx, in, info, handler)
  258. }
  259. func _MessageCenter_UserList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  260. in := new(UserReq)
  261. if err := dec(in); err != nil {
  262. return nil, err
  263. }
  264. if interceptor == nil {
  265. return srv.(MessageCenterServer).UserList(ctx, in)
  266. }
  267. info := &grpc.UnaryServerInfo{
  268. Server: srv,
  269. FullMethod: "/messagecenter.messageCenter/UserList",
  270. }
  271. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  272. return srv.(MessageCenterServer).UserList(ctx, req.(*UserReq))
  273. }
  274. return interceptor(ctx, in, info, handler)
  275. }
  276. func _MessageCenter_FindMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  277. in := new(MessageReq)
  278. if err := dec(in); err != nil {
  279. return nil, err
  280. }
  281. if interceptor == nil {
  282. return srv.(MessageCenterServer).FindMessage(ctx, in)
  283. }
  284. info := &grpc.UnaryServerInfo{
  285. Server: srv,
  286. FullMethod: "/messagecenter.messageCenter/FindMessage",
  287. }
  288. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  289. return srv.(MessageCenterServer).FindMessage(ctx, req.(*MessageReq))
  290. }
  291. return interceptor(ctx, in, info, handler)
  292. }
  293. func _MessageCenter_SaveMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  294. in := new(MessageEntity)
  295. if err := dec(in); err != nil {
  296. return nil, err
  297. }
  298. if interceptor == nil {
  299. return srv.(MessageCenterServer).SaveMessage(ctx, in)
  300. }
  301. info := &grpc.UnaryServerInfo{
  302. Server: srv,
  303. FullMethod: "/messagecenter.messageCenter/SaveMessage",
  304. }
  305. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  306. return srv.(MessageCenterServer).SaveMessage(ctx, req.(*MessageEntity))
  307. }
  308. return interceptor(ctx, in, info, handler)
  309. }
  310. func _MessageCenter_CreateChatSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  311. in := new(ChatSessionReq)
  312. if err := dec(in); err != nil {
  313. return nil, err
  314. }
  315. if interceptor == nil {
  316. return srv.(MessageCenterServer).CreateChatSession(ctx, in)
  317. }
  318. info := &grpc.UnaryServerInfo{
  319. Server: srv,
  320. FullMethod: "/messagecenter.messageCenter/CreateChatSession",
  321. }
  322. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  323. return srv.(MessageCenterServer).CreateChatSession(ctx, req.(*ChatSessionReq))
  324. }
  325. return interceptor(ctx, in, info, handler)
  326. }
  327. func _MessageCenter_CloseChatSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  328. in := new(CloseSessionReq)
  329. if err := dec(in); err != nil {
  330. return nil, err
  331. }
  332. if interceptor == nil {
  333. return srv.(MessageCenterServer).CloseChatSession(ctx, in)
  334. }
  335. info := &grpc.UnaryServerInfo{
  336. Server: srv,
  337. FullMethod: "/messagecenter.messageCenter/CloseChatSession",
  338. }
  339. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  340. return srv.(MessageCenterServer).CloseChatSession(ctx, req.(*CloseSessionReq))
  341. }
  342. return interceptor(ctx, in, info, handler)
  343. }
  344. func _MessageCenter_SaveAutoReplyMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  345. in := new(SaveAutoReplyReq)
  346. if err := dec(in); err != nil {
  347. return nil, err
  348. }
  349. if interceptor == nil {
  350. return srv.(MessageCenterServer).SaveAutoReplyMsg(ctx, in)
  351. }
  352. info := &grpc.UnaryServerInfo{
  353. Server: srv,
  354. FullMethod: "/messagecenter.messageCenter/SaveAutoReplyMsg",
  355. }
  356. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  357. return srv.(MessageCenterServer).SaveAutoReplyMsg(ctx, req.(*SaveAutoReplyReq))
  358. }
  359. return interceptor(ctx, in, info, handler)
  360. }
  361. func _MessageCenter_UpdateReadById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  362. in := new(ReadStateReq)
  363. if err := dec(in); err != nil {
  364. return nil, err
  365. }
  366. if interceptor == nil {
  367. return srv.(MessageCenterServer).UpdateReadById(ctx, in)
  368. }
  369. info := &grpc.UnaryServerInfo{
  370. Server: srv,
  371. FullMethod: "/messagecenter.messageCenter/UpdateReadById",
  372. }
  373. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  374. return srv.(MessageCenterServer).UpdateReadById(ctx, req.(*ReadStateReq))
  375. }
  376. return interceptor(ctx, in, info, handler)
  377. }
  378. func _MessageCenter_WithdrawMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  379. in := new(ReadWithdrawReq)
  380. if err := dec(in); err != nil {
  381. return nil, err
  382. }
  383. if interceptor == nil {
  384. return srv.(MessageCenterServer).WithdrawMessage(ctx, in)
  385. }
  386. info := &grpc.UnaryServerInfo{
  387. Server: srv,
  388. FullMethod: "/messagecenter.messageCenter/WithdrawMessage",
  389. }
  390. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  391. return srv.(MessageCenterServer).WithdrawMessage(ctx, req.(*ReadWithdrawReq))
  392. }
  393. return interceptor(ctx, in, info, handler)
  394. }
  395. func _MessageCenter_AppraiseMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  396. in := new(AppraiseReq)
  397. if err := dec(in); err != nil {
  398. return nil, err
  399. }
  400. if interceptor == nil {
  401. return srv.(MessageCenterServer).AppraiseMessage(ctx, in)
  402. }
  403. info := &grpc.UnaryServerInfo{
  404. Server: srv,
  405. FullMethod: "/messagecenter.messageCenter/AppraiseMessage",
  406. }
  407. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  408. return srv.(MessageCenterServer).AppraiseMessage(ctx, req.(*AppraiseReq))
  409. }
  410. return interceptor(ctx, in, info, handler)
  411. }
  412. func _MessageCenter_ConversationList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  413. in := new(ConversationReq)
  414. if err := dec(in); err != nil {
  415. return nil, err
  416. }
  417. if interceptor == nil {
  418. return srv.(MessageCenterServer).ConversationList(ctx, in)
  419. }
  420. info := &grpc.UnaryServerInfo{
  421. Server: srv,
  422. FullMethod: "/messagecenter.messageCenter/ConversationList",
  423. }
  424. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  425. return srv.(MessageCenterServer).ConversationList(ctx, req.(*ConversationReq))
  426. }
  427. return interceptor(ctx, in, info, handler)
  428. }
  429. func _MessageCenter_GroupChat_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  430. in := new(MessageSaveReq)
  431. if err := dec(in); err != nil {
  432. return nil, err
  433. }
  434. if interceptor == nil {
  435. return srv.(MessageCenterServer).GroupChat(ctx, in)
  436. }
  437. info := &grpc.UnaryServerInfo{
  438. Server: srv,
  439. FullMethod: "/messagecenter.messageCenter/GroupChat",
  440. }
  441. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  442. return srv.(MessageCenterServer).GroupChat(ctx, req.(*MessageSaveReq))
  443. }
  444. return interceptor(ctx, in, info, handler)
  445. }
  446. func _MessageCenter_OneUserPosition_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  447. in := new(OneUserPositionReq)
  448. if err := dec(in); err != nil {
  449. return nil, err
  450. }
  451. if interceptor == nil {
  452. return srv.(MessageCenterServer).OneUserPosition(ctx, in)
  453. }
  454. info := &grpc.UnaryServerInfo{
  455. Server: srv,
  456. FullMethod: "/messagecenter.messageCenter/OneUserPosition",
  457. }
  458. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  459. return srv.(MessageCenterServer).OneUserPosition(ctx, req.(*OneUserPositionReq))
  460. }
  461. return interceptor(ctx, in, info, handler)
  462. }
  463. // MessageCenter_ServiceDesc is the grpc.ServiceDesc for MessageCenter service.
  464. // It's only intended for direct use with grpc.RegisterService,
  465. // and not to be introspected or modified (even as a copy)
  466. var MessageCenter_ServiceDesc = grpc.ServiceDesc{
  467. ServiceName: "messagecenter.messageCenter",
  468. HandlerType: (*MessageCenterServer)(nil),
  469. Methods: []grpc.MethodDesc{
  470. {
  471. MethodName: "Count",
  472. Handler: _MessageCenter_Count_Handler,
  473. },
  474. {
  475. MethodName: "UserList",
  476. Handler: _MessageCenter_UserList_Handler,
  477. },
  478. {
  479. MethodName: "FindMessage",
  480. Handler: _MessageCenter_FindMessage_Handler,
  481. },
  482. {
  483. MethodName: "SaveMessage",
  484. Handler: _MessageCenter_SaveMessage_Handler,
  485. },
  486. {
  487. MethodName: "CreateChatSession",
  488. Handler: _MessageCenter_CreateChatSession_Handler,
  489. },
  490. {
  491. MethodName: "CloseChatSession",
  492. Handler: _MessageCenter_CloseChatSession_Handler,
  493. },
  494. {
  495. MethodName: "SaveAutoReplyMsg",
  496. Handler: _MessageCenter_SaveAutoReplyMsg_Handler,
  497. },
  498. {
  499. MethodName: "UpdateReadById",
  500. Handler: _MessageCenter_UpdateReadById_Handler,
  501. },
  502. {
  503. MethodName: "WithdrawMessage",
  504. Handler: _MessageCenter_WithdrawMessage_Handler,
  505. },
  506. {
  507. MethodName: "AppraiseMessage",
  508. Handler: _MessageCenter_AppraiseMessage_Handler,
  509. },
  510. {
  511. MethodName: "ConversationList",
  512. Handler: _MessageCenter_ConversationList_Handler,
  513. },
  514. {
  515. MethodName: "GroupChat",
  516. Handler: _MessageCenter_GroupChat_Handler,
  517. },
  518. {
  519. MethodName: "OneUserPosition",
  520. Handler: _MessageCenter_OneUserPosition_Handler,
  521. },
  522. },
  523. Streams: []grpc.StreamDesc{},
  524. Metadata: "messagecenter.proto",
  525. }