Mirrors/espurna
2
0
Fork 0
mirror of https://github.com/xoseperez/espurna.git synced 2026-03-24 17:17:06 +01:00
Code Issues Packages Projects Releases Wiki Activity

mqtt: allow empty payload

Browse Source
This commit is contained in:
Maxim Prokhorov
2024-09-10 16:07:29 +03:00
parent d0c81a7381
commit 024b1362eb
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
code/espurna/mqtt.cpp
View File

@@ -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());