TopicHandler.hpp

Go to the documentation of this file.

#ifndef RAD_TOPIC_HANDLER_HPP
#define RAD_TOPIC_HANDLER_HPP

#include <rad/Logger.hpp>
#include <rad/Exceptions.hpp>

#include <memory>
#include <string>
#include <unordered_map>

namespace rad {

class TopicHandler {
public:
    virtual ~TopicHandler() {}
    virtual void handle(const std::string& topicTypeId,
                        const void* pData,
                        size_t dataSize) = 0;
};


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

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

    typename EventType::payload_t topicPayload;

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

    return EventType(topicPayload);
}

} // namespace rad

#endif /* #ifndef RAD_TOPIC_HANDLER_HPP */