broker_core.h

#ifndef RECODEX_BROKER_CORE_H
#define RECODEX_BROKER_CORE_H

#include "spdlog/spdlog.h"
#include <curl/curl.h>
#include <functional>
#include <iostream>
#include <memory>
#include <thread>
#include <vector>
#include <yaml-cpp/yaml.h>

#define BOOST_FILESYSTEM_NO_DEPRECATED
#define BOOST_NO_CXX11_SCOPED_ENUMS
#include <boost/filesystem.hpp>
#include <boost/program_options.hpp>
namespace fs = boost::filesystem;


// Our very own code includes
#include "broker_connect.h"
#include "config/broker_config.h"
#include "config/log_config.h"
#include "notifier/http_status_notifier.h"
#include "reactor/command_holder.h"


class broker_core
{
public:
    broker_core() = delete;

    broker_core(const broker_core &source) = delete;

    broker_core &operator=(const broker_core &source) = delete;

    broker_core(const broker_core &&source) = delete;

    broker_core &operator=(const broker_core &&source) = delete;

    broker_core(std::vector<std::string> args);

    ~broker_core();

    void run();

private:
    void log_init();

    void broker_init();

    void curl_init();

    void curl_fini();

    void force_exit(std::string msg = "");

    void parse_params();

    void load_config();

    // PRIVATE DATA MEMBERS
    std::vector<std::string> args_;

    std::string config_filename_;

    std::shared_ptr<broker_config> config_;

    std::shared_ptr<spdlog::logger> logger_;

    std::shared_ptr<worker_registry> workers_;

    std::shared_ptr<zmq::context_t> context_;

    std::shared_ptr<broker_connect> broker_;
};

#endif // RECODEX_BROKER_CORE_H