daqContext.cpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_common_libdaq
 * @copyright 2022 ESO - European Southern Observatory
 *
 * @brief Contains definition of `daq::Context` helpers.
 */
#include <daq/daqContext.hpp>
 
namespace daq {
 
bool operator==(DaqContext const& lhs, DaqContext const& rhs) noexcept {
    return lhs.id == rhs.id && lhs.file_id == rhs.file_id &&
           lhs.await_interval == rhs.await_interval && lhs.dp_name_prefix == rhs.dp_name_prefix &&
           lhs.process_name == rhs.process_name && lhs.keywords == rhs.keywords &&
           lhs.meta_sources == rhs.meta_sources && lhs.prim_sources == rhs.prim_sources &&
           lhs.results == rhs.results && lhs.specification == rhs.specification;
}
 
bool operator==(DaqContext::Source const& lhs, DaqContext::Source const& rhs) noexcept {
    return lhs.name == rhs.name && lhs.rr_uri == rhs.rr_uri;
}
 
void UpdateKeywords(fits::KeywordVector& out,
                    fits::KeywordVector const& in,
                    fits::KeywordFormatter const& fmt) {
    if (in.empty()) {
        return;
    }
    fits::KeywordVector reformatted;
    reformatted.reserve(in.size());
 
    std::transform(
        in.begin(), in.end(), std::back_inserter(reformatted), [&](fits::KeywordVariant const& kw) {
            return fmt.Format(kw);
        });
 
    fits::UpdateKeywords(out, reformatted);
}
 
void UpdateKeywords(DaqContext& ctx,
                    fits::KeywordVector const& keywords,
                    fits::KeywordFormatter const& fmt) {
    UpdateKeywords(ctx.keywords, keywords, fmt);
}
 
void AddDpParts(DaqContext& ctx, std::vector<DpPart> const& parts) {
    using std::copy;
    copy(parts.begin(), parts.end(), std::back_inserter(ctx.results));
}
 
}  // namespace daq