ActionDispatcher.h

Go to the documentation of this file.

 
// ###########################################################################################################################################################################################################################################################################################################################
 
#pragma once
 
// OpenTwin header
#include "OTCore/JSON.h"
#include "OTCore/OTClassHelper.h"
#include "OTCommunication/CommunicationTypes.h"
#include "OTCommunication/CommunicationAPIExport.h"
 
// std header
#include <string>
#include <map>
#include <list>
#include <mutex>
 
#pragma warning(disable : 4251)
 
namespace ot {
 
    class ActionHandleConnectorBase;
 
    class OT_COMMUNICATION_API_EXPORT ActionDispatcher {
        OT_DECL_NOCOPY(ActionDispatcher)
    public:
        static ActionDispatcher& instance(void);
 
        void add(ActionHandleConnectorBase* _handler, bool _overwrite = false);
        void remove(ActionHandleConnectorBase* _handler);
 
        char* dispatchWrapper(const char* _json, const char* _senderUrl, ot::MessageType _messageType);
 
        std::string dispatch(const std::string& _json, ot::MessageType _messageType);
 
        std::string dispatch(JsonDocument& _document, MessageType _messageType);
 
        std::string dispatch(const std::string& _action, JsonDocument& _document, ot::MessageType _messageType);
 
        std::string dispatch(const std::string& _action, JsonDocument& _document, bool& _handlerFound, ot::MessageType _messageType);
 
        std::string dispatchLocked(const std::string& _action, JsonDocument& _document, bool& _handlerFound, ot::MessageType _messageType);
 
    private:
 
        std::map<std::string, ActionHandleConnectorBase*> m_data;
        std::mutex                                        m_mutex;
 
        ActionDispatcher();
        virtual ~ActionDispatcher();
    };
}