reactor_status_notifier.h

#ifndef RECODEX_BROKER_REACTOR_STATUS_NOTIFIER_H
#define RECODEX_BROKER_REACTOR_STATUS_NOTIFIER_H

#include "../config/notifier_config.h"
#include "../helpers/curl.h"
#include "../reactor/handler_interface.h"
#include "status_notifier.h"
#include <spdlog/logger.h>

class reactor_status_notifier : public status_notifier_interface
{
private:
    handler_interface::response_cb callback_;

    const std::string key_;

public:
    reactor_status_notifier(handler_interface::response_cb callback, const std::string &key);

    virtual void error(const std::string &desc);
    virtual void rejected_job(const std::string &job_id, const std::string &desc = "");
    virtual void rejected_jobs(std::vector<std::string> job_ids, const std::string &desc = "");
    virtual void job_done(const std::string &job_id);
    virtual void job_failed(const std::string &job_id, const std::string &desc = "");
};

#endif // RECODEX_BROKER_REACTOR_STATUS_NOTIFIER_H