@@ -20,7 +20,6 @@ import (
20
20
21
21
"github.com/openimsdk/openim-sdk-core/v3/pkg/common"
22
22
"github.com/openimsdk/openim-sdk-core/v3/pkg/constant"
23
- "github.com/openimsdk/openim-sdk-core/v3/pkg/sdkerrs"
24
23
25
24
"github.com/openimsdk/openim-sdk-core/v3/pkg/utils"
26
25
"github.com/openimsdk/openim-sdk-core/v3/sdk_struct"
@@ -120,18 +119,22 @@ func (c *Conversation) deleteMessage(ctx context.Context, conversationID string,
120
119
if err != nil {
121
120
return err
122
121
}
122
+
123
123
localMessage , err := c .db .GetMessage (ctx , conversationID , clientMsgID )
124
124
if err != nil {
125
125
return err
126
126
}
127
+
127
128
if localMessage .Status == constant .MsgStatusSendFailed {
128
129
log .ZInfo (ctx , "delete msg status is send failed, do not need delete" , "msg" , localMessage )
129
130
return nil
130
131
}
132
+
131
133
if localMessage .Seq == 0 {
132
- log .ZInfo (ctx , "delete msg seq is 0, try again " , "msg" , localMessage )
133
- return sdkerrs . ErrMsgHasNoSeq
134
+ log .ZInfo (ctx , "delete msg seq is 0, only delete in local " , "msg" , localMessage )
135
+ return c . deleteMessageFromLocal ( ctx , conversationID , clientMsgID )
134
136
}
137
+
135
138
err = c .deleteMessagesFromServer (ctx , conversationID , []int64 {localMessage .Seq })
136
139
if err != nil {
137
140
return err
0 commit comments