sourceResolver.cpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_dpm_libmerge
 * @copyright (c) Copyright ESO 2022
 * All Rights Reserved
 * ESO (eso.org) is an Intergovernmental Organisation, and therefore special legal conditions apply.
 *
 * @brief Defines daq::dpm::SourceResolver.
 */
#include <daq/dpm/sourceResolver.hpp>
 
#include <fmt/format.h>
#include <fmt/ostream.h>
 
namespace daq::dpm {
 
std::ostream& operator<<(std::ostream& os, SourceResolver::SourceFile const& source) {
    os << "source name: \"" << source.source_name << "\", origin: \"" << source.origin << '"';
    return os;
}
 
SourceResolver::SourceResolver(Mapping mapping) : m_mapping(std::move(mapping)) {
}
 
void SourceResolver::Add(SourceResolver::SourceFile const& source,
                         std::filesystem::path const& path) {
    m_mapping[source] = path.native();
}
 
auto SourceResolver::Resolve(SourceResolver::SourceFile const& source) const
    -> std::filesystem::path {
    auto it = m_mapping.find(source);
    if (it == m_mapping.end()) {
        throw SourceNotFound(
            fmt::format("Could not resolve local filename for source: '{}' and origin: '{}'",
                        source.source_name,
                        source.origin));
    }
    return std::filesystem::path(it->second);
}
 
auto SourceResolver::GetMapping() const noexcept -> Mapping const& {
    return m_mapping;
}
 
void SourceResolver::SetMapping(Mapping mapping) noexcept {
    m_mapping.swap(mapping);
}
 
// NOLINTNEXTLINE
 
// NOLINTNEXTLINE
void to_json(nlohmann::json& j, SourceResolver::Mapping const& p) {
    j = nlohmann::json::array();
    for (auto const& s : p) {
        j.emplace_back(nlohmann::json{
                {"sourceName", s.first.source_name},
                {"origin", s.first.origin},
                {"localPath", s.second}});
    }
}
// NOLINTNEXTLINE
void from_json(nlohmann::json const& j, SourceResolver::Mapping& p) {
    p.clear();
    for (auto const& s : j) {
        p.emplace(SourceResolver::SourceFile{s["sourceName"], s["origin"]}, s["localPath"]);
    }
}
 
}  // namespace daq::dpm