Fehlerkorrekturen und Erweiterungen

lib/tools/mqtt_core.dart

@@ -49,6 +49,7 @@ import 'package:uuid/uuid.dart';
 import '../main.dart';
 import '../model/session_status.dart';
 import 'constants.dart';
+import 'messages/bwv_message.dart';
 import 'util.dart';
 
 enum ConnectionStateEnum { notConnected, connected }
@@ -301,13 +302,10 @@ class MqttCore with ProducerMixin, ConsumerMixin {
 
     Util.logInfo('subscribed to topic: $fromServerTopic');
 
-    // TODO MESSAGING
     sendMessage(
       routingKey: Constants.messageTopicConnectionStatusChanged,
       payload: ConnectionStatus(status: ConnectionStatusEnum.connected),
     );
-
-    //await MessageService().publish<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged, arguments: ConnectionStatus(status: ConnectionStatusEnum.connected));
   }
 
   void _sessionMessageReceived(payloadData) async {
@@ -324,7 +322,12 @@ class MqttCore with ProducerMixin, ConsumerMixin {
       await MyApp.isarInstance.sessionStatus.put(sessionStatusMessage);
     });
 
-    Util.preferencesSaveBool(Constants.prefsBWVEnabled, sessionStatusMessage.bwvEnabled);
+    var bwvEnabled = sessionStatusMessage.bwvEnabled;
+    Util.preferencesSaveBool(Constants.prefsBWVEnabled, bwvEnabled);
+    sendMessage(
+      routingKey: Constants.messageTopicBWVEnabled,
+      payload: BWVMessage(bwvEnabled: bwvEnabled),
+    );
 
     sendMessage(
       routingKey: Constants.messageTopicSessionStatusInfoUpdate,