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 */