diff --git a/CMakeLists.txt b/CMakeLists.txt index 273cfe9..a839860 100644 --- a/CMakeLists.txt +++ b/CMakeLists.txt @@ -99,4 +99,16 @@ add_executable(wctest src/main.cpp) target_link_libraries(wctest whisperCom) add_executable(wcListener src/Listener.cpp) -target_link_libraries(wcListener whisperCom) \ No newline at end of file +target_link_libraries(wcListener whisperCom) + + +# +# Everything TEST related +# +IF (${TEST_WHISPERCOM}) + +add_executable(test_Service tests/test_Service.cpp) +target_link_libraries(test_Service Catch2::Catch2WithMain whisperCom loguru) +catch_discover_tests(test_Service) + +ENDIF() \ No newline at end of file diff --git a/tests/test_Service.cpp b/tests/test_Service.cpp new file mode 100644 index 0000000..4b37072 --- /dev/null +++ b/tests/test_Service.cpp @@ -0,0 +1,66 @@ +/* +* This Source Code Form is subject to the terms of the Mozilla Public +* License, v. 2.0. If a copy of the MPL was not distributed with this +* file, You can obtain one at https://mozilla.org/MPL/2.0/. +*/ + +/** +* @file +* @copyright 2023 MPLv2 +*/ + +/** + * \defgroup xy test + * + * These scenarios test xy + */ + +#define CATCH_CONFIG_MAIN + +#include + +#include +#include +#include + +/** +* \brief Verify functional correctness of the class WhisperCom::Service. +* \ingroup class_test +* +*/ +SCENARIO("Constructing two services that send and receive messages.","[Service]") +{ + using namespace std::chrono_literals; + GIVEN("Two services, one for sending and one for receiving messages.") + { + std::string testTopic = "testTopic"; + + std::shared_ptr serviceSource = nullptr; + REQUIRE_NOTHROW( serviceSource = std::make_shared() ); + REQUIRE( serviceSource != nullptr ); + serviceSource->subscribe( testTopic ); + + std::shared_ptr serviceSink = nullptr; + REQUIRE_NOTHROW( serviceSink = std::make_shared() ); + REQUIRE( serviceSink != nullptr ); + serviceSink->subscribe( testTopic ); + + WHEN("Sending a message") + { + WhisperCom::Protobuf::TestMessage msg; + msg.set_str( "Hello World" ); + WhisperCom::Protobuf::Message wmsg{}; + wmsg.mutable_payload()->PackFrom( msg ); + serviceSource->sendMessage( "test", wmsg ); + std::this_thread::sleep_for( 400ms ); + + THEN("The sink service should receive the message") + { + CHECK( serviceSink->hasMessages() ); + } //THEN + } // WHEN + + serviceSource->stop(); + serviceSink->stop(); + } // GIVEN +} //SCENARIO