fix: changing naming irregularities under pkg and internal packages, #520

internal/msgtransfer/init.go

@@ -71,8 +71,8 @@ func StartTransfer(prometheusPort int) error {
 	msgMysModel := relation.NewChatLogGorm(db)
 	chatLogDatabase := controller.NewChatLogDatabase(msgMysModel)
 	msgDatabase := controller.NewCommonMsgDatabase(msgDocModel, msgModel, msgMysModel)
-	conversationRpcClient := rpcclient.NewConversationRpcClient(client)
+	conversationRpcClient := rpcclient.NewConversationRPCClient(client)
-	groupRpcClient := rpcclient.NewGroupRpcClient(client)
+	groupRpcClient := rpcclient.NewGroupRPCClient(client)
 	msgTransfer := NewMsgTransfer(chatLogDatabase, msgDatabase, &conversationRpcClient, &groupRpcClient)
 	msgTransfer.initPrometheus()
 	return msgTransfer.Start(prometheusPort)
@@ -80,7 +80,7 @@ func StartTransfer(prometheusPort int) error {
 
 func NewMsgTransfer(chatLogDatabase controller.ChatLogDatabase,
 	msgDatabase controller.CommonMsgDatabase,
-	conversationRpcClient *rpcclient.ConversationRpcClient, groupRpcClient *rpcclient.GroupRpcClient) *MsgTransfer {
+	conversationRpcClient *rpcclient.ConversationRPCClient, groupRpcClient *rpcclient.GroupRPCClient) *MsgTransfer {
 	return &MsgTransfer{
 		persistentCH:   NewPersistentConsumerHandler(chatLogDatabase),
 		historyCH:      NewOnlineHistoryRedisConsumerHandler(msgDatabase, conversationRpcClient, groupRpcClient),

internal/rpc/msg/server.go

@@ -3,6 +3,7 @@ package msg
 import (
 	"context"
 	"github.com/OpenIMSDK/Open-IM-Server/pkg/common/db/relation"
+	"github.com/OpenIMSDK/Open-IM-Server/pkg/proto/sdkws"
 
 	"google.golang.org/grpc"
 
@@ -33,6 +34,21 @@ type msgServer struct {
 	notificationSender     *rpcclient.NotificationSender
 }
 
+func (m *msgServer) GetMaxSeq(ctx context.Context, req *sdkws.GetMaxSeqReq) (*sdkws.GetMaxSeqResp, error) {
+	// TODO implement me
+	panic("implement me")
+}
+
+func (m *msgServer) PullMessageBySeqs(ctx context.Context, req *sdkws.PullMessageBySeqsReq) (*sdkws.PullMessageBySeqsResp, error) {
+	// TODO implement me
+	panic("implement me")
+}
+
+func (m *msgServer) SearchMessage(ctx context.Context, req *msg.SearchMessageReq) (*msg.SearchMessageResp, error) {
+	// TODO implement me
+	panic("implement me")
+}
+
 func (m *msgServer) addInterceptorHandler(interceptorFunc ...MessageInterceptorFunc) {
 	m.Handlers = append(m.Handlers, interceptorFunc...)
 }

pkg/rpcclient/msg.go

@@ -3,6 +3,7 @@ package rpcclient
 import (
 	"context"
 	"encoding/json"
+	"github.com/OpenIMSDK/Open-IM-Server/pkg/proto/user"
 	"google.golang.org/grpc"
 	"google.golang.org/protobuf/proto"