Handles remove message events

lib/helpers/conversations_helper.dart

@@ -333,6 +333,11 @@ class ConversationsHelper {
     await _conversationMessagesDatabaseHelper.insertOrUpdate(msg);
   }
 
+  /// Remove a message from the database
+  Future<void> removeMessage(int msgID) async {
+    await _conversationMessagesDatabaseHelper.delete(msgID);
+  }
+
   /// Update a message content
   Future<bool> updateMessage(int id, String newContent) async {
     final response = await APIRequest(
@@ -355,8 +360,7 @@ class ConversationsHelper {
 
     if (response.code != 200) return false;
 
-    // Delete the message locally
-    return await _conversationMessagesDatabaseHelper.delete(id);
+    return true;
   }
 
   /// Register a conversation : ask the server to notify about updates to the

lib/helpers/events_helper.dart

@@ -60,6 +60,12 @@ class UpdatedConversationMessageEvent {
   UpdatedConversationMessageEvent(this.msg);
 }
 
+/// Deleted conversation message
+class DeletedConversationMessageEvent {
+  final ConversationMessage msg;
+
+  DeletedConversationMessageEvent(this.msg);
+}
 
 class EventsHelper {
   static EventBus _mgr = EventBus();

lib/helpers/websocket_helper.dart

@@ -150,6 +150,12 @@ class WebSocketHelper {
             ConversationsHelper.apiToConversationMessage(msg.data)));
         break;
 
+      // Deleted a conversation message
+      case "deleted_conv_message":
+        EventsHelper.emit(DeletedConversationMessageEvent(
+            ConversationsHelper.apiToConversationMessage(msg.data)));
+        break;
+
       default:
         throw Exception("Unknown message type: ${msg.title}");
     }

lib/lists/conversation_messages_list.dart

@@ -54,4 +54,7 @@ class ConversationMessagesList extends ListBase<ConversationMessage> {
     final index = this.indexWhere((t) => t.id == msg.id);
     if (index >= 0) this[index] = msg;
   }
+
+  /// Remove a message from this list
+  void removeMsg(int id) => removeWhere((f) => f.id == id);
 }

lib/ui/screens/conversation_screen.dart

@@ -98,6 +98,13 @@ class _ConversationScreenState extends SafeState<ConversationScreen> {
         setState(() => _messages.replace(ev.msg));
       }
     });
+
+    this.listen<DeletedConversationMessageEvent>((ev) async {
+      if (ev.msg.conversationID == widget.conversationID) {
+        await _conversationsHelper.removeMessage(ev.msg.id);
+        setState(() => _messages.removeMsg(ev.msg.id));
+      }
+    });
   }
 
   /// Free resources when this conversation widget is no longer required
@@ -450,10 +457,5 @@ class _ConversationScreenState extends SafeState<ConversationScreen> {
     // Execute the request
     if (!await _conversationsHelper.deleteMessage(message.id))
       showSimpleSnack(context, tr("Could not delete conversation message!"));
-
-    // Remove the message from the list
-    setState(() {
-      _messages.remove(message);
-    });
   }
 }