MqttPayloadParser.h

Go to the documentation of this file.

/****
 * Sming Framework Project - Open Source framework for high efficiency native ESP8266 development.
 * Created 2015 by Skurydin Alexey
 * http://github.com/SmingHub/Sming
 * All files of the Sming Core are provided under the LGPL v3 license.
 *
 * MqttPayloadParser.h
 *
 * @author Slavey Karadzhov <slaff@attachix.com>
 *
 ****/
 
#pragma once
 
#include <esp_systemapi.h>
#include "mqtt-codec/src/message.h"
 
#define MQTT_PAYLOAD_PARSER_START -1
#define MQTT_PAYLOAD_PARSER_END -2
 
#define MQTT_PAYLOAD_LENGTH 1024
 
struct MqttPayloadParserState {
    void* userData; 
    size_t offset;  
};
 
using MqttPayloadParser =
    Delegate<int(MqttPayloadParserState& state, mqtt_message_t* message, const char* buffer, int length)>;
 
int defaultPayloadParser(MqttPayloadParserState& state, mqtt_message_t* message, const char* buffer, int length);