use sql match

lib/src/database/daos/messages.dao.dart

@@ -212,32 +212,41 @@ class MessagesDao extends DatabaseAccessor<TwonlyDB> with _$MessagesDaoMixin {
     );
   }
 
-  Future<void> handleMessageOpened(
+  Future<void> handleMessagesOpened(
     int contactId,
-    String messageId,
+    List<String> messageIds,
     DateTime timestamp,
   ) async {
-    await into(messageActions).insertOnConflictUpdate(
+    await batch((batch) async {
+      for (final messageId in messageIds) {
+        batch.insert(
+          messageActions,
           MessageActionsCompanion(
             messageId: Value(messageId),
             contactId: Value(contactId),
             type: const Value(MessageActionType.openedAt),
             actionAt: Value(timestamp),
           ),
+          mode: InsertMode.insertOrReplace,
         );
-    // Directly show as message opened as soon as one person has opened it
+      }
-    final openedByAll =
+
-        await haveAllMembers(messageId, MessageActionType.openedAt)
+      for (final messageId in messageIds) {
-            ? clock.now()
+        final isOpenedByAll =
-            : null;
+            await haveAllMembers(messageId, MessageActionType.openedAt);
-    await twonlyDB.messagesDao.updateMessageId(
+        final now = clock.now();
-      messageId,
+
+        batch.update(
+          twonlyDB.messages,
           MessagesCompanion(
-        openedAt: Value(clock.now()),
+            openedAt: Value(now),
-        openedByAll: Value(openedByAll),
+            openedByAll: Value(isOpenedByAll ? now : null),
           ),
+          where: (tbl) => tbl.messageId.equals(messageId),
         );
       }
+    });
+  }
 
   Future<void> handleMessageAckByServer(
     int contactId,

lib/src/services/api/client2client/messages.c2c.dart

@@ -9,20 +9,18 @@ Future<void> handleMessageUpdate(
 ) async {
   switch (messageUpdate.type) {
     case EncryptedContent_MessageUpdate_Type.OPENED:
-      for (final targetMessageId in messageUpdate.multipleTargetMessageIds) {
       Log.info(
-          'Opened message $targetMessageId',
+        'Opened message ${messageUpdate.multipleTargetMessageIds}',
       );
       try {
-          await twonlyDB.messagesDao.handleMessageOpened(
+        await twonlyDB.messagesDao.handleMessagesOpened(
           contactId,
-            targetMessageId,
+          messageUpdate.multipleTargetMessageIds,
           fromTimestamp(messageUpdate.timestamp),
         );
       } catch (e) {
         Log.warn(e);
       }
-      }
     case EncryptedContent_MessageUpdate_Type.DELETE:
       if (!await isSender(contactId, messageUpdate.senderMessageId)) {
         return;

lib/src/services/api/messages.dart

@@ -375,15 +375,18 @@ Future<void> notifyContactAboutOpeningMessage(
     ),
     blocking: false,
   );
+  await twonlyDB.batch((batch) {
     for (final messageId in messageOtherIds) {
-    await twonlyDB.messagesDao.updateMessageId(
+      batch.update(
-      messageId,
+        twonlyDB.messages,
         MessagesCompanion(
           openedAt: Value(actionAt),
           openedByAll: Value(actionAt),
         ),
+        where: (tbl) => tbl.messageId.equals(messageId),
       );
     }
+  });
   await updateLastMessageId(contactId, biggestMessageId);
 }
 

lib/src/views/chats/chat_messages.view.dart

@@ -128,12 +128,6 @@ class _ChatMessagesViewState extends State<ChatMessagesView> {
     final msgStream = twonlyDB.messagesDao.watchByGroupId(group.groupId);
     messageSub = msgStream.listen((update) async {
       allMessages = update;
-
-      /// In case a message is not open yet the message is updated, which will trigger this watch to be called again.
-      /// So as long as the Mutex is locked just return...
-      if (protectMessageUpdating.isLocked) {
-        // return;
-      }
       await protectMessageUpdating.protect(() async {
         await setMessages(update, groupActions);
       });