mqtt.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <future>
 
#include "spsp/layers.hpp"
#include "spsp/mqtt_adapter_if.hpp"
#include "spsp/mqtt_types.hpp"
#include "spsp/node.hpp"
 
namespace SPSP::FarLayers::MQTT
{
    class MQTT : public IFarLayer
    {
        Config m_conf;                           
        bool m_initializing = true;              
        std::promise<void> m_connectingPromise;  
        IAdapter& m_adapter;                     
 
    public:
        MQTT(IAdapter& adapter, const Config& conf);
 
        ~MQTT();
 
        bool publish(const std::string& src, const std::string& topic,
                     const std::string& payload);
 
        bool subscribe(const std::string& topic);
 
        bool unsubscribe(const std::string& topic);
 
    protected:
        void connectedCb();
 
        void subDataCb(const std::string& topic, const std::string& payload);
    };
} // namespace SPSP::FarLayers::MQTT