Assecutor/stadtbote-app
4
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fehlerkorrekturen

Browse Source
This commit is contained in:
Sven committed 2024-05-06 11:48:24 +02:00
1 parent 8c45d1052e
commit db93891dc9
2 files changed
+14 -11
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

lib/tools/mqtt_core.dart
+13 -10
View File
@@ -167,9 +167,9 @@ class MqttCore {
var json = jsonEncode(payloadContainer.toJson());
try {
_publishText(_toServerTopic, json);
_publishText(topic, json);
} catch (e) {
_enqueueMessage(_toServerTopic, jsonEncode(payloadContainer.toJson()));
_enqueueMessage(topic, jsonEncode(payloadContainer.toJson()));
}
}
@@ -216,6 +216,10 @@ class MqttCore {
_syncRequestReceived(jsonDecode(payload));
break;
case 'location_status':
_locationStatusMessageReceived(jsonDecode(payload));
break;
case "mssg":
_messageMessageReceived(jsonDecode(payload));
break;
@@ -235,10 +239,12 @@ class MqttCore {
}
});
var fromServerTopic = "$_fromServerTopic#";
if (await Util.preferencesContainsKey(Constants.prefsPreviousMqttSubscription)) {
String previousMqttSubscription = await Util.preferencesGetString(Constants.prefsPreviousMqttSubscription, "") as String;
if (previousMqttSubscription != _fromServerTopic) {
if (previousMqttSubscription != fromServerTopic) {
Util.logInfo('topic changed -> unsubscribe from $previousMqttSubscription');
_mqttClient!.unsubscribe(previousMqttSubscription);
}
@@ -246,14 +252,12 @@ class MqttCore {
_mqttClient!.subscribe(_fromServerTopic, MqttQos.exactlyOnce);
}
_mqttClient!.subscribe(_fromServerTopic, MqttQos.exactlyOnce);
Util.preferencesSaveString(Constants.prefsPreviousMqttSubscription, _fromServerTopic);
_mqttClient!.subscribe(fromServerTopic, MqttQos.exactlyOnce);
Util.preferencesSaveString(Constants.prefsPreviousMqttSubscription, fromServerTopic);
var fromServerTopic = "$_fromServerTopic#";
Util.logInfo('subscribed to topic: $fromServerTopic');
MessageService().publish<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged,
arguments: ConnectionStatus(status: ConnectionStatusEnum.connected));
MessageService().publish<ConnectionStatus>(Constants.messageTopicConnectionStatusChanged, arguments: ConnectionStatus(status: ConnectionStatusEnum.connected));
}
void _sessionMessageReceived(payloadData) async {
@@ -295,8 +299,7 @@ class MqttCore {
await MyApp.isarInstance.locationStatus.put(locationStatus);
});
MessageService()
.publish<LocationStatusUpdate>(Constants.messageTopicLocationStatusUpdated, arguments: LocationStatusUpdate(status: locationStatus));
MessageService().publish<LocationStatusUpdate>(Constants.messageTopicLocationStatusUpdated, arguments: LocationStatusUpdate(status: locationStatus));
}
void _rankingMessageReceived(payloadData) async {