Fix chats does not sorting by local messages (#701)

lib/domain/repository/chat.dart

@@ -286,9 +286,6 @@ abstract class RxChat implements Comparable<RxChat> {
   /// [MyUser] in this [chat].
   Rx<ChatItem>? get firstUnread;
 
-  /// Returns the last [ChatItem] of this [RxChat].
-  ChatItem? get lastItem;
-
   /// Listens to the updates of this [RxChat] while the returned [Stream] is
   /// listened to.
   Stream<void> get updates;

lib/store/chat.dart

@@ -422,6 +422,7 @@ class ChatRepository extends DisposableInterface
         rxChat = await ensureRemoteDialog(chatId);
       } catch (_) {
         local?.status.value = SendingStatus.error;
+        return;
       }
     }
 
@@ -1459,6 +1460,14 @@ class ChatRepository extends DisposableInterface
     // [Chat.firstItem] is maintained locally only for [Pagination] reasons.
     chat.value.firstItem ??= saved?.chat.value.firstItem;
 
+    // [Chat.lastItem] and [Chat.updatedAt] are maintained locally if last
+    // message is local.
+    if (saved != null &&
+        saved.chat.value.updatedAt.isAfter(chat.value.updatedAt)) {
+      chat.value.updatedAt = saved.chat.value.updatedAt;
+      chat.value.lastItem = saved.chat.value.lastItem;
+    }
+
     // Check the versions first, if [ignoreVersion] is `false`.
     if (saved != null && !ignoreVersion) {
       if (saved.ver != null && saved.ver! >= chat.ver) {

lib/store/chat_rx.dart

@@ -142,6 +142,9 @@ class HiveRxChat extends RxChat {
   /// [Timer] unmuting the muted [chat] when its [MuteDuration.until] expires.
   Timer? _muteTimer;
 
+  /// [ChatItemHiveProvider.boxEvents] subscription.
+  StreamIterator<BoxEvent>? _localSubscription;
+
   /// [ChatRepository.chatEvents] subscription.
   ///
   /// May be uninitialized since connection establishment may fail.
@@ -245,19 +248,6 @@ class HiveRxChat extends RxChat {
     return null;
   }
 
-  @override
-  ChatItem? get lastItem {
-    ChatItem? item = chat.value.lastItem;
-    if (messages.isNotEmpty) {
-      final ChatItem last = messages.last.value;
-      if (item?.at.isBefore(last.at) == true) {
-        item = last;
-      }
-    }
-
-    return item;
-  }
-
   @override
   Stream<void> get updates => _controller.stream;
 
@@ -380,6 +370,8 @@ class HiveRxChat extends RxChat {
 
     await _local.init(userId: me);
 
+    _initLocalSubscription();
+
     HiveChatItem? item;
     if (chat.value.lastReadItem != null) {
       item = await get(chat.value.lastReadItem!);
@@ -402,6 +394,7 @@ class HiveRxChat extends RxChat {
     _aroundToken.cancel();
     _muteTimer?.cancel();
     _readTimer?.cancel();
+    _localSubscription?.cancel();
     _remoteSubscription?.close(immediate: true);
     _remoteSubscription = null;
     _paginationSubscription?.cancel();
@@ -1063,6 +1056,46 @@ class HiveRxChat extends RxChat {
     }
   }
 
+  /// Initializes [ChatItemHiveProvider.boxEvents] subscription.
+  Future<void> _initLocalSubscription() async {
+    _localSubscription = StreamIterator(_local.boxEvents);
+    while (await _localSubscription!.moveNext()) {
+      final BoxEvent event = _localSubscription!.current;
+      final ChatItemKey key = ChatItemKey.fromString(event.key);
+
+      if (event.deleted) {
+        if (chat.value.lastItem?.key == key) {
+          final HiveChat? chatEntity = await _chatLocal.get(id);
+
+          if (chatEntity != null) {
+            if (_local.keys.isNotEmpty) {
+              final HiveChatItem? item = await _local.get(_local.keys.last);
+              if (item != null) {
+                chatEntity.value.lastItem = item.value;
+                chatEntity.value.updatedAt = item.value.at;
+              }
+            } else {
+              chatEntity.value.lastItem = null;
+            }
+
+            await _chatRepository.put(chatEntity, ignoreVersion: true);
+          }
+        }
+      } else {
+        final HiveChatItem item = event.value;
+        if (item.value.at.isAfter(chat.value.updatedAt)) {
+          final HiveChat? chatEntity = await _chatLocal.get(id);
+
+          if (chatEntity != null) {
+            chatEntity.value.updatedAt = item.value.at;
+            chatEntity.value.lastItem = item.value;
+            await _chatRepository.put(chatEntity, ignoreVersion: true);
+          }
+        }
+      }
+    }
+  }
+
   /// Initializes [ChatRepository.chatEvents] subscription.
   Future<void> _initRemoteSubscription() async {
     if (_disposed) {

lib/store/pagination/hive.dart

@@ -250,13 +250,14 @@ class HivePageProvider<T extends Object, C, K>
 
     final T? firstItem = items.firstOrNull;
     if (firstItem != null && isFirst != null) {
-      hasPrevious =
-          !isFirst!.call(firstItem) || getKey(firstItem) != ordered.first;
+      hasPrevious = items.none((e) => isFirst!.call(e)) ||
+          getKey(firstItem) != ordered.first;
     }
 
     final T? lastItem = items.lastOrNull;
     if (lastItem != null && isLast != null) {
-      hasNext = !isLast!.call(lastItem) || getKey(lastItem) != ordered.last;
+      hasNext = items.none((e) => isLast!.call(e)) ||
+          getKey(lastItem) != ordered.last;
     }
 
     final Page<T, C> page = Page(

lib/ui/page/home/page/chat/controller.dart

@@ -447,6 +447,8 @@ class ChatController extends GetxController {
 
             if (!PlatformUtils.isMobile) {
               Future.delayed(Duration.zero, send.field.focus.requestFocus);
+            } else {
+              send.field.focus.requestFocus();
             }
           }
         }

lib/ui/page/home/tab/chats/widget/recent_chat.dart

@@ -331,7 +331,7 @@ class RecentChatTile extends StatelessWidget {
       final List<Widget> subtitle;
 
       final Chat chat = rxChat.chat.value;
-      final ChatItem? item = rxChat.lastItem;
+      final ChatItem? item = rxChat.chat.value.lastItem;
       final ChatMessage? draft = rxChat.draft.value;
 
       final Iterable<String> typings = rxChat.typingUsers
@@ -825,7 +825,7 @@ class RecentChatTile extends StatelessWidget {
     return Obx(() {
       final Chat chat = rxChat.chat.value;
 
-      final ChatItem? item = rxChat.lastItem;
+      final ChatItem? item = rxChat.chat.value.lastItem;
 
       if (item != null && item.author.id == me && !chat.isMonolog) {
         final bool isSent = item.status.value == SendingStatus.sent;

lib/ui/page/style/page/widgets/common/dummy_chat.dart

@@ -54,9 +54,6 @@ class DummyRxChat extends RxChat {
   @override
   RxBool get hasPrevious => RxBool(false);
 
-  @override
-  ChatItem? get lastItem => null;
-
   @override
   UserId? get me => null;