linux/spsp/mqtt_adapter.hpp

Go to the documentation of this file.

 
#pragma once
 
#include "MQTTAsync.h"
 
#include "spsp/mqtt_adapter_if.hpp"
#include "spsp/mqtt_types.hpp"
 
namespace SPSP::FarLayers::MQTT
{
    class Adapter : public IAdapter
    {
        Config m_conf;                               
        MQTTAsync m_mqtt;                            
        AdapterSubDataCb m_subDataCb = nullptr;      
        AdapterConnectedCb m_connectedCb = nullptr;  
 
    public:
        Adapter(const Config& conf);
 
        ~Adapter();
 
        bool publish(const std::string& topic, const std::string& payload);
 
        bool subscribe(const std::string& topic);
 
        bool unsubscribe(const std::string& topic);
 
        void setSubDataCb(AdapterSubDataCb cb);
 
        AdapterSubDataCb getSubDataCb() const;
 
        void setConnectedCb(AdapterConnectedCb cb);
 
        AdapterConnectedCb getConnectedCb() const;
 
    protected:
        bool connect();
 
        static void connectedCb(void* ctx, char* cause);
 
        static void connFailureCb(void* ctx, MQTTAsync_failureData* resp);
 
        static void connLostCb(void* ctx, char* cause);
 
        static int subMsgCb(void* ctx, char* topic, int topicLen,
                            MQTTAsync_message* msg);
 
        inline static const char* stringToCOrNull(const std::string& str)
        {
            return str.empty() ? nullptr : str.c_str();
        }
    };
} // namespace SPSP::FarLayers::MQTT