From 403efa84859dc2f35847ce56b32ff7d3e42429d4 Mon Sep 17 00:00:00 2001
From: Mathias Kraus <mathias.kraus@apex.ai>
Date: Wed, 5 Jan 2022 20:46:24 +0100
Subject: [PATCH] iox-#989 Add tests for SubscriberOptions serialization

---
 .../test_popo_subscriber_options.cpp          | 79 +++++++++++++++++++
 1 file changed, 79 insertions(+)
 create mode 100644 iceoryx_posh/test/moduletests/test_popo_subscriber_options.cpp

diff --git a/iceoryx_posh/test/moduletests/test_popo_subscriber_options.cpp b/iceoryx_posh/test/moduletests/test_popo_subscriber_options.cpp
new file mode 100644
index 0000000000..a3f625227d
--- /dev/null
+++ b/iceoryx_posh/test/moduletests/test_popo_subscriber_options.cpp
@@ -0,0 +1,79 @@
+// Copyright (c) 2022 by Apex.AI Inc. All rights reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+// SPDX-License-Identifier: Apache-2.0
+
+#include "iceoryx_posh/popo/subscriber_options.hpp"
+
+#include "test.hpp"
+
+namespace
+{
+using namespace ::testing;
+
+TEST(SubscriberOptions_test, SerializationRoundTripIsSuccessful)
+{
+    iox::popo::SubscriberOptions defaultOptions;
+    iox::popo::SubscriberOptions testOptions;
+
+    testOptions.queueCapacity = 73;
+    testOptions.historyRequest = 42;
+    testOptions.nodeName = "hypnotoad";
+    testOptions.subscribeOnCreate = false;
+    testOptions.queueFullPolicy = iox::popo::QueueFullPolicy::BLOCK_PUBLISHER;
+
+    iox::popo::SubscriberOptions::deserialize(testOptions.serialize())
+        .and_then([&](auto& roundTripOptions) {
+            EXPECT_THAT(roundTripOptions.queueCapacity, Ne(defaultOptions.queueCapacity));
+            EXPECT_THAT(roundTripOptions.queueCapacity, Eq(testOptions.queueCapacity));
+
+            EXPECT_THAT(roundTripOptions.historyRequest, Ne(defaultOptions.historyRequest));
+            EXPECT_THAT(roundTripOptions.historyRequest, Eq(testOptions.historyRequest));
+
+            EXPECT_THAT(roundTripOptions.nodeName, Ne(defaultOptions.nodeName));
+            EXPECT_THAT(roundTripOptions.nodeName, Eq(testOptions.nodeName));
+
+            EXPECT_THAT(roundTripOptions.subscribeOnCreate, Ne(defaultOptions.subscribeOnCreate));
+            EXPECT_THAT(roundTripOptions.subscribeOnCreate, Eq(testOptions.subscribeOnCreate));
+
+            EXPECT_THAT(roundTripOptions.queueFullPolicy, Ne(defaultOptions.queueFullPolicy));
+            EXPECT_THAT(roundTripOptions.queueFullPolicy, Eq(testOptions.queueFullPolicy));
+        })
+        .or_else([&](auto&) { FAIL() << "Serialization/Deserialization of SubscriberOptions failed!"; });
+}
+
+TEST(SubscriberOptions_test, DeserializingBogusDataFails)
+{
+    const auto bogusSerialization = iox::cxx::Serialization::create("hypnotoad", "brain slug", "rock star");
+    iox::popo::SubscriberOptions::deserialize(bogusSerialization)
+        .and_then([&](auto&) { FAIL() << "Deserialization is expected to fail!"; })
+        .or_else([&](auto&) { SUCCEED(); });
+}
+
+TEST(SubscriberOptions_test, DeserializingInvalidQueueFullPolicyFails)
+{
+    constexpr uint64_t QUEUE_CAPACITY{73U};
+    constexpr uint64_t HISTORY_REQUEST{42U};
+    const iox::NodeName_t NODE_NAME{"harr-harr"};
+    constexpr bool SUBSCRIBE_ON_CREATE{true};
+    constexpr std::underlying_type_t<iox::popo::QueueFullPolicy> QUEUE_FULL_POLICY{111};
+
+    const auto serialized = iox::cxx::Serialization::create(
+        QUEUE_CAPACITY, HISTORY_REQUEST, NODE_NAME, SUBSCRIBE_ON_CREATE, QUEUE_FULL_POLICY);
+    iox::popo::SubscriberOptions::deserialize(serialized)
+        .and_then([&](auto&) { FAIL() << "Deserialization is expected to fail!"; })
+        .or_else([&](auto&) { SUCCEED(); });
+}
+
+} // namespace