ConnectinoMqtt.h

#ifndef ConnectinoMqtt_h
#define ConnectinoMqtt_h

#include "ConnectinoModule.h"
#include "StxHwSerial.h"

class ConnectinoMqtt : public ConnectinoModule
{
    public:
        ConnectinoMqtt(StxHwSerial &refSerial);

        bool moduleCallback(uint8_t subId, uint8_t reqId, uint16_t dataSize, uint8_t *data);

        uint8_t getModId();

        bool setSessionConfiguration(const char server[], uint16_t port, const char resource[] = "", const char clientId[] = "",
                               const char userName[] = "", const char password[] = "", uint8_t connectionType = 0, bool cleanSession = true,
                               uint16_t keepaliveInterval = 60);

        void setWill(const char topic[], const char payload[], const bool retain = false, const uint8_t QoS = 0);

        void setWill(const char topic[], const uint8_t payload[], const uint8_t payloadSize, const bool retain = false, const uint8_t QoS = 0);

        bool publish(const char topic[], const char payload[], const bool retain = false, const uint8_t QoS = 0);

        bool publish(const char topic[], const uint8_t payload[], const uint16_t payloadSize, const bool retain = false, const uint8_t QoS = 0);

        void subscribe(const char topic[], const uint8_t QoS = 0);

        bool isDataAvailable(const char * topic = NULL);

        bool getData(char * payloadBuffer, uint16_t &payloadBufferSize, char * topicBuffer = NULL, uint16_t topicBufferSize = 0);

        bool getData(uint8_t * payloadBuffer, uint16_t &payloadBufferSize, char * topicBuffer = NULL, uint16_t topicBufferSize = 0);

        bool isConnected();

        void setState(bool state);

    private:
        bool parseData(uint8_t ** topic, uint8_t * topicSize, uint8_t ** payload = NULL, uint16_t * payloadSize = NULL);

        StxHwSerial &StxSerial; 
        volatile bool setSessionConfiguration_done = false; 
        volatile bool setWill_done = false; 
        volatile bool subscribe_done = false; 
        volatile bool subscribed = false; 
        volatile bool connected = false; 
        volatile bool setState_done = false; 
        volatile bool dataAvailable = false; 
};

#endif