IM/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2026-05-13 13:35:59 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/errcode' into errcode

Browse Source
This commit is contained in:
withchao
2023-05-31 11:50:12 +08:00
parent 765a33db1f 7a5c2f0038
commit dd283c1007
19 changed files with 1310 additions and 1159 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/rpc/conversation/conversaion.go
+5 -1
View File
@@ -272,7 +272,11 @@ func (c *conversationServer) CreateSingleChatConversations(ctx context.Context,
}
func (c *conversationServer) CreateGroupChatConversations(ctx context.Context, req *pbConversation.CreateGroupChatConversationsReq) (*pbConversation.CreateGroupChatConversationsResp, error) {
err := c.conversationDatabase.CreateGroupChatConversation(ctx, req.GroupID, req.UserIDs)
maxSeq, err := c.msgRpcClient.GetConversationMaxSeq(ctx, utils.GenGroupConversationID(req.GroupID))
if err != nil {
return nil, err
}
err = c.conversationDatabase.CreateGroupChatConversation(ctx, req.GroupID, req.UserIDs, maxSeq)
if err != nil {
return nil, err
}
internal/rpc/msg/seq.go
+13
View File
@@ -0,0 +1,13 @@
package msg
import (
"context"
pbMsg "github.com/OpenIMSDK/Open-IM-Server/pkg/proto/msg"
)
func (m *msgServer) GetConversationMaxSeq(ctx context.Context, req *pbMsg.GetConversationMaxSeqReq) (resp *pbMsg.GetConversationMaxSeqResp, err error) {
resp = &pbMsg.GetConversationMaxSeqResp{}
resp.MaxSeq, err = m.MsgDatabase.GetMaxSeq(ctx, req.ConversationID)
return resp, err
}