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

Fehlerkorrekturen und Erweiterungen

Browse Source
This commit is contained in:
Sven committed 2025-03-03 14:29:35 +01:00
1 parent 777876bc8d
commit 1f3cc1e995
357 files changed
+50603 -572
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

lib/tools/mqtt_core.dart
+7 -7
View File
@@ -113,7 +113,7 @@ class MqttCore with ProducerMixin, ConsumerMixin {
_connectToBroker() async {
try {
String clientId = await Util.getAppUuid();
String clientId = Util.getAppUuid();
Util.logInfo("client id: $clientId");
Util.logInfo("broker uri: $_brokerUri");
Util.logInfo("broker port: $_brokerPort");
@@ -137,7 +137,7 @@ class MqttCore with ProducerMixin, ConsumerMixin {
var connectionLostEncapsulatedMessage = _encapsulateMessage(const Uuid().v4(), false, connectionLostMessage.toJson());
_mqttClient!.connectionMessage = MqttConnectMessage()
.withClientIdentifier(await Util.getAppUuid())
.withClientIdentifier(Util.getAppUuid())
.authenticateAs("app", "apppwd")
.withSessionExpiryInterval(2700)
.withWillProperties(willProperties)
@@ -281,8 +281,8 @@ class MqttCore with ProducerMixin, ConsumerMixin {
var fromServerTopic = "$_fromServerTopic$_clientId/#";
if (await Util.preferencesContainsKey(Constants.prefsPreviousMqttSubscription)) {
String previousMqttSubscription = await Util.preferencesGetString(Constants.prefsPreviousMqttSubscription, "") as String;
if (Util.preferencesContainsKey(Constants.prefsPreviousMqttSubscription)) {
String previousMqttSubscription = Util.preferencesGetString(Constants.prefsPreviousMqttSubscription, "") as String;
if (previousMqttSubscription != fromServerTopic) {
Util.logInfo('topic changed -> unsubscribe from $previousMqttSubscription');
@@ -417,7 +417,7 @@ class MqttCore with ProducerMixin, ConsumerMixin {
if (job != null) {
sendMessage(
routingKey: Constants.messageTopicJobDeleted,
payload: JobDeletedMessage(job: job!),
payload: JobDeletedMessage(job: job),
);
}
}
@@ -535,7 +535,7 @@ class MqttCore with ProducerMixin, ConsumerMixin {
var handshakeMessage = BootstrapRequest();
handshakeMessage.app = "sb";
handshakeMessage.mqttClientId = await Util.getAppUuid();
handshakeMessage.mqttClientId = Util.getAppUuid();
handshakeMessage.deviceObject = deviceObject;
handshakeMessage.ver = await Util.getAppVersion();
@@ -577,7 +577,7 @@ class MqttCore with ProducerMixin, ConsumerMixin {
_initSession() async {
var startSessionMessage = StartSessionMessage();
startSessionMessage.desiredZip = (await Util.preferencesGetString(Constants.prefsDesiredZip, ""))!;
startSessionMessage.desiredZip = (Util.preferencesGetString(Constants.prefsDesiredZip, ""))!;
var jsonMap = startSessionMessage.toJson();