orchestrator.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <arkanjo/base/function.hpp>
#include <arkanjo/base/path.hpp>
 
#include <arkanjo/base/similarity_table.hpp>
#include <arkanjo/utils/utils.hpp>
 
#include <arkanjo/cli/parser_options.hpp>
 
struct Context {
    std::string command_name;
    ParsedOptions options;
    std::vector<std::string> extra_args;
 
    int argc;
    char** argv;
};
 
using Step = std::function<bool(Context&)>;
class Orchestrator {
  private:
    std::vector<Step> steps;
    size_t current_step = 0;
 
  public:
    void add_step(Step step) { steps.push_back(step); }
 
    void skip() {
        current_step = steps.size();
    }
 
    void run_pipeline(Context& ctx) {
        for (current_step = 0; current_step < steps.size(); ++current_step) {
            if (!steps[current_step] || !steps[current_step](ctx)) {
                std::cerr << "Pipeline aborted (" << current_step << ")\n";
                break;
            }
        }
    }
};