From 9c240c3004f340319d7da0e1621cf798ed277972 Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Wed, 21 Jun 2023 11:24:58 +0800 Subject: [PATCH] rpc client --- internal/rpc/group/group.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/internal/rpc/group/group.go b/internal/rpc/group/group.go index c319a0a09..13d8c9e83 100644 --- a/internal/rpc/group/group.go +++ b/internal/rpc/group/group.go @@ -48,7 +48,7 @@ func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) e if err != nil { return err } - user := rpcclient.NewUserClient(client) + user := rpcclient.NewUserRpcClient(client) database := controller.InitGroupDatabase(db, rdb, mongo.GetDatabase()) pbGroup.RegisterGroupServer(server, &groupServer{ GroupDatabase: database, @@ -60,18 +60,18 @@ func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) e } return utils.Slice(users, func(e *sdkws.UserInfo) notification.CommonUser { return e }), nil }), - conversationRpcClient: rpcclient.NewConversationClient(client), - msgRpcClient: rpcclient.NewMsgClient(client), + conversationRpcClient: rpcclient.NewConversationRpcClient(client), + msgRpcClient: rpcclient.NewMessageRpcClient(client), }) return nil } type groupServer struct { GroupDatabase controller.GroupDatabase - User *rpcclient.UserClient + User rpcclient.UserRpcClient Notification *notification.GroupNotificationSender - conversationRpcClient *rpcclient.ConversationClient - msgRpcClient *rpcclient.MsgClient + conversationRpcClient rpcclient.ConversationRpcClient + msgRpcClient rpcclient.MessageRpcClient } func (s *groupServer) CheckGroupAdmin(ctx context.Context, groupID string) error {