New convos should be loaded at the app resumed (#1722)

BasedHardware · Jan 22, 2025 · 9ae0669 · 9ae0669
2 parents c017b15 + 63fe74e
commit 9ae0669
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 9 deletions.
diff --git a/app/lib/pages/conversations/widgets/capture.dart b/app/lib/pages/conversations/widgets/capture.dart
@@ -19,8 +19,7 @@ class LiteCaptureWidget extends StatefulWidget {
   State<LiteCaptureWidget> createState() => LiteCaptureWidgetState();
 }
 
-class LiteCaptureWidgetState extends State<LiteCaptureWidget>
-    with AutomaticKeepAliveClientMixin, WidgetsBindingObserver {
+class LiteCaptureWidgetState extends State<LiteCaptureWidget> with AutomaticKeepAliveClientMixin {
   @override
   bool get wantKeepAlive => true;
 
@@ -31,7 +30,6 @@ class LiteCaptureWidgetState extends State<LiteCaptureWidget>
   @override
   void initState() {
     WavBytesUtil.clearTempWavFiles();
-    WidgetsBinding.instance.addObserver(this);
     SchedulerBinding.instance.addPostFrameCallback((_) async {
       if (context.read<DeviceProvider>().connectedDevice != null) {
         context.read<OnboardingProvider>().stopScanDevices();
@@ -47,12 +45,6 @@ class LiteCaptureWidgetState extends State<LiteCaptureWidget>
     super.initState();
   }
 
-  @override
-  void dispose() {
-    WidgetsBinding.instance.removeObserver(this);
-    super.dispose();
-  }
-
   Future<BleAudioCodec> _getAudioCodec(String deviceId) async {
     var connection = await ServiceManager.instance().device.ensureConnection(deviceId);
     if (connection == null) {

diff --git a/app/lib/pages/home/page.dart b/app/lib/pages/home/page.dart
@@ -111,6 +111,12 @@ class _HomePageState extends State<HomePage> with WidgetsBindingObserver, Ticker
       event = 'App is paused';
     } else if (state == AppLifecycleState.resumed) {
       event = 'App is resumed';
+
+      // Reload convos
+      if (mounted) {
+        debugPrint('Reload convos');
+        Provider.of<ConversationProvider>(context, listen: false).fetchNewConversations();
+      }
     } else if (state == AppLifecycleState.hidden) {
       event = 'App is hidden';
     } else if (state == AppLifecycleState.detached) {

diff --git a/app/lib/providers/conversation_provider.dart b/app/lib/providers/conversation_provider.dart
@@ -161,6 +161,18 @@ class ConversationProvider extends ChangeNotifier implements IWalServiceListener
     notifyListeners();
   }
 
+  Future fetchNewConversations() async {
+    List<ServerConversation> newConversations = await getConversationsFromServer();
+    List<ServerConversation> upsertConvos =
+        newConversations.where((c) => conversations.indexWhere((cc) => cc.id == c.id) == -1).toList();
+    if (upsertConvos.isEmpty) {
+      return;
+    }
+    conversations.insertAll(0, upsertConvos);
+    _groupConversationsByDateWithoutNotify();
+    notifyListeners();
+  }
+
   Future fetchConversations() async {
     previousQuery = "";
     currentSearchPage = 0;