Bei Ablehnen werden Jobs gleich auf dem Gerät gelöscht

lib/content_views/assigned_jobs_page.dart

@@ -9,6 +9,8 @@ import 'package:intl/intl.dart';
 import 'package:badges/badges.dart' as badges;
 import 'package:stadtbote/protocoll_messages/accept_job_message.dart';
 import 'package:stadtbote/protocoll_messages/fin_task_message.dart';
+import 'package:stadtbote/tools/message_service.dart';
+import 'package:stadtbote/tools/messages/refresh_badges_message.dart';
 import 'package:stadtbote/tools/mqtt_core.dart';
 
 import '../main.dart';
@@ -198,8 +200,11 @@ class _AssignedJobsPageState extends State<AssignedJobsPage> {
 
     MqttCore.instance.publishText("reaction", jsonEncode(message.toJson()));
 
-    job.state = 9;
-    MyApp.isarInstance.writeTxnSync(() => {MyApp.isarInstance.jobs.putSync(job)});
+    MyApp.isarInstance.writeTxnSync(() {
+      MyApp.isarInstance.jobs.deleteSync(job.id);
+    });
+
+    MessageService().publish(Constants.messageTopicRefreshBadges, arguments: RefreshBadgesMessage());
 
     _entries = await _createListEntries();
 

lib/content_views/main_page.dart

@@ -19,6 +19,7 @@ import 'package:stadtbote/tools/message_service.dart';
 import 'package:stadtbote/tools/messages/job_deleted_message.dart';
 import 'package:stadtbote/tools/messages/job_received_message.dart';
 import 'package:stadtbote/tools/messages/message_message.dart';
+import 'package:stadtbote/tools/messages/refresh_badges_message.dart';
 import 'package:stadtbote/tools/messages/session_info_update.dart';
 import 'package:badges/badges.dart' as badges;
 import 'package:stadtbote/tools/messages/status_info_update.dart';
@@ -276,6 +277,10 @@ class _MainPageState extends State<MainPage> {
     MessageService().subscribe<JobDeletedMessage>(Constants.messageTopicJobDeleted, this, (JobDeletedMessage job) {
       _refreshBadges();
     });
+
+    MessageService().subscribe<RefreshBadgesMessage>(Constants.messageTopicRefreshBadges, this, (RefreshBadgesMessage refreshMessage) {
+      _refreshBadges();
+    });
   }
 
   void _exitMessages() {

lib/popups/accept_jobs_popup.dart

@@ -8,6 +8,8 @@ import 'package:stadtbote/protocoll_messages/accept_job_message.dart';
 import 'package:stadtbote/model/job.dart';
 import 'package:stadtbote/protocoll_messages/fin_task_message.dart';
 import 'package:stadtbote/tools/constants.dart';
+import 'package:stadtbote/tools/message_service.dart';
+import 'package:stadtbote/tools/messages/refresh_badges_message.dart';
 import 'package:stadtbote/tools/mqtt_core.dart';
 import 'package:stadtbote/tools/util.dart';
 import 'package:badges/badges.dart' as badges;
@@ -169,6 +171,9 @@ _sendAnswer(Job job, int item) {
 
   MqttCore.instance.publishText("reaction", jsonEncode(message.toJson()));
 
-  job.state = 9;
-  MyApp.isarInstance.writeTxnSync(() => {MyApp.isarInstance.jobs.putSync(job)});
+  MyApp.isarInstance.writeTxnSync(() {
+    MyApp.isarInstance.jobs.deleteSync(job.id);
+  });
+
+  MessageService().publish(Constants.messageTopicRefreshBadges, arguments: RefreshBadgesMessage());
 }

lib/tools/constants.dart

@@ -11,6 +11,7 @@ class Constants {
   static const String messageTopicRankingUpdated = "ranking_updated";
   static const String messageTopicJobReceived = "job_received";
   static const String messageTopicJobDeleted = "job_deleted";
+  static const String messageTopicRefreshBadges = "refresh_badges";
   static const String messageTopicMessageReceived = "message_received";
   static const String messageTopicPushContentView = "push_content_view";
   static const String messageTopicPopContentView = "pop_content_view";

lib/tools/messages/refresh_badges_message.dart

@@ -0,0 +1,4 @@
+
+class RefreshBadgesMessage {
+  RefreshBadgesMessage();
+}