refactor: fix error handling in SendMessage function (#704)

Author: mo3et

internal/conversation_msg/api.go

@@ -504,6 +504,7 @@ func (c *Conversation) SendMessage(ctx context.Context, s *sdk_struct.MsgStruct,
 			if err != nil {
 				c.updateMsgStatusAndTriggerConversation(ctx, s.ClientMsgID, "", s.CreateTime, constant.MsgStatusSendFailed, s, lc, isOnlineOnly)
 				putErrs = err
+				return
 			}
 			if res != nil {
 				s.VideoElem.VideoURL = res.URL

pkg/constant/constant.go

@@ -65,6 +65,8 @@ const (
 	CustomMsgNotTriggerConversation = 119
 	CustomMsgOnlineOnly             = 120
 
+	NotificationBegin = 1000
+
 	FriendNotificationBegin = 1200
 
 	FriendApplicationApprovedNotification = 1201 //add_friend_response
@@ -124,6 +126,7 @@ const (
 
 	HasReadReceipt = 2200
 
+	NotificationEnd = 5000
 	////////////////////////////////////////
 
 	//MsgFrom

pkg/db/conversation_model.go

@@ -95,8 +95,7 @@ func (d *DataBase) GetConversationListSplitDB(ctx context.Context, offset, count
 	d.mRWMutex.RLock()
 	defer d.mRWMutex.RUnlock()
 	var conversationList []*model_struct.LocalConversation
-	return conversationList, errs.WrapMsg(d.conn.WithContext(ctx).Where("latest_msg_send_time > ?", 0).Order("case when is_pinned=1 then 0 else 1 end,max(latest_msg_send_time,draft_text_time) DESC").Offset(offset).Limit(count).Find(&conversationList).Error,
-		"GetFriendList failed")
+	return conversationList, errs.Wrap(d.conn.WithContext(ctx).Where("latest_msg_send_time > ?", 0).Order("case when is_pinned=1 then 0 else 1 end,max(latest_msg_send_time,draft_text_time) DESC").Offset(offset).Limit(count).Find(&conversationList).Error)
 }
 
 func (d *DataBase) BatchInsertConversationList(ctx context.Context, conversationList []*model_struct.LocalConversation) error {