Continuously load more messages until there are 20 or no more

lib/controllers/room_chat_controller.dart

@@ -123,9 +123,9 @@ class RoomChatController extends AsyncNotifier<InMemoryChatController> {
 
     ref.onDispose(controller.dispose);
 
-    // While there are under 20 messages, try up to two times to load more messages.
+    // While there are under 20 messages, try up to load more messages until theres no more or we have 20 messages.
-    for (var i = 0; i < 2 && messages.length < 20; i++) {
+    for (var more = true; more == true && controller.messages.length < 20;) {
-      await loadOlder(controller);
+      more = await loadOlder(controller);
     }
 
     return controller;
@@ -151,7 +151,7 @@ class RoomChatController extends AsyncNotifier<InMemoryChatController> {
         RedactEventRequest(eventId: message.id, roomId: roomId, reason: reason),
       );
 
-  Future<void> loadOlder([InMemoryChatController? chatController]) async {
+  Future<bool> loadOlder([InMemoryChatController? chatController]) async {
     final response = await ref
         .watch(ClientController.provider.notifier)
         .paginate(
@@ -183,28 +183,30 @@ class RoomChatController extends AsyncNotifier<InMemoryChatController> {
             ),
           }),
           const ISet.empty(),
+          addToNewEvents: false,
         );
 
     final room = ref.read(RoomsController.provider)[roomId];
-    if (room == null) return;
+    if (room != null) {
+      final messages = await ref.watch(
+        MessagesController.provider(
+          MessagesConfig(room: room, events: response.events.reversed),
+        ).future,
+      );
 
-    final messages = await ref.watch(
+      final controller = chatController ?? await future;
-      MessagesController.provider(
+      await controller.insertAllMessages(
-        MessagesConfig(room: room, events: response.events.reversed),
+        messages
-      ).future,
+            .where(
-    );
+              (newMessage) => !controller.messages.any(
-
+                (message) => message.id == newMessage.id,
-    final controller = chatController ?? await future;
+              ),
-    await controller.insertAllMessages(
+            )
-      messages
+            .toList(),
-          .where(
+        index: 0,
-            (newMessage) => !controller.messages.any(
+      );
-              (message) => message.id == newMessage.id,
+    }
-            ),
+    return response.hasMore;
-          )
-          .toList(),
-      index: 0,
-    );
   }
 
   Future<void> send(

lib/controllers/rooms_controller.dart

@@ -11,7 +11,11 @@ class RoomsController extends Notifier<IMap<String, Room>> {
   @override
   IMap<String, Room> build() => const IMap.empty();
 
-  void update(IMap<String, Room> rooms, ISet<String> leftRooms) {
+  void update(
+    IMap<String, Room> rooms,
+    ISet<String> leftRooms, {
+    bool addToNewEvents = true,
+  }) {
     final homeserver =
         ref.watch(
           ClientStateController.provider.select(
@@ -29,18 +33,20 @@ class RoomsController extends Notifier<IMap<String, Room>> {
         (item) => item.eventId,
       );
 
-      ref
+      if (addToNewEvents) {
-          .watch(NewEventsController.provider(roomId).notifier)
+        ref
-          .add(
+            .watch(NewEventsController.provider(roomId).notifier)
-            incoming.timeline
+            .add(
-                .map(
+              incoming.timeline
-                  (timelineTuple) => events?.firstWhereOrNull(
+                  .map(
-                    (event) => timelineTuple.eventRowId == event.rowId,
+                    (timelineTuple) => events?.firstWhereOrNull(
-                  ),
+                      (event) => timelineTuple.eventRowId == event.rowId,
-                )
+                    ),
-                .nonNulls
+                  )
-                .toIList(),
+                  .nonNulls
-          );
+                  .toIList(),
+            );
+      }
 
       return acc.add(
         roomId,