blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-06 04:15:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: webhookAfterSingleMsgRead (#2884)

Browse Source
This commit is contained in:
icey-yu 2024-11-25 14:11:34 +08:00 committed by OpenIM-Robot
parent 3e220a3519
commit d8afbb82fc
1 changed files with 16 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
internal/rpc/msg/as_read.go
View File

@ -181,14 +181,23 @@ func (m *msgServer) MarkConversationAsRead(ctx context.Context, req *msg.MarkCon
req.UserID, seqs, hasReadSeq) req.UserID, seqs, hasReadSeq)
} }
reqCall := &cbapi.CallbackGroupMsgReadReq{ if conversation.ConversationType == constant.SingleChatType {
SendID: conversation.OwnerUserID, reqCall := &cbapi.CallbackSingleMsgReadReq{
ReceiveID: req.UserID, ConversationID: conversation.ConversationID,
UnreadMsgNum: req.HasReadSeq, UserID: conversation.OwnerUserID,
ContentType: int64(conversation.ConversationType), Seqs: req.Seqs,
ContentType: conversation.ConversationType,
}
m.webhookAfterSingleMsgRead(ctx, &m.config.WebhooksConfig.AfterSingleMsgRead, reqCall)
} else if conversation.ConversationType == constant.ReadGroupChatType {
reqCall := &cbapi.CallbackGroupMsgReadReq{
SendID: conversation.OwnerUserID,
ReceiveID: req.UserID,
UnreadMsgNum: req.HasReadSeq,
ContentType: int64(conversation.ConversationType),
}
m.webhookAfterGroupMsgRead(ctx, &m.config.WebhooksConfig.AfterGroupMsgRead, reqCall)
} }
m.webhookAfterGroupMsgRead(ctx, &m.config.WebhooksConfig.AfterGroupMsgRead, reqCall)
return &msg.MarkConversationAsReadResp{}, nil return &msg.MarkConversationAsReadResp{}, nil
} }