From a2f3d11110d5a6a53f170e021863e9780cf75ac7 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 19 May 2023 10:44:19 +0800 Subject: [PATCH 1/2] init --- internal/rpc/conversation/conversaion.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/rpc/conversation/conversaion.go b/internal/rpc/conversation/conversaion.go index 23326475d..c15e3feaa 100644 --- a/internal/rpc/conversation/conversaion.go +++ b/internal/rpc/conversation/conversaion.go @@ -43,6 +43,7 @@ func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) e pbConversation.RegisterConversationServer(server, &conversationServer{ conversationNotificationSender: notification.NewConversationNotificationSender(client), groupRpcClient: rpcclient.NewGroupClient(client), + msgRpcClient: *rpcclient.NewMsgClient(client), conversationDatabase: controller.NewConversationDatabase(conversationDB, cache.NewConversationRedis(rdb, cache.GetDefaultOpt(), conversationDB), tx.NewGorm(db)), }) return nil From 01f773c0f8bd55ae4cd7125079df0ce14106580f Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 19 May 2023 10:44:37 +0800 Subject: [PATCH 2/2] init --- internal/rpc/conversation/conversaion.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/rpc/conversation/conversaion.go b/internal/rpc/conversation/conversaion.go index c15e3feaa..4649409b7 100644 --- a/internal/rpc/conversation/conversaion.go +++ b/internal/rpc/conversation/conversaion.go @@ -24,7 +24,7 @@ type conversationServer struct { groupRpcClient *rpcclient.GroupClient conversationDatabase controller.ConversationDatabase conversationNotificationSender *notification.ConversationNotificationSender - msgRpcClient rpcclient.MsgClient + msgRpcClient *rpcclient.MsgClient } func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) error { @@ -43,7 +43,7 @@ func Start(client discoveryregistry.SvcDiscoveryRegistry, server *grpc.Server) e pbConversation.RegisterConversationServer(server, &conversationServer{ conversationNotificationSender: notification.NewConversationNotificationSender(client), groupRpcClient: rpcclient.NewGroupClient(client), - msgRpcClient: *rpcclient.NewMsgClient(client), + msgRpcClient: rpcclient.NewMsgClient(client), conversationDatabase: controller.NewConversationDatabase(conversationDB, cache.NewConversationRedis(rdb, cache.GetDefaultOpt(), conversationDB), tx.NewGorm(db)), }) return nil