Erweiterungen

lib/main.dart

@@ -7,9 +7,11 @@ import 'package:isar/isar.dart';
 import 'package:path_provider/path_provider.dart';
 import 'package:stadtbote/model/message.dart';
 import 'package:stadtbote/model/task_info.dart';
+import 'package:stadtbote/popups/accept_jobs_popup.dart';
 import 'package:stadtbote/tools/colored_safe_area.dart';
 import 'package:stadtbote/model/status.dart';
 import 'package:stadtbote/tools/connection_status.dart';
+import 'package:stadtbote/tools/messages/job_received_message.dart';
 
 import 'tools/mqtt_core.dart';
 import 'content_views/main_page.dart';
@@ -317,6 +319,9 @@ class _MainState extends State<Main> with SingleTickerProviderStateMixin {
     BroadcastReceiver().subscribe<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged, (ConnectionStatus connectionStatus) {
       _connectionStatusChanged(connectionStatus);
     });
+    BroadcastReceiver().subscribe<JobReceivedMessage>(Constants.messageTopicJobReceived, (JobReceivedMessage jobReceivedMessage) {
+      _jobReceived(jobReceivedMessage.job);
+    });
   }
 
   void _replaceContentView(ContentViewWidget widget) async {
@@ -396,4 +401,10 @@ class _MainState extends State<Main> with SingleTickerProviderStateMixin {
   void _connectionStatusChanged(ConnectionStatus connectionStatus) {
     _connectionLostValueNotifier.value = connectionStatus.status == ConnectionStatusEnum.notConnected;
   }
+
+  void _jobReceived(Job job) async {
+    if (job.state == 0) {
+      await showAcceptJobsPopup(context, await MyApp.isarInstance.jobs.filter().stateEqualTo(0).findAll());
+    }
+  }
 }