From 097131d7fbd6ca50d4eaa9322b89add547945f7d Mon Sep 17 00:00:00 2001 From: Gunnar Skjold Date: Mon, 6 Dec 2021 10:47:42 +0100 Subject: [PATCH] Some changes --- src/AmsToMqttBridge.ino | 5 ++--- src/mqtt/JsonMqttHandler.cpp | 2 +- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/src/AmsToMqttBridge.ino b/src/AmsToMqttBridge.ino index 7dd9574b..fd1ec1a1 100644 --- a/src/AmsToMqttBridge.ino +++ b/src/AmsToMqttBridge.ino @@ -62,7 +62,7 @@ Timezone* tz; AmsWebServer ws(&Debug, &hw); MQTTClient *mqtt = NULL; -WiFiClient *mqttClient = NULL; +WiFiClient *mqttClient = new WiFiClient(); WiFiClientSecure *mqttSecureClient = NULL; AmsMqttHandler* mqttHandler = NULL; @@ -72,7 +72,6 @@ SoftwareSerial *swSerial = NULL; GpioConfig gpioConfig; MeterConfig meterConfig; bool mqttEnabled = false; -uint8_t payloadFormat = 0; String topic = "ams"; AmsData meterState; bool ntpEnabled = false; @@ -920,7 +919,6 @@ void MQTT_connect() { mqttEnabled = true; ws.setMqttEnabled(true); - payloadFormat = mqttConfig.payloadFormat; topic = String(mqttConfig.publishTopic); if(mqttHandler != NULL) { @@ -1002,6 +1000,7 @@ void MQTT_connect() { if(Debug.isActive(RemoteDebug::INFO)) { debugI("Connecting to MQTT %s:%d", mqttConfig.host, mqttConfig.port); } + mqtt->begin(mqttConfig.host, mqttConfig.port, *mqttClient); #if defined(ESP8266) diff --git a/src/mqtt/JsonMqttHandler.cpp b/src/mqtt/JsonMqttHandler.cpp index 5c216d6d..55b488f8 100644 --- a/src/mqtt/JsonMqttHandler.cpp +++ b/src/mqtt/JsonMqttHandler.cpp @@ -113,7 +113,7 @@ bool JsonMqttHandler::publishTemperatures(AmsConfiguration* config, HwTools* hw) bool JsonMqttHandler::publishPrices(EntsoeApi* eapi) { if(topic.isEmpty() || !mqtt->connected()) return false; - if(strcmp(eapi->getToken(), "") == 0) + if(strlen(eapi->getToken()) == 0) return false; time_t now = time(nullptr);