SK-477: Message reply functionality (#78)

* add  PopupMessageMenu

* add ReplyMessageWidget

* add repliedMessageId

* add sender to MessageModel

* add scrollTo

* add Autoscroll

* add focus menu

* fix attachment in reply

* add showScrollFAB

* add draft reply

---------

Co-authored-by: Magellan <magellan@connectycube.com>

Author: 2 people

lib/objectbox-model.json

@@ -92,7 +92,7 @@
     },
     {
       "id": "11:6168919874786736956",
-      "lastPropertyId": "9:1875750503242122079",
+      "lastPropertyId": "14:1893283248997063821",
       "name": "MessageModel",
       "properties": [
         {
@@ -142,6 +142,37 @@
           "id": "9:1875750503242122079",
           "name": "dbExtension",
           "type": 9
+        },
+        {
+          "id": "10:6395861719839579723",
+          "name": "repliedMessageId",
+          "type": 9
+        },
+        {
+          "id": "11:8502424052705749036",
+          "name": "replyMessageBindId",
+          "type": 11,
+          "flags": 520,
+          "indexId": "39:2280023974172957156",
+          "relationTarget": "MessageModel"
+        },
+        {
+          "id": "12:6401592278627748216",
+          "name": "senderBindId",
+          "type": 11,
+          "flags": 520,
+          "indexId": "40:5803255922961343502",
+          "relationTarget": "UserModel"
+        },
+        {
+          "id": "13:5213655976270008005",
+          "name": "isOwn",
+          "type": 1
+        },
+        {
+          "id": "14:1893283248997063821",
+          "name": "isTempReplied",
+          "type": 1
         }
       ],
       "relations": [
@@ -330,7 +361,7 @@
     }
   ],
   "lastEntityId": "13:9106374520578572502",
-  "lastIndexId": "38:1718185030575189588",
+  "lastIndexId": "40:5803255922961343502",
   "lastRelationId": "5:7785256265115248397",
   "lastSequenceId": "0:0",
   "modelVersion": 5,

lib/objectbox.g.dart

@@ -21,6 +21,8 @@ Future<(bool, Message?)> sendMessage({
     'id': message.id,
     'cid': message.cid,
     if (message.body?.isNotEmpty ?? false) 'body': message.body,
+    if (message.repliedMessageId?.isNotEmpty ?? false)
+      'replied_message_id': message.repliedMessageId,
     if (message.extension != null) 'x': message.extension,
     if (message.attachments != null) 'attachments': message.attachments,
   };

lib/src/api/chats/messages_api.dart

@@ -6,6 +6,7 @@ class Message extends Equatable {
   final String? id; //_id
   final String? from; //from
   final String? cid; //cid
+  final String? repliedMessageId; //replied_message_id
   final String? rawStatus; //status
   final String? body; //body
   final List<Attachment>? attachments; //attachments
@@ -17,6 +18,7 @@ class Message extends Equatable {
     this.id,
     this.from,
     this.cid,
+    this.repliedMessageId,
     this.rawStatus,
     this.body,
     this.attachments,
@@ -29,6 +31,7 @@ class Message extends Equatable {
       : id = json['_id'],
         from = json['from'],
         cid = json['cid'],
+        repliedMessageId = json['replied_message_id'],
         rawStatus = json['status'],
         body = json['body'],
         attachments = json['attachments'] == null
@@ -53,6 +56,7 @@ class Message extends Equatable {
     String? id,
     String? from,
     String? cid,
+    String? repliedMessageId,
     String? rawStatus,
     String? body,
     List<Attachment>? attachments,
@@ -64,6 +68,7 @@ class Message extends Equatable {
       id: id ?? this.id,
       from: from ?? this.from,
       cid: cid ?? this.cid,
+      repliedMessageId: repliedMessageId ?? this.repliedMessageId,
       rawStatus: rawStatus ?? this.rawStatus,
       body: body ?? this.body,
       attachments: attachments ?? this.attachments,

lib/src/api/conversations/models/message.dart

@@ -275,17 +275,19 @@ class DatabaseService {
   /// ///////////////////////////
 
   Future<List<MessageModel>> getAllMessagesLocal(
-      String cid, DateTime? ltDate) async {
+      String cid, DateTime? ltDate, int? limit) async {
     final query = store!
         .box<MessageModel>()
         .query(MessageModel_.cid
             .equals(cid)
             .and(MessageModel_.createdAt.lessThanDate(ltDate ?? DateTime.now()))
+            .and(MessageModel_.isTempReplied.isNull())
             .and(MessageModel_.rawStatus
                 .notEquals(ChatMessageStatus.draft.name) //hide draft messages
                 .or(MessageModel_.rawStatus.isNull())))
         .order(MessageModel_.createdAt, flags: Order.descending)
-        .build();
+        .build()
+      ..limit = limit ?? 0;
     final results = await query.findAsync();
     query.close();
     return results;
@@ -295,20 +297,32 @@ class DatabaseService {
       [int violationId = 0]) async {
     final query = store!
         .box<MessageModel>()
-        .query(MessageModel_.id
-            .oneOf(items.map((element) => element.id!).toList()))
+        .query(
+            MessageModel_.id.oneOf(items.map((element) => element.id).toList()))
         .build();
 
     final messagesInDb = await query.findAsync();
     query.close();
 
     var messagesInDbMap = {for (var v in messagesInDb) v.id: v};
-    for (var message in items) {
+
+    Map<String, MessageModel> messagesMap = {};
+
+    for (var message in items.reversed) {
       final messageInDb = messagesInDbMap[message.id];
       if (messageInDb != null) {
         assignMessage(message, messageInDb);
       }
+      messagesMap[message.id] = message;
+
+      if (message.repliedMessageId != null && message.replyMessage == null) {
+        var replyMessage = messagesMap[message.repliedMessageId];
+        if (replyMessage != null) {
+          message.replyMessage = replyMessage;
+        }
+      }
     }
+
     try {
       await store!.box<MessageModel>().putManyAsync(items, mode: PutMode.put);
     } on UniqueViolationException catch (e) {
@@ -379,14 +393,27 @@ class DatabaseService {
       if (msgInDb != null) {
         assignMessage(item, msgInDb);
       }
+      // TODO delete after check replyMessage functionality
+      // if (item.replyMessage != null && item.replyMessage!.bid == null) {
+      //   final query = store!
+      //       .box<MessageModel>()
+      //       .query(MessageModel_.id.equals(item.replyMessage!.id))
+      //       .build();
+      //   final replyMsgInDb = await query.findFirstAsync();
+      //   query.close();
+      //   print('updateMessageLocal replyMsgInDb= $replyMsgInDb');
+      //   item.replyMessage = replyMsgInDb?.replyMessage;
+      // }
     }
+
     return await store!
         .box<MessageModel>()
         .putAndGetAsync(item, mode: PutMode.put);
   }
 
   Future<void> assignMessage(MessageModel msg, MessageModel msgInDb) async {
     msg.bid = msgInDb.bid;
+    msg.replyMessage = msgInDb.replyMessage;
     if (msg.attachments.isNotEmpty) {
       msg.attachments.clear();
     }

lib/src/db/db_service.dart

@@ -6,10 +6,10 @@ class MessageLocalDatasource {
   final DatabaseService _databaseService = DatabaseService.instance;
 
   Future<List<MessageModel>> getAllMessagesLocal(String cid,
-      {DateTime? ltDate}) async {
+      {DateTime? ltDate, int? limit}) async {
     print('getAllMessagesLocal');
     try {
-      return await _databaseService.getAllMessagesLocal(cid, ltDate);
+      return await _databaseService.getAllMessagesLocal(cid, ltDate, limit);
     } catch (e) {
       print('getAllMessagesLocal e ${e.toString()}');
       throw DatabaseException(e.toString());