command_holder.h

#ifndef RECODEX_BROKER_COMMANDS_BASE_H
#define RECODEX_BROKER_COMMANDS_BASE_H

#include "../helpers/logger.h"
#include "../notifier/empty_status_notifier.h"
#include "../notifier/status_notifier.h"
#include "../worker_registry.h"
#include "handler_interface.h"
#include "message_container.h"
#include <functional>
#include <map>
#include <memory>
#include <string>


class command_holder
{
public:
    typedef std::function<void(const std::string &, const std::vector<std::string> &, handler_interface::response_cb)>
        callback_fn;

    void call_function(const std::string &command,
        const std::string &identity,
        const std::vector<std::string> &message,
        handler_interface::response_cb respond);

    bool register_command(const std::string &command, callback_fn callback);

private:
    std::map<std::string, callback_fn> functions_;
};

#endif // RECODEX_BROKER_COMMANDS_BASE_H