dpyMwServer.h

Go to the documentation of this file.

#pragma once
#include <boost/shared_ptr.hpp>
#include <boost/asio.hpp>
#include <boost/make_shared.hpp>
#include <boost/any.hpp>
#include <boost/system/error_code.hpp>
#include <boost/function.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <boost/chrono.hpp>
#include <boost/asio/waitable_timer_service.hpp>
#include <boost/thread.hpp>

// The forward reference.
class DpyMwPublisher;
class DpyMwRouter;


typedef boost::function<void(const std::string&, const std::string&, int)> f_proto_message_server;

typedef std::map<uint64_t, f_proto_message_server> map_proto_register_server;

typedef boost::asio::basic_waitable_timer<boost::chrono::steady_clock> steady_timer; 

class DpyMwServer: public boost::enable_shared_from_this<DpyMwServer>
{

    struct Global_config
    {
        int time_count; 
        int period; 
        int response_type; 
    };

private:
    boost::asio::io_service publisherIo;

    bool m_working;
    steady_timer m_publisherTimer;
    steady_timer m_heartbeatTimer;
    int timerCounter;
    boost::shared_ptr<DpyMwPublisher> m_publisher;
    boost::shared_ptr<DpyMwRouter> m_router;
    int lastPublisherID = 0;
    std::map<int, Global_config> m_map_publishers;
    boost::thread bt;

protected:
    boost::asio::io_service& mIo;
    map_proto_register_server m_register_map;
    map_proto_register_server m_publisher_map;
    void sendResponse(int messageType, std::string content, const std::string& id_dealer, int msgId, boost::system::error_code &ec);
    void sendPublication(int messageType, std::string content, boost::system::error_code &ec);
    virtual void RegisterCallbacks()=0;
    virtual void RegisterPublications()=0;
    std::mutex m_map_mutex;

public:
    explicit DpyMwServer(boost::asio::io_service& io, int rport, int pport);
    virtual ~DpyMwServer();
    void start();
    void stop();
    void publish(int messageType, int frecuency);

private:
    void router_handler(const std::string &id, const std::string &payload);
    void publisherTimer_handler(const boost::system::error_code& e);
    void heartbeatTimer_handler(const boost::system::error_code& e);

};