From 024b1362eb0efbf61833181765003a89cf3a9cd4 Mon Sep 17 00:00:00 2001 From: Maxim Prokhorov Date: Tue, 10 Sep 2024 16:07:29 +0300 Subject: [PATCH] mqtt: allow empty payload --- code/espurna/mqtt.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/code/espurna/mqtt.cpp b/code/espurna/mqtt.cpp index 7591d516..25b5ff70 100644 --- a/code/espurna/mqtt.cpp +++ b/code/espurna/mqtt.cpp @@ -1664,7 +1664,7 @@ void _mqttOnMessageAsync(char* raw_topic, char* raw_payload, AsyncMqttClientMess static constexpr size_t BufferSize { MQTT_BUFFER_MAX_SIZE }; static_assert(BufferSize > 0, ""); - if (!len || (len > BufferSize) || (total > BufferSize)) { + if ((len > BufferSize) || (total > BufferSize)) { return; } @@ -1684,7 +1684,7 @@ void _mqttOnMessageAsync(char* raw_topic, char* raw_payload, AsyncMqttClientMess } buffer[len + index] = '\0'; - if (len < mqtt::build::MessageLogMax) { + if (len > 0 || len < mqtt::build::MessageLogMax) { DEBUG_MSG_P(PSTR("[MQTT] Received %.*s => %s\n"), topic.length(), topic.data(), buffer); } else { @@ -1708,7 +1708,7 @@ void _mqttOnMessage(char* raw_topic, char* raw_payload, unsigned int len) { auto message = espurna::StringView{ payload, len }; - if (len < mqtt::build::MessageLogMax) { + if (len > 0 || len < mqtt::build::MessageLogMax) { DEBUG_MSG_P(PSTR("[MQTT] Received %.*s => %.*s\n"), topic.length(), topic.data(), message.length(), message.data());