From 035f25190bd46b8d02bd967a6713bfc764b22ea1 Mon Sep 17 00:00:00 2001 From: Ben Meadors Date: Fri, 2 Jul 2021 07:47:12 -0500 Subject: [PATCH] Handle MQTT host string with port omitted --- src/mqtt/MQTT.cpp | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/src/mqtt/MQTT.cpp b/src/mqtt/MQTT.cpp index f82f9940a..33e0ee7c3 100644 --- a/src/mqtt/MQTT.cpp +++ b/src/mqtt/MQTT.cpp @@ -69,10 +69,14 @@ void MQTT::reconnect() String server = String(serverAddr); int delimIndex = server.indexOf(':'); - String host = server.substring(0, delimIndex); - String port = server.substring(delimIndex+1, server.length()); - - pubSub.setServer(host.c_str(), port.toInt()); + if (delimIndex > 0) { + String host = server.substring(0, delimIndex); + String port = server.substring(delimIndex+1, server.length()); + pubSub.setServer(host.c_str(), port.toInt()); + } + else { + pubSub.setServer(serverAddr, 1883); + } DEBUG_MSG("Connecting to MQTT server\n", serverAddr); auto myStatus = (statusTopic + owner.id);