msgHandler.hpp

Go to the documentation of this file.

 
#ifndef RAD_MSG_HANDLER_HPP
#define RAD_MSG_HANDLER_HPP
 
#include <rad/exceptions.hpp>
 
#include <memory>
#include <string>
#include <unordered_map>
 
namespace rad {
 
class MsgHandler {
   public:
    virtual ~MsgHandler() {}
    virtual void Handle(const std::string& identity, const std::string& msg_type_id,
                        const void* data, size_t data_size) = 0;
};
 
template <typename EventType>
EventType ParseRequestAndCreateEvent(const std::string& identity, const std::string& request_name,
                                     const void* msg, size_t msg_size) {
    // Check that requestId matches the event)
#if 0
    if (strcmp(request_name.c_str(), EventType::id) != 0) {
        throw rad::Exception("Error request_name <" + request_name +
                "> payload type, does not match eventId <" + EventType::id + ">.");
    }
#endif
 
    // EventType = rad::MsgRequest<ProtoBuf_Type>
    // msg_payload_t = ProtoBuf_Type
    using msg_payload_t = typename EventType::payload_t::payload_t;
    msg_payload_t req_payload;
 
    if (req_payload.ParseFromArray(msg, msg_size) == false) {
        throw rad::Exception("Error parsing <" + request_name + "> payload.");
    }
 
    return EventType(identity.c_str(), req_payload);
}
 
}  // namespace rad
 
#endif /* #ifndef RAD_MSG_HANDLER_HPP */