tests [excluded]

Author: iceseer

tests/CMakeLists.txt

@@ -4,4 +4,9 @@
 # SPDX-License-Identifier: Apache-2.0
 #
 
-message(STATUS "There are no tests yet")
+include_directories(
+    ${CMAKE_CURRENT_SOURCE_DIR}
+    ${PROJECT_SOURCE_DIR}/src
+    )
+
+# add_subdirectory(utils)

tests/utils/CMakeLists.txt

@@ -0,0 +1,13 @@
+#
+# Copyright Quadrivium LLC
+# All Rights Reserved
+# SPDX-License-Identifier: Apache-2.0
+#
+
+# addtest(utils_test
+#     channel.cpp
+#     )
+
+# target_link_libraries(utils_test
+    
+#     )

tests/utils/channel.cpp

@@ -0,0 +1,70 @@
+#include <gtest/gtest.h>
+#include <optional>
+#include <thread>
+#include <chrono>
+#include "utils/channel.hpp"
+
+using namespace std::chrono_literals;
+
+TEST(ChannelTest, SendAndReceiveValue) {
+  auto [recv, send] = Channel<int>::create_channel<int>();
+
+  send.set(42);
+  auto value = recv.wait();
+
+  ASSERT_TRUE(value.has_value());
+  EXPECT_EQ(value.value(), 42);
+}
+
+TEST(ChannelTest, SendLValue) {
+  auto [recv, send] = Channel<int>::create_channel<int>();
+
+  int x = 123;
+  send.set(x);
+  auto value = recv.wait();
+
+  ASSERT_TRUE(value.has_value());
+  EXPECT_EQ(value.value(), 123);
+}
+
+TEST(ChannelTest, SenderDestructionNotifiesReceiver) {
+  std::optional<Channel<int>::Receiver> recv;
+  std::optional<Channel<int>::Sender> send;
+
+  std::tie(recv, send) = Channel<int>::create_channel<int>();
+
+  std::optional<int> result;
+
+  std::thread t([&]() {
+    result = recv->wait();
+  });
+
+  std::this_thread::sleep_for(50ms);
+  send.reset();
+
+  t.join();
+
+  EXPECT_FALSE(result.has_value());
+}
+
+TEST(ChannelTest, MultipleSendKeepsOneValue) {
+  auto [recv, send] = Channel<int>::create_channel<int>();
+
+  send.set(1);
+  send.set(2);
+
+  auto value = recv.wait();
+  ASSERT_TRUE(value.has_value());
+  EXPECT_TRUE(value.value() == 1 || value.value() == 2);
+}
+
+TEST(ChannelTest, ReceiverDestructionUnregistersSender) {
+  std::optional<Channel<int>::Receiver> recv;
+  std::optional<Channel<int>::Sender> send;
+
+  std::tie(recv, send) = Channel<int>::create_channel<int>();
+
+  recv.reset();  
+
+  EXPECT_NO_THROW(send->set(999));
+}