stage_bridge.hpp

Go to the documentation of this file.

// SPDX-FileCopyrightText: 2026 Povl Filip Sonne-Frederiksen
//
// SPDX-License-Identifier: GPL-3.0-or-later
 
#pragma once
 
// Shared glue between the `rux create <stage>` subcommands and the library's
// pipeline::run_stage (#284).
//
// The stage bodies themselves live in libs/reusex/src/pipeline/stages.cpp and
// exist exactly once. What stays here is the part that is genuinely the CLI's
// job: turning parsed flags into a parameter blob, and turning the library's
// outcome back into a process exit code.
 
#include "../global-params.hpp"
 
#include <reusex/pipeline/stages.hpp>
 
#include <fmt/format.h>
#include <nlohmann/json.hpp>
 
#include <functional>
#include <string>
#include <string_view>
#include <type_traits>
 
namespace rux {

inline int exit_code_for(const reusex::pipeline::StageResult &result) {
  if (result.ok)
    return RuxError::SUCCESS;
  if (result.invalid_input)
    return RuxError::INVALID_ARGUMENT;
  return RuxError::GENERIC;
}

class StageParams {
  nlohmann::json object_ = nlohmann::json::object();
 
    public:
  template <typename T> StageParams &set(const char *key, const T &value) {
    if constexpr (std::is_floating_point_v<T>)
      object_[key] = nlohmann::json::parse(fmt::format("{}", value));
    else
      object_[key] = value;
    return *this;
  }

  template <typename T>
  StageParams &set_if(bool condition, const char *key, const T &value) {
    return condition ? set(key, value) : *this;
  }
 
  std::string dump() const { return object_.dump(); }
};

using StageParamsSink =
    std::function<void(std::string_view stage, const std::string &params)>;

void set_stage_params_sink(StageParamsSink sink);

bool capture_stage_params(std::string_view stage, const std::string &params);
 
} // namespace rux