testJson.cpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_common_libdpm
 * @copyright (c) Copyright ESO 2022
 * All Rights Reserved
 * ESO (eso.org) is an Intergovernmental Organisation, and therefore special legal conditions apply.
 *
 * @brief Defines tests for JSON support
 */
#include <gtest/gtest.h>
 
#include <daq/json.hpp>
#include <daq/status.hpp>
 
namespace daq {
 
TEST(TestJson, SerializeStatus) {
    Status orig = {};
    orig.id = "ID";
    orig.state = State::Acquiring;
    orig.result = "file.fits";
    ReceiverStatus& receiver = orig.receivers[1];
    receiver.state = ReceiverStatus::State::Started;
 
    nlohmann::json j = orig;
    auto deserialized = j.get<Status>();
 
    EXPECT_EQ(orig, deserialized);
    EXPECT_EQ(orig.id, deserialized.id);
    EXPECT_EQ(orig.state, deserialized.state);
    EXPECT_EQ(orig.receivers, deserialized.receivers);
}
 
TEST(TestJson, DaqContext) {
    using namespace std::chrono_literals;
    DaqContext ctx;
    ctx.id = "ID";
    ctx.await_interval = 5s;
    ctx.file_id = "FILE_ID";
    ctx.keywords.push_back(fits::ValueKeyword("FOO", "BAR"));
    ctx.dp_name_prefix = "FOO";
    ctx.meta_sources.push_back({"NAME", "URI"});
 
    nlohmann::json j = ctx;
    auto deserialized = j.get<DaqContext>();
 
    EXPECT_TRUE(ctx == deserialized);
    EXPECT_EQ(ctx.id, deserialized.id);
    EXPECT_EQ(ctx.await_interval, deserialized.await_interval);
}
 
TEST(TestJson, DaqContextWithSpecification) {
    using namespace std::chrono_literals;
    DaqContext ctx;
    ctx.id = "ID";
    ctx.await_interval = 5s;
    ctx.file_id = "FILE_ID";
    ctx.keywords.push_back(fits::ValueKeyword("FOO", "BAR"));
    ctx.dp_name_prefix = "FOO";
    ctx.meta_sources.push_back({"NAME", "URI"});
    auto& spec = ctx.specification.emplace();
    spec.file_prefix = "FOO";
    auto ds1 = json::StartDaqV2Spec::PrimaryDataSource{};
    ds1.rr_uri = "uri";
    ds1.source_name = "prim";
    auto ds2 = json::StartDaqV2Spec::MetadataSource{};
    ds2.rr_uri = "uri";
    ds2.source_name = "meta";
 
    spec.sources.push_back(ds1);
    spec.sources.push_back(ds2);
 
    nlohmann::json j = ctx;
    auto deserialized = j.get<DaqContext>();
 
    EXPECT_TRUE(ctx == deserialized);
    EXPECT_EQ(ctx.id, deserialized.id);
    EXPECT_EQ(ctx.await_interval, deserialized.await_interval);
    EXPECT_EQ(ctx.specification->file_prefix, deserialized.specification->file_prefix);
    ASSERT_EQ(ctx.specification->sources.size(), 2u);
    EXPECT_EQ(ctx.specification->sources[0], deserialized.specification->sources[0]);
    EXPECT_EQ(ctx.specification->sources[1], deserialized.specification->sources[1]);
}
 
}  // namespace daq