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

RevokeMsgTips

Browse Source
This commit is contained in:
withchao 2023-05-31 19:19:04 +08:00
parent 1d4b5960d2
commit 90d77652ab
1 changed files with 26 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
pkg/common/db/unrelation/msg.go
View File

@ -2,8 +2,11 @@ package unrelation
import (
"context"
"encoding/json"
"errors"
"fmt"
"github.com/OpenIMSDK/Open-IM-Server/pkg/common/constant"
"strings"
table "github.com/OpenIMSDK/Open-IM-Server/pkg/common/db/table/unrelation"
"github.com/OpenIMSDK/Open-IM-Server/pkg/errs"
@ -236,6 +239,29 @@ func (m *MsgMongoDriver) GetMsgBySeqIndexIn1Doc(ctx context.Context, userID stri
if len(msgDocModel) == 0 {
return nil, errs.Wrap(mongo.ErrNoDocuments)
}
for i, model := range msgDocModel[0].Msg {
if model.Msg != nil && model.Revoke != nil {
var conversationID string
if index := strings.LastIndex(docID, ":"); index > 0 {
conversationID = docID[:index]
}
tips := sdkws.RevokeMsgTips{
RevokerUserID: model.Revoke.UserID,
ClientMsgID: model.Msg.ClientMsgID,
RevokeTime: model.Revoke.Time,
SesstionType: model.Msg.SessionType,
Seq: model.Msg.Seq,
ConversationID: conversationID,
}
tipsData, _ := json.Marshal(&tips)
elem := sdkws.NotificationElem{
Detail: string(tipsData),
}
content, _ := json.Marshal(&elem)
msgDocModel[0].Msg[i].Msg.ContentType = constant.Revoke
msgDocModel[0].Msg[i].Msg.Content = string(content)
}
}
return msgDocModel[0].Msg, nil
}