Merge pull request #1724 from matthiasn/feat/fetch_on_startup

feat: fetch messages on startup

integration_test/matrix_service_test.dart

@@ -314,12 +314,6 @@ void main() {
         final bobEntriesCount = await bobDb.getJournalCount();
         expect(bobEntriesCount, n);
         debugPrint('Bob persisted $bobEntriesCount entries');
-
-        debugPrint('\n--- Logging out Alice and Bob');
-
-        await alice.logout();
-        await waitSeconds(defaultDelay * delayFactor);
-        await bob.logout();
       },
       timeout: const Timeout(Duration(minutes: 15)),
     );

lib/sync/matrix/matrix_service.dart

@@ -195,6 +195,7 @@ class MatrixService {
 
   Future<void> logout() async {
     if (_client.isLogged()) {
+      timeline?.cancelSubscriptions();
       await _client.logout();
     }
   }

lib/sync/matrix/timeline.dart

@@ -1,3 +1,5 @@
+import 'dart:async';
+
 import 'package:flutter/foundation.dart';
 import 'package:lotti/database/database.dart';
 import 'package:lotti/database/logging_db.dart';
@@ -25,12 +27,17 @@ Future<void> listenToTimelineEvents({
     service.timeline = await service.syncRoom?.getTimeline(
       onNewEvent: () {
         final clientRunner = service.clientRunner;
-        if (clientRunner.queueSize < 2) {
+        if (clientRunner.queueSize < 5) {
           service.clientRunner.enqueueRequest(null);
         }
       },
     );
 
+    unawaited(
+      Future<void>.delayed(const Duration(seconds: 1))
+          .then((value) => service.clientRunner.enqueueRequest(null)),
+    );
+
     final timeline = service.timeline;
 
     if (timeline == null) {
@@ -61,6 +68,7 @@ Future<void> processNewTimelineEvents({
 
   try {
     final lastReadEventContextId = service.lastReadEventContextId;
+
     await service.client.sync();
     final hasMessage = await service.syncRoom
             ?.getEventById(lastReadEventContextId.toString()) !=
@@ -109,21 +117,26 @@ Future<void> processNewTimelineEvents({
           service.lastReadEventContextId = eventId;
           await setLastReadMatrixEventId(eventId);
         }
-
-        await timeline.setReadMarker(eventId: eventId);
-      } catch (e) {
-        debugPrint('$e');
+        final loginState = service.client.onLoginStateChanged.value;
+        if (loginState == LoginState.loggedIn) {
+          await timeline.setReadMarker(eventId: eventId);
+        }
+      } catch (e, stackTrace) {
+        loggingDb.captureException(
+          e,
+          domain: 'MATRIX_SERVICE',
+          subDomain: 'setReadMarker ${service.client.deviceName}',
+          stackTrace: stackTrace,
+        );
       }
     }
   } catch (e, stackTrace) {
-    debugPrint('$e');
     loggingDb.captureException(
       e,
       domain: 'MATRIX_SERVICE',
       subDomain: 'listenToTimelineEvents ${service.client.deviceName}',
       stackTrace: stackTrace,
     );
-    rethrow;
   }
 }
 

pubspec.yaml

@@ -1,7 +1,7 @@
 name: lotti
 description: Achieve your goals and keep your data private with Lotti.
 publish_to: 'none'
-version: 0.9.449+2465
+version: 0.9.450+2467
 
 msix_config:
   display_name: LottiApp