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

reaction message add expiration

Browse Source
This commit is contained in:
Gordon 2022-12-12 16:52:36 +08:00
parent 84df956293
commit 2b0a997573
4 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/api/msg/extend_msg.go
View File

@ -57,7 +57,9 @@ func SetMessageReactionExtensions(c *gin.Context) {
}
resp.ErrCode = respPb.ErrCode
resp.ErrMsg = respPb.ErrMsg
resp.Data = respPb.Result
resp.Data.ResultKeyValue = respPb.Result
resp.Data.MsgFirstModifyTime = reqPb.MsgFirstModifyTime
resp.Data.IsReact = reqPb.IsReact
log.NewInfo(req.OperationID, utils.GetSelfFuncName(), resp)
c.JSON(http.StatusOK, resp)

1
internal/rpc/msg/extend_msg.go
View File

@ -50,6 +50,7 @@ func (rpc *rpcChat) SetMessageReactionExtensions(ctx context.Context, req *msg.S
}
setKeyResultInfo(&rResp, 0, "", req.ClientMsgID, k, v)
}
rResp.IsReact = true
_, err := db.DB.SetMessageReactionExpire(req.ClientMsgID, req.SessionType, time.Duration(24*3)*time.Hour)
if err != nil {
log.Error(req.OperationID, "SetMessageReactionExpire err:", err.Error(), req.String())

6
pkg/base_info/msg.go
View File

@ -68,7 +68,11 @@ type ModifyMessageReactionExtensionsReq struct {
type ModifyMessageReactionExtensionsResp struct {
CommResp
Data []*msg.KeyValueResp `json:"data"`
Data struct {
ResultKeyValue []*msg.KeyValueResp `json:"result"`
MsgFirstModifyTime int64 `json:"msgFirstModifyTime"`
IsReact bool `json:"isReact"`
} `json:"data"`
}
type OperateMessageListReactionExtensionsReq struct {

3
pkg/proto/msg/msg.proto
View File

@ -185,7 +185,8 @@ message SetMessageReactionExtensionsResp {
string errMsg = 2;
string clientMsgID = 3;
int64 msgFirstModifyTime = 4;
repeated KeyValueResp result = 5;
bool isReact = 5;
repeated KeyValueResp result = 6;
}
message ModifyMessageReactionExtensionsResp {