refactor: Add PublishTaskPositionsOnUpdate.dart

lib/app_wrappers/PublishTaskPositionsOnUpdate.dart

@@ -0,0 +1,58 @@
+import 'dart:async';
+
+import 'package:flutter/material.dart';
+import 'package:locus/services/current_location_service.dart';
+import 'package:locus/services/location_point_service.dart';
+import 'package:locus/services/task_service/index.dart';
+import 'package:provider/provider.dart';
+
+class PublishTaskPositionsOnUpdate extends StatefulWidget {
+  const PublishTaskPositionsOnUpdate({super.key});
+
+  @override
+  State<PublishTaskPositionsOnUpdate> createState() =>
+      _PublishTaskPositionsOnUpdateState();
+}
+
+class _PublishTaskPositionsOnUpdateState
+    extends State<PublishTaskPositionsOnUpdate> {
+  late final CurrentLocationService _currentLocation;
+  late final StreamSubscription _stream;
+
+  @override
+  void initState() {
+    super.initState();
+
+    _currentLocation = context.read<CurrentLocationService>();
+
+    _stream = _currentLocation.stream.listen((position) async {
+      final taskService = context.read<TaskService>();
+
+      final runningTasks = await taskService.getRunningTasks().toList();
+
+      if (runningTasks.isEmpty) {
+        return;
+      }
+
+      final locationData = await LocationPointService.fromPosition(position);
+
+      for (final task in runningTasks) {
+        await task.publisher.publishOutstandingPositions();
+        await task.publisher.publishLocation(
+          locationData.copyWithDifferentId(),
+        );
+      }
+    });
+  }
+
+  @override
+  void dispose() {
+    _stream.cancel();
+    super.dispose();
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return const SizedBox.shrink();
+  }
+}

lib/app_wrappers/RegisterBackgroundListeners.dart

@@ -42,6 +42,10 @@ class _RegisterBackgroundListenersState
   }
 
   void _updateListeners() async {
+    if (!_settings.userHasSeenWelcomeScreen) {
+      return;
+    }
+
     FlutterLogs.logInfo(
       LOG_TAG,
       "Register Background Listeners",

lib/main.dart

@@ -11,6 +11,7 @@ import 'package:locus/app_wrappers/CheckViewAlarmsLive.dart';
 import 'package:locus/app_wrappers/HandleNotifications.dart';
 import 'package:locus/app_wrappers/InitCurrentLocationFromSettings.dart';
 import 'package:locus/app_wrappers/LocationHistoryUpdater.dart';
+import 'package:locus/app_wrappers/PublishTaskPositionsOnUpdate.dart';
 import 'package:locus/app_wrappers/RegisterBackgroundListeners.dart';
 import 'package:locus/app_wrappers/ManageQuickActions.dart';
 import 'package:locus/app_wrappers/ShowUpdateDialog.dart';
@@ -116,6 +117,7 @@ void main() async {
           ManageQuickActions(),
           InitCurrentLocationFromSettings(),
           ShowUpdateDialog(),
+          PublishTaskPositionsOnUpdate(),
           App(),
         ],
       ),

lib/screens/LocationsOverviewScreen.dart

@@ -300,7 +300,6 @@ class _LocationsOverviewScreenState extends State<LocationsOverviewScreen>
     );
 
     _positionStream!.listen((position) async {
-      final taskService = context.read<TaskService>();
       final currentLocation = context.read<CurrentLocationService>();
 
       currentLocation.updateCurrentPosition(position);
@@ -309,21 +308,6 @@ class _LocationsOverviewScreenState extends State<LocationsOverviewScreen>
         lastPosition = position;
         locationStatus = LocationStatus.active;
       });
-
-      final runningTasks = await taskService.getRunningTasks().toList();
-
-      if (runningTasks.isEmpty) {
-        return;
-      }
-
-      final locationData = await LocationPointService.fromPosition(position);
-
-      for (final task in runningTasks) {
-        await task.publisher.publishOutstandingPositions();
-        await task.publisher.publishLocation(
-          locationData.copyWithDifferentId(),
-        );
-      }
     });
   }