topicHandler.hpp

Go to the documentation of this file.

#ifndef RAD_TOPIC_HANDLER_HPP
#define RAD_TOPIC_HANDLER_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& topic_type_id, const void* data, size_t data_size) = 0;
};

template <typename EventType>
EventType ParseTopicAndCreateEvent(const std::string& topic_name, const void* msg,
                                   size_t msg_size) {
    typename EventType::payload_t topic_payload;
    if (topic_payload.ParseFromArray(msg, msg_size) == false) {
        throw rad::Exception("Error parsing <" + topic_name + "> payload.");
    }
    return EventType(topic_payload);
}

}  // namespace rad

#endif /* #ifndef RAD_TOPIC_HANDLER_HPP */