testReceivers.cpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_libjson
 * @copyright
 * (c) Copyright ESO 2023
 * All Rights Reserved
 * ESO (eso.org) is an Intergovernmental Organisation, and therefore special legal conditions apply.
 */
#include <gmock/gmock.h>
#include <gtest/gtest.h>
 
#include <daq/json/commonSpecTypes.hpp>
 
using namespace testing;
 
namespace daq::json {
using Json = nlohmann::json;
using JsonPointer = nlohmann::json_pointer<Json>;
 
TEST(TestParseReceivers, EmptyReceiverList) {
    using namespace nlohmann;
    auto j = R"(
    [
    ]
    )"_json;
    ReceiverList l = ParseReceiverList(j, JsonPointer("/"));
    ASSERT_EQ(l.size(), 0u);
}
 
TEST(TestParseReceivers, ValidReceiverList) {
    using namespace nlohmann;
    auto j = R"(
    [
      {
        "type": "olasReceiver",
        "host": "1.2.3.4",
        "path": "/path/to/incoming"
      }
    ]
    )"_json;
    ReceiverList l = ParseReceiverList(j, JsonPointer("/"));
    ASSERT_EQ(l.size(), 1u);
    ASSERT_TRUE(std::holds_alternative<OlasReceiver>(l[0]));
    auto const& r = std::get<OlasReceiver>(l[0]);
    EXPECT_EQ(r.host, "1.2.3.4");
    EXPECT_EQ(r.path, "/path/to/incoming/");
}
 
TEST(TestParseOlasReceiver, ValidOlasReceiverWithoutHost) {
    using namespace nlohmann;
    auto j = R"(
      {
        "type": "olasReceiver",
        "path": "/path/to/incoming"
      }
    )"_json;
    OlasReceiver r = ParseOlasReceiver(j, JsonPointer("/"));
    EXPECT_EQ(r.host, "");
    EXPECT_EQ(r.path, "/path/to/incoming/");
}
 
TEST(TestParseOlasReceiver, ValidOlasReceiverWithOptions) {
    using namespace nlohmann;
    auto j = R"(
      {
        "type": "olasReceiver",
        "path": "/path/to/incoming",
        "options": {
          "allowSymlink": false
        }
      }
    )"_json;
    OlasReceiver r = ParseOlasReceiver(j, JsonPointer("/"));
    EXPECT_EQ(r.host, "");
    EXPECT_EQ(r.path, "/path/to/incoming/");
    EXPECT_FALSE(r.options.allow_symlink);
}
 
 
TEST(TestParseOlasReceiver, MissingPathIsRejected) {
    using namespace nlohmann;
    auto j = R"(
      {
        "type": "olasReceiver",
        "path": ""
      }
    )"_json;
    EXPECT_THROW(ParseOlasReceiver(j, JsonPointer("/")), SchemaError);
}
 
TEST(TestParseOlasReceiver, RelativePathsShouldBeRejected) {
    using namespace nlohmann;
    auto j = R"(
      {
        "type": "olasReceiver",
        "path": "relative/path/to/incoming"
      }
    )"_json;
    EXPECT_THROW(ParseOlasReceiver(j, JsonPointer("/")), SchemaError);
}
 
TEST(TestRoundTripParsing, ReceiverList) {
    using namespace nlohmann;
    auto in = R"(
    [
      {
        "type": "olasReceiver",
        "host": "1.2.3.4",
        "path": "/path/to/incoming/",
        "options": {
          "noSymlink": true
        }
      }
    ]
    )"_json;
    ReceiverList l1 = ParseReceiverList(in, JsonPointer("/"));
    ASSERT_EQ(l1.size(), 1u);
 
    Json out;
    to_json(out, l1);
    ReceiverList l2 = ParseReceiverList(in, JsonPointer("/"));
    EXPECT_EQ(l1, l2);
}
 
} // namespace daq::json