MsgHandler.hpp

Go to the documentation of this file.

#ifndef RAD_MSG_HANDLER_HPP
#define RAD_MSG_HANDLER_HPP

#include <rad/Logger.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& msgTypeId,
                        const void* pData,
                        size_t dataSize) = 0;
};

template<typename EventType>
EventType ParseRequestAndCreateEvent(const std::string& identity, const std::string& requestName, const void* pMsg, size_t msgSize)
{
    RAD_LOG_TRACE();

    // Check that requestId matches the event)
#if 0
    if (strcmp(requestName.c_str(), EventType::id) != 0) {
        std::string errMsg("Error requestName <" + requestName +
                           "> payload type, does not match eventId <" + EventType::id + ">.");
        RAD_LOG_ERROR() << errMsg;
        throw rad::Exception(errMsg);
    }
#endif

    // EventType = rad::MsgRequest<ProtoBuf_Type>
    // msg_payload_t = ProtoBuf_Type
    using msg_payload_t = typename EventType::payload_t::payload_t;
    msg_payload_t reqPayload;

    if (reqPayload.ParseFromArray(pMsg, msgSize) == false) {
        std::string errMsg("Error parsing <" + requestName + "> payload.");
        RAD_LOG_ERROR() << errMsg;
        throw rad::Exception(errMsg);
    }

    return EventType(identity.c_str(), reqPayload);
}




} // namespace rad

#endif /* #ifndef RAD_MSG_HANDLER_HPP */