### Fixed

* Fixed #29 update messages list after delete message

### Dependencies

* Upgraded `supabase_flutter` to `^2.9.1`
* Upgraded `meta` to `^1.16.0`

Author: rickypid

example/lib/src/pages/room.dart

@@ -223,6 +223,29 @@ class _RoomPageState extends State<RoomPage> {
                 enabled: true,
                 onTextChanged: (text) => _chatController.onTyping(),
               ),
+              onMessageLongPress: (context, p1) async {
+                final confirm = await showDialog<bool>(
+                  context: context,
+                  builder: (context) => AlertDialog(
+                    title: Text('Confirmation of deletion'),
+                    content: Text('Do you really want to delete this message?'),
+                    actions: [
+                      TextButton(
+                        onPressed: () => Navigator.of(context).pop(false),
+                        child: Text('Cancel'),
+                      ),
+                      TextButton(
+                        onPressed: () => Navigator.of(context).pop(true),
+                        child: Text('Delete'),
+                      ),
+                    ],
+                  ),
+                );
+                if (confirm == true) {
+                  await _chatController.deleteMessage(widget.room.id, p1.id);
+                }
+              },
+
             ),
           ),
         ),

lib/src/class/supabase_chat_controller.dart

@@ -77,14 +77,7 @@ class SupabaseChatController {
 
   void _onData(
     List<Map<String, dynamic>> newData,
-    List<Map<String, dynamic>> oldData,
   ) {
-    final deletedMessagesId = oldData
-        .map(
-          (e) => e['id'].toString(),
-        )
-        .toList();
-    _messages.removeWhere((element) => deletedMessagesId.contains(element.id));
     for (var val in newData) {
       final author = _room.users.firstWhere(
         (u) => u.id == val['authorId'],
@@ -112,7 +105,7 @@ class SupabaseChatController {
   /// then it will be necessary to call the [loadPreviousMessages] method to get
   /// the next page of messages
   Stream<List<types.Message>> get messages {
-    _messagesQuery().then((value) => _onData(value, []));
+    _messagesQuery().then((value) => _onData(value));
     _client
         .channel('${_config.schema}:${_config.messagesTableName}:${_room.id}')
         .onPostgresChanges(
@@ -124,8 +117,7 @@ class SupabaseChatController {
             column: 'roomId',
             value: _room.id,
           ),
-          callback: (payload) =>
-              _onData([payload.newRecord], [payload.oldRecord]),
+          callback: (payload) => _onData([payload.newRecord]),
         )
         .subscribe();
     return _messagesController.stream;
@@ -135,7 +127,7 @@ class SupabaseChatController {
   /// page
   Future<void> loadPreviousMessages() async {
     _currentPage += 1;
-    await _messagesQuery().then((value) => _onData(value, []));
+    await _messagesQuery().then((value) => _onData(value));
   }
 
   /// Returns a stream of typing users from Supabase for a specified room.
@@ -168,6 +160,17 @@ class SupabaseChatController {
         'typing': typing,
       };
 
+  /// Removes message.
+  Future<bool> deleteMessage(String roomId, String messageId) async {
+    final result =
+        await SupabaseChatCore.instance.deleteMessage(roomId, messageId);
+    if (result) {
+      _messages.removeWhere((e) => messageId == e.id);
+      _messagesController.sink.add(_messages);
+    }
+    return result;
+  }
+
   void dispose() {
     _typingChannel.untrack();
   }

lib/src/class/supabase_chat_core.dart

@@ -282,13 +282,15 @@ class SupabaseChatCore {
   }
 
   /// Removes message.
-  Future<void> deleteMessage(String roomId, String messageId) async {
-    await client
+  Future<bool> deleteMessage(String roomId, String messageId) async {
+    final result = await client
         .schema(config.schema)
         .from(config.messagesTableName)
         .delete()
         .eq('roomId', roomId)
-        .eq('id', messageId);
+        .eq('id', messageId)
+        .select();
+    return result.isNotEmpty;
   }
 
   /// Removes room.