Ranking erweitert

lib/tools/mqtt_core.dart

@@ -13,6 +13,7 @@ import 'package:stadtbote/model/job.dart';
 import 'package:stadtbote/model/log_entry.dart';
 import 'package:stadtbote/model/message.dart';
 import 'package:stadtbote/model/location_status.dart';
+import 'package:stadtbote/model/rank.dart';
 import 'package:stadtbote/protocoll_messages/acknowledge_job.dart';
 import 'package:stadtbote/protocoll_messages/bootstrap_request.dart';
 import 'package:stadtbote/protocoll_messages/bootstrap_response_payload.dart';
@@ -27,6 +28,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/ranking_updated.dart';
 import 'package:stadtbote/tools/messages/session_info_update.dart';
 import 'package:stadtbote/tools/messages/status_info_update.dart';
 // ignore: depend_on_referenced_packages
@@ -246,16 +248,15 @@ class MqttCore {
     MessageService().publish<LocationStatusUpdate>(Constants.messageTopicLocationStatusUpdated, arguments: LocationStatusUpdate(status: locationStatus));
   }
 
-  void _rankingMessageReceived(List<dynamic> payloadData) async {
-    /*Map<String, dynamic> rankingMap = {};
-    rankingMap["ranks"] = payloadData;
-    var ranking = Ranking.fromJson(rankingMap);
+  void _rankingMessageReceived(payloadData) async {
+    var ranking = Ranking.fromJson(payloadData);
 
     await MyApp.isarInstance.writeTxn(() async {
+      await MyApp.isarInstance.rankings.clear();
       await MyApp.isarInstance.rankings.put(ranking);
     });
 
-    MessageService().publish<RankingUpdated>(Constants.messageTopicRankingUpdated, arguments: RankingUpdated());*/
+    MessageService().publish<RankingUpdated>(Constants.messageTopicRankingUpdated, arguments: RankingUpdated());
   }
 
   void _jobMessageReceived(payloadData) async {
@@ -405,6 +406,8 @@ class MqttCore {
 
       _connectToBroker();
     } catch (ex) {
+      Util.logException("bootstrap failed");
+
       _startBootstrapReconnectTimer();
     }
   }