espidf/spsp/mqtt_adapter.hpp

Go to the documentation of this file.

 
#pragma once
 
#include "mqtt_client.h"
 
#include "spsp/mqtt_adapter_if.hpp"
#include "spsp/mqtt_types.hpp"
 
namespace SPSP::FarLayers::MQTT
{
    class Adapter : public IAdapter
    {
        esp_mqtt_client_handle_t m_mqtt;             
        Config m_conf;                               
        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:
        inline static const char* stringToCOrNull(const std::string& str)
        {
            return str.empty() ? nullptr : str.c_str();
        }
    };
} // namespace SPSP::FarLayers::MQTT