CMqttAdapter.hpp

Go to the documentation of this file.

#ifndef C_MQTT_ADAPTER_HPP
#define C_MQTT_ADAPTER_HPP

#include "IAdapter.hpp"
#include "CMqttMessage.hpp"

#include <map>
#include <list>
#include <string>

#include <MQTTClient.h>
#include <boost/thread.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/property_tree/ptree.hpp>
#include <boost/enable_shared_from_this.hpp>

namespace freedm {
namespace broker {
namespace device {

class CMqttAdapter
    : public IAdapter
    , public boost::enable_shared_from_this<CMqttAdapter>
{
public:
    typedef boost::shared_ptr<CMqttAdapter> Pointer;

    static IAdapter::Pointer Create(std::string id, std::string address);

    void Start();

    void Stop();

    SignalValue GetState(const std::string device, const std::string key) const;

    void SetCommand(const std::string device, const std::string key, const SignalValue value);

    ~CMqttAdapter();

private:
    struct DeviceData
    {
        std::map<std::string, SignalValue> s_SignalToValue;
        std::map<std::string, std::string> s_IndexReference;
    };

    CMqttAdapter(std::string id, std::string address);

    static void ConnectionLost(void * id, char * reason);

    static int HandleMessage(void * id, char * topic, int topicLen, MQTTClient_message * msg);

    static void DeliveryComplete(void * id, MQTTClient_deliveryToken token);

    void HandleMessage(std::string topic, std::string message);
    
    void Publish(std::string topic, std::string content);

    void SubscribeAll(std::string deviceName);

    void UnsubscribeAll(std::string deviceName);

    void CreateDevice(std::string deviceName, std::string json);

    void AddSignals(std::string device, boost::property_tree::ptree::value_type & ptree, std::set<std::string> & sigset, std::set<std::string> & type);

    typedef std::map<std::string, DeviceData> TDeviceToData;

    TDeviceToData m_DeviceData;

    std::list<CMqttMessage::Pointer> m_MessageQueue;

    mutable boost::mutex m_DeviceDataLock;

    MQTTClient m_Client;
    MQTTClient_message pubmsg;
    MQTTClient_deliveryToken token;

    char m_ID[24];
};

} //namespace device
} //namespace broker
} //namespace freedm

#endif // C_MQTT_ADAPTER_HPP