TopicSubscriber.h

#pragma once

#include "ros_bridge/include/ComPrivateInclude.h"
#include "ros_bridge/include/RosBridgeClient.h"
#include "ros_bridge/include/TypeFactory.h"
#include "ros_bridge/include/CasePacker.h"

namespace ROSBridge {
namespace ComPrivate {

class TopicSubscriber
{
public:    
    typedef std::function<void(JsonDocUPtr)> CallbackType;
    typedef std::map<HashType, CallbackType> CallbackMap;

    TopicSubscriber() = delete;
    TopicSubscriber(CasePacker *casePacker, RosbridgeWsClient *rbc);

    void start();
    void stop();

    //! @return Returns false if a subscription to this topic allready exists.
    //!
    //! @note Only one callback can be registered.
    bool subscribe(const char* topic, const CallbackType &callback);

private:
    CasePacker         *_casePacker;
    RosbridgeWsClient  *_rbc;
    CallbackMap         _callbackMap;
};

void subscriberCallback(const HashType &hash,
                        const TopicSubscriber::CallbackMap &map,
                        std::shared_ptr<WsClient::Connection> /*connection*/,
                        std::shared_ptr<WsClient::InMessage> in_message);

}
}