Use timelines, encryption now works, except not fetching keys from old devices

lib/controllers/events_controller.dart

@@ -1,30 +1,18 @@
 import "package:flutter_riverpod/flutter_riverpod.dart";
 import "package:matrix/matrix.dart";
-import "package:nexus/controllers/from_controller.dart";
 
-class EventsController extends AsyncNotifier<GetRoomEventsResponse> {
+class EventsController extends AsyncNotifier<Timeline> {
   EventsController(this.room);
   final Room room;
 
   @override
-  Future<GetRoomEventsResponse> build({String? from}) async {
-    final response = await room.client.getRoomEvents(
-      room.id,
-      Direction.b,
-      from: from,
-      limit: 32,
-    );
-    if (ref.mounted) {
-      ref.watch(FromController.provider(room).notifier).set(response.end);
-    }
-    return response;
+  Future<Timeline> build({String? from}) => room.getTimeline();
+
+  Future<void> prev() async {
+    final timeline = await future;
+    await timeline.requestHistory();
   }
 
-  Future<GetRoomEventsResponse> prev() async =>
-      build(from: ref.read(FromController.provider(room)));
-
   static final provider = AsyncNotifierProvider.autoDispose
-      .family<EventsController, GetRoomEventsResponse, Room>(
-        EventsController.new,
-      );
+      .family<EventsController, Timeline, Room>(EventsController.new);
 }

lib/controllers/from_controller.dart

@@ -1,15 +0,0 @@
-import "package:flutter_riverpod/flutter_riverpod.dart";
-import "package:matrix/matrix.dart";
-
-class FromController extends Notifier<String?> {
-  FromController(_);
-  @override
-  String? build() => null;
-
-  void set(String? value) => state = value;
-
-  static final provider =
-      NotifierProvider.family<FromController, String?, Room>(
-        FromController.new,
-      );
-}

lib/controllers/room_chat_controller.dart

@@ -60,7 +60,7 @@ class RoomChatController extends AsyncNotifier<ChatController> {
     );
 
     return InMemoryChatController(
-      messages: await response.chunk.toMessages(room),
+      messages: await response.events.toMessages(room),
     );
   }
 
@@ -85,14 +85,22 @@ class RoomChatController extends AsyncNotifier<ChatController> {
   }
 
   Future<void> loadOlder() async {
+    final currentEvents = await future;
+    await ref.watch(EventsController.provider(room).notifier).prev();
+    final newEvents = await ref.watch(EventsController.provider(room).future);
+
     final controller = await future;
-    final response = await ref
-        .watch(EventsController.provider(room).notifier)
-        .prev();
-
-    final messages = await response.chunk.toMessages(room);
-
-    await controller.insertAllMessages(messages, index: 0);
+    await controller.insertAllMessages(
+      await newEvents.events
+          .where(
+            (event) => !currentEvents.messages.any(
+              (existingEvent) => existingEvent.id == event.eventId,
+            ),
+          )
+          .toList()
+          .toMessages(room),
+      index: 0,
+    );
     ref.notifyListeners();
   }
 

lib/main.dart

@@ -34,6 +34,7 @@ New Value: ${newValue is AsyncData ? newValue.value : newValue}
 void showError(Object error, [StackTrace? stackTrace]) {
   if (error.toString().contains("DioException")) return;
   if (error.toString().contains("UTF-16")) return;
+  if (error.toString().contains("HTTP request failed")) return;
   if (error.toString().contains("Invalid image data")) return;
 
   debugPrintStack(stackTrace: stackTrace, label: error.toString());