From 851b8ca90048eea75343e39dee72fe037fd451b9 Mon Sep 17 00:00:00 2001 From: Garth Vander Houwen Date: Mon, 21 Jul 2025 12:00:55 -0700 Subject: [PATCH] update mqtt port parsing --- .../Helpers/Mqtt/MqttClientProxyManager.swift | 14 ++++++++------ 1 file changed, 8 insertions(+), 6 deletions(-) diff --git a/Meshtastic/Helpers/Mqtt/MqttClientProxyManager.swift b/Meshtastic/Helpers/Mqtt/MqttClientProxyManager.swift index 7256883d..853533e9 100644 --- a/Meshtastic/Helpers/Mqtt/MqttClientProxyManager.swift +++ b/Meshtastic/Helpers/Mqtt/MqttClientProxyManager.swift @@ -26,17 +26,19 @@ class MqttClientProxyManager { var topic = "msh" var debugLog = false func connectFromConfigSettings(node: NodeInfoEntity) { - var host = node.mqttConfig?.address ?? "mqtt.meshtastic.org" + let originalAddress = node.mqttConfig?.address ?? "mqtt.meshtastic.org" let defaultServerAddress = "mqtt.meshtastic.org" var useSsl = node.mqttConfig?.tlsEnabled == true + var defaultServerPort = useSsl ? 8883 : 1883 + var host = originalAddress + if originalAddress.contains(":") { + host = host.components(separatedBy: ":")[0] + defaultServerPort = Int(originalAddress.components(separatedBy: ":")[1]) ?? (useSsl ? 8883 : 1883) + } // Require TLS for the public Server if host.lowercased() == defaultServerAddress { useSsl = true - } - var defaultServerPort = useSsl ? 8883 : 1883 - if host.contains(":") { - host = host.components(separatedBy: ":")[0] - defaultServerPort = Int(host.components(separatedBy: ":")[1]) ?? (useSsl ? 8883 : 1883) + defaultServerPort = 8883 } let port = defaultServerPort let root = node.mqttConfig?.root?.count ?? 0 > 0 ? node.mqttConfig?.root : "msh"