From df2a1d9f02e222ff6bc1810c81ae42f11fec8dbf Mon Sep 17 00:00:00 2001 From: Gordon <46924906+FGadvancer@users.noreply.github.com> Date: Mon, 15 Apr 2024 11:29:36 +0800 Subject: [PATCH] refactor: cmd update. --- internal/rpc/msg/server.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/rpc/msg/server.go b/internal/rpc/msg/server.go index 7f52dfa7e..1ccc493ac 100644 --- a/internal/rpc/msg/server.go +++ b/internal/rpc/msg/server.go @@ -39,7 +39,7 @@ type ( // MsgServer encapsulates dependencies required for message handling. msgServer struct { RegisterCenter discovery.SvcDiscoveryRegistry // Service discovery registry for service registration. - MsgDatabase controller.MsgDatabase // Interface for message database operations. + MsgDatabase controller.CommonMsgDatabase // Interface for message database operations. Conversation *rpcclient.ConversationRpcClient // RPC client for conversation service. UserLocalCache *rpccache.UserLocalCache // Local cache for user data. FriendLocalCache *rpccache.FriendLocalCache // Local cache for friend data. @@ -88,7 +88,7 @@ func Start(ctx context.Context, config *Config, client discovery.SvcDiscoveryReg userRpcClient := rpcclient.NewUserRpcClient(client, config.Share.RpcRegisterName.User, config.Share.IMAdminUserID) groupRpcClient := rpcclient.NewGroupRpcClient(client, config.Share.RpcRegisterName.Group) friendRpcClient := rpcclient.NewFriendRpcClient(client, config.Share.RpcRegisterName.Friend) - msgDatabase, err := controller.NewMsgDatabase(msgDocModel, msgModel, seqModel, &config.KafkaConfig) + msgDatabase, err := controller.NewCommonMsgDatabase(msgDocModel, msgModel, seqModel, &config.KafkaConfig) if err != nil { return err }