From 3a80a3a48c151834ed614895b32050f0ff5de987 Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Wed, 4 Dec 2024 16:10:35 +0800 Subject: [PATCH] feat: seq user hook set conversation --- internal/rpc/conversation/conversation.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/internal/rpc/conversation/conversation.go b/internal/rpc/conversation/conversation.go index f232322db..6a8a6d800 100644 --- a/internal/rpc/conversation/conversation.go +++ b/internal/rpc/conversation/conversation.go @@ -16,6 +16,7 @@ package conversation import ( "context" + "github.com/openimsdk/open-im-server/v3/pkg/msgprocessor" pbmsg "github.com/openimsdk/protocol/msg" "sort" "time" @@ -434,6 +435,10 @@ func (c *conversationServer) CreateGroupChatConversations(ctx context.Context, r if err != nil { return nil, err } + conversationID := msgprocessor.GetConversationIDBySessionType(constant.ReadGroupChatType, req.GroupID) + if _, err := c.msgRpcClient.Client.SetUserConversationMaxSeq(ctx, &pbmsg.SetUserConversationMaxSeqReq{ConversationID: conversationID, OwnerUserID: req.UserIDs, MaxSeq: 0}); err != nil { + return nil, err + } return &pbconversation.CreateGroupChatConversationsResp{}, nil }