From a00a3134c67657949ab7ab5317133a49a855fe30 Mon Sep 17 00:00:00 2001 From: David Cermak Date: Sun, 23 May 2021 15:43:07 +0200 Subject: [PATCH] Add support for Retain flag in messages posted by events Closes https://github.com/espressif/esp-mqtt/issues/193 --- include/mqtt_client.h | 2 ++ mqtt_client.c | 1 + 2 files changed, 3 insertions(+) diff --git a/include/mqtt_client.h b/include/mqtt_client.h index da98b85..e4a656c 100644 --- a/include/mqtt_client.h +++ b/include/mqtt_client.h @@ -50,6 +50,7 @@ typedef enum { - data_len length of the data for this event - current_data_offset offset of the current data for this event - total_data_len total length of the data received + - retain retain flag of the message Note: Multiple MQTT_EVENT_DATA could be fired for one message, if it is longer than internal buffer. In that case only first event contains topic pointer and length, other contain data only with current data length @@ -151,6 +152,7 @@ typedef struct { int msg_id; /*!< MQTT messaged id of message */ int session_present; /*!< MQTT session_present flag for connection event */ esp_mqtt_error_codes_t *error_handle; /*!< esp-mqtt error handle including esp-tls errors as well as internal mqtt errors */ + bool retain; /*!< Retained flag of the message associated with this event */ } esp_mqtt_event_t; typedef esp_mqtt_event_t *esp_mqtt_event_handle_t; diff --git a/mqtt_client.c b/mqtt_client.c index e67f4fe..6346575 100644 --- a/mqtt_client.c +++ b/mqtt_client.c @@ -923,6 +923,7 @@ static esp_err_t deliver_publish(esp_mqtt_client_handle_t client) } // post data event + client->event.retain = mqtt_get_retain(msg_buf); client->event.msg_id = mqtt_get_id(msg_buf, msg_data_len); client->event.total_data_len = msg_data_len + msg_total_len - msg_read_len;