smRequestorRaw.hpp

Go to the documentation of this file.

#ifndef RAD_SM_REQUESTOR_RAW_HPP
#define RAD_SM_REQUESTOR_RAW_HPP

#include <rad/anyEvent.hpp>
#include <rad/msgHandler.hpp>
#include <rad/msgRequestorRaw.hpp>
#include <rad/smAdapter.hpp>

namespace rad {

class SMRequestorRaw {
   public:
    SMRequestorRaw(const std::string& endpoint, const std::string& identity,
                   boost::asio::io_service& ios, SMAdapter& sm, UniqueEvent&& ok_event,
                   UniqueEvent&& err_event, UniqueEvent&& timeout_event);
    virtual ~SMRequestorRaw();

    size_t Send(const std::string& payload_type, const std::string& payload,
                const long timeout = 0);

    void ReplyHandler(const std::error_code& err_code, const std::string& msg_type_id,
                      const void* data, const size_t data_size);

    const std::string& GetReplyPayloadType();
    const std::string& GetReplyPayload();

    SMRequestorRaw(const SMRequestorRaw&) = delete;
    SMRequestorRaw& operator=(const SMRequestorRaw&) = delete;

   private:
    MsgRequestorRaw m_msg_requestor_raw;
    SMAdapter& m_sm;
    UniqueEvent m_ok_event;
    UniqueEvent m_err_event;
    UniqueEvent m_timeout_event;
    std::string m_reply_payload_type;
    std::string m_reply_payload;
};

}  // namespace rad

#endif  // RAD_SM_REQUESTOR_RAW_HPP