CAdapterFactory.hpp

Go to the documentation of this file.

#ifndef C_ADAPTER_FACTORY_HPP
#define C_ADAPTER_FACTORY_HPP

#include "IAdapter.hpp"
#include "CTcpServer.hpp"
#include "CDeviceBuilder.hpp"

#include <map>
#include <set>
#include <string>
#include <iostream>
#include <stdexcept>

#include <boost/thread.hpp>
#include <boost/noncopyable.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/io_service.hpp>
#include <boost/asio/deadline_timer.hpp>
#include <boost/property_tree/ptree_fwd.hpp>

namespace freedm {
namespace broker {
namespace device {

class CAdapterFactory
    : private boost::noncopyable
{
public:
    static CAdapterFactory & Instance();

    void StartSessionProtocol(unsigned short port);

    void CreateAdapter(const boost::property_tree::ptree & p);

    void RemoveAdapter(const std::string identifier);

    void Stop();
private:
    CAdapterFactory();

    void RunService();

    void CreateDevice(const std::string name, const std::string type,
            IAdapter::Pointer adapter);

    void InitializeAdapter(IAdapter::Pointer adapter,
            const boost::property_tree::ptree & p);

    void SessionProtocol();

    void StartSession();

    void HandleRead(const boost::system::error_code & e);

    void Timeout(const boost::system::error_code & e);

    std::map<std::string, IAdapter::Pointer> m_adapters;

    boost::asio::io_service m_ios;

    CTcpServer::Pointer m_server;

    boost::thread m_thread;

    boost::asio::streambuf m_buffer;

    boost::asio::deadline_timer m_timeout;

    CDeviceBuilder m_builder;

    friend class CMqttAdapter;
};

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

#endif // C_ADAPTER_FACTORY_HPP