UPDATE: I came up with an idea to avoid the header problem.
I found that the headers are compared/analysed in a function called: int
mqtt_has_valid_msg_hdr(uint8_t *buffer, uint16_t length)
which is located in $HOME/esp/esp-idf/components/mqtt/esp-mqtt/lib/mqtt_msg.c file.
Code: Select all
int mqtt_has_valid_msg_hdr(uint8_t *buffer, uint16_t length)
{
int qos, dup;
if (length < 1) {
return 0;
}
switch (mqtt_get_type(buffer)) {
case MQTT_MSG_TYPE_CONNECT: //0x10
case MQTT_MSG_TYPE_CONNACK: //0x20
case MQTT_MSG_TYPE_PUBACK: //0x40
case MQTT_MSG_TYPE_PUBREC: //0x50
case MQTT_MSG_TYPE_PUBCOMP: //0x70
case MQTT_MSG_TYPE_PINGREQ: //0xC0
case MQTT_MSG_TYPE_PINGRESP: //0xD0
case MQTT_MSG_TYPE_DISCONNECT: //0xE0
return (buffer[0] & 0x0f) == 0; /* all flag bits are 0 */
//-----------------These are the headers that i had problems------------------
case MQTT_MSG_TYPE_SUBACK: //0x90
case MQTT_MSG_TYPE_UNSUBACK: //0xB0
if ((buffer[0] & 0x0f) == 0)
{
return (buffer[0] & 0x0f) == 0;
}
else if ((buffer[0] & 0x0f) == 0x02)
{
return (buffer[0] & 0x0f) == 0x02; /* only bit 1 is set */
}
else
return 0;
//--------------------------------End of my "solution"---------------------------------
case MQTT_MSG_TYPE_PUBREL: //0x60
case MQTT_MSG_TYPE_SUBSCRIBE: //0x80
case MQTT_MSG_TYPE_UNSUBSCRIBE: //0xA0
return (buffer[0] & 0x0f) == 0x02; /* only bit 1 is set */
case MQTT_MSG_TYPE_PUBLISH: //0x30
qos = mqtt_get_qos(buffer);
dup = mqtt_get_dup(buffer);
/*
* there is no qos=3 [MQTT-3.3.1-4]
* dup flag must be set to 0 for all qos=0 messages [MQTT-3.3.1-2]
*/
return (qos < 3) && ((qos > 0) || (dup == 0));
default:
return 0;
}
}
Basically what i did is adding the headers that i receive (assuming they are correct) and filtered them as correct.
Now the problem is that the message is not published, it's supposed that it passes the headers problem but looks like is not working the publish function itself.
PS: In order to check the headers i changed the code from $HOME/esp/esp-idf/components/mqtt/esp-mqtt/mqtt_client.c in the function static int
mqtt_message_receive(esp_mqtt_client_handle_t client, int read_poll_timeout_ms) and added this lines:
Code: Select all
/*
* Verify the flags and act according to MQTT protocol: close connection
* if the flags are set incorrectly.
*/
ESP_LOGE(TAG, "buf=0x%x y buf_type = 0x%x", *buf, mqtt_get_type(buf));
if (!mqtt_has_valid_msg_hdr(buf, read_len)) {
ESP_LOGE(TAG, "%s: received a message with an invalid header=0x%x", __func__, *buf);
goto err;
}
I hope someone comes with an idea of how to fix this problem of publish in Thingsboard