🚀 Launch 1.2.1+39

lib/controllers/chat_events_controller.dart

@@ -1,3 +1,5 @@
+import 'dart:math' as math;
+
 import 'package:get/get.dart';
 import 'package:solian/models/channel.dart';
 import 'package:solian/models/event.dart';
@@ -30,14 +32,31 @@ class ChatEventController {
     this.channel = channel;
     this.scope = scope;
 
-    isLoading.value = true;
-    await syncLocal(channel, take: 10);
+    const firstTake = 20;
+    const furtherTake = 100;
 
-    src.pullRemoteEvents(channel, scope: scope, take: 10).then((result) {
-      totalEvents.value = result?.$2 ?? 0;
-      syncLocal(channel, take: 10);
-    });
+    isLoading.value = true;
+    await syncLocal(channel, take: firstTake);
     isLoading.value = false;
+
+    // Take a small range of messages to check is local database up to date
+    var isUpToDate = true;
+    final result =
+        await src.pullRemoteEvents(channel, scope: scope, take: firstTake);
+    totalEvents.value = result?.$2 ?? 0;
+    if ((result?.$1.length ?? 0) > 0) {
+      final minId = result!.$1.map((x) => x.id).reduce(math.min);
+      isUpToDate = await src.getEventFromLocal(minId) != null;
+    }
+    syncLocal(channel, take: firstTake);
+
+    if (!isUpToDate) {
+      // Loading more content due to isn't up to date
+      final result =
+          await src.pullRemoteEvents(channel, scope: scope, take: furtherTake);
+      totalEvents.value = result?.$2 ?? 0;
+      syncLocal(channel, take: furtherTake);
+    }
   }
 
   Future<void> loadEvents(Channel channel, String scope) async {
@@ -46,7 +65,9 @@ class ChatEventController {
 
     isLoading.value = true;
     await syncLocal(channel, take: take, offset: offset);
-    src.pullRemoteEvents(channel, scope: scope, offset: offset).then((result) {
+    src
+        .pullRemoteEvents(channel, scope: scope, take: take, offset: offset)
+        .then((result) {
       totalEvents.value = result?.$2 ?? 0;
       syncLocal(channel, take: take, offset: offset);
     });
@@ -56,7 +77,11 @@ class ChatEventController {
   Future<bool> syncLocal(Channel channel,
       {required int take, int offset = 0}) async {
     final data = await src.listEvents(channel, take: take, offset: offset);
-    currentEvents.replaceRange(0, currentEvents.length, data);
+    if (currentEvents.length >= offset + take) {
+      currentEvents.replaceRange(offset, offset + take, data);
+    } else {
+      currentEvents.insertAll(currentEvents.length, data);
+    }
     for (final x in data.reversed) {
       applyEvent(x);
     }

lib/models/packet.dart

@@ -4,7 +4,7 @@ part 'packet.g.dart';
 
 @JsonSerializable()
 class NetworkPackage {
-  @JsonKey(name: 'w')
+  @JsonKey(name: 'w', defaultValue: 'unknown')
   String method;
   @JsonKey(name: 'e')
   String? endpoint;

lib/models/packet.g.dart

@@ -8,7 +8,7 @@ part of 'packet.dart';
 
 NetworkPackage _$NetworkPackageFromJson(Map<String, dynamic> json) =>
     NetworkPackage(
-      method: json['w'] as String,
+      method: json['w'] as String? ?? 'unknown',
       endpoint: json['e'] as String?,
       message: json['m'] as String?,
       payload: json['p'] as Map<String, dynamic>?,

lib/providers/database/services/messages.dart

@@ -129,6 +129,14 @@ class MessagesFetchingProvider extends GetxController {
     return await receiveEvent(remoteRecord);
   }
 
+  Future<LocalMessageEventTableData?> getEventFromLocal(int id) async {
+    final database = Get.find<DatabaseProvider>().database;
+    final localRecord = await (database.select(database.localMessageEventTable)
+          ..where((x) => x.id.equals(id)))
+        .getSingleOrNull();
+    return localRecord;
+  }
+
   /// Pull the remote events to local database
   Future<(List<Event>, int)?> pullRemoteEvents(Channel channel,
       {String scope = 'global', take = 10, offset = 0}) async {

lib/screens/auth/signin.dart

@@ -153,7 +153,7 @@ class _SignInScreenState extends State<SignInScreen> {
 
     try {
       // Check ticket
-      final resp = await client.patch('/auth', {
+      final resp = await client.request('/auth', 'PATCH', body: {
         'ticket_id': _currentTicket!.id,
         'factor_id': _factorPicked!,
         'code': password,

lib/widgets/chat/chat_event_list.dart

@@ -92,10 +92,13 @@ class ChatEventList extends StatelessWidget {
               );
             },
             onFetchData: () {
-              chatController.loadEvents(
-                chatController.channel!,
-                chatController.scope!,
-              );
+              if (chatController.currentEvents.length <
+                  chatController.totalEvents.value) {
+                chatController.loadEvents(
+                  chatController.channel!,
+                  chatController.scope!,
+                );
+              }
             },
           );
         }),

lib/widgets/navigation/app_navigation_region.dart

@@ -1,3 +1,4 @@
+import 'package:animations/animations.dart';
 import 'package:flutter/material.dart';
 import 'package:get/get.dart';
 import 'package:solian/models/realm.dart';
@@ -126,16 +127,12 @@ class _AppNavigationRegionState extends State<AppNavigationRegion> {
     final NavigationStateProvider navState = Get.find();
 
     return Obx(
-      () => AnimatedSwitcher(
-        switchInCurve: Curves.fastOutSlowIn,
-        switchOutCurve: Curves.fastOutSlowIn,
-        duration: const Duration(milliseconds: 300),
-        transitionBuilder: (child, animation) {
-          return SlideTransition(
-            position: Tween<Offset>(
-              begin: const Offset(1.0, 0.0),
-              end: Offset.zero,
-            ).animate(animation),
+      () => PageTransitionSwitcher(
+        transitionBuilder: (child, animation, secondaryAnimation) {
+          return SharedAxisTransition(
+            animation: animation,
+            secondaryAnimation: secondaryAnimation,
+            transitionType: SharedAxisTransitionType.horizontal,
             child: Material(
               color: Theme.of(context).colorScheme.surface,
               child: child,

pubspec.yaml

@@ -2,7 +2,7 @@ name: solian
 description: "The Solar Network App"
 publish_to: "none"
 
-version: 1.2.1+38
+version: 1.2.1+39
 
 environment:
   sdk: ">=3.3.4 <4.0.0"