test: test for data downloader event registration

Author: AndyTWF

include/ECFMP/event/Event.h

@@ -47,5 +47,7 @@ namespace ECFMP::Event {
          * Compares events.
          */
         [[nodiscard]] auto operator==(const class Event& event) const -> bool;
+
+        // TODO: Event participants
     };
 }// namespace ECFMP::Event

include/ECFMP/eventbus/EventBus.h

@@ -7,9 +7,6 @@
 
 namespace ECFMP::EventBus {
 
-    template<typename EventType>
-    class EventStreamFactory;
-
     class EventBus
     {
         public:
@@ -48,6 +45,17 @@ namespace ECFMP::EventBus {
             GetStream<EventType>().SubscribeOnce(listener, filter);
         };
 
+        /**
+         * Checks whether a specified type of listener is registered for a specified type of event.
+         *
+         * Can be used for test assertions.
+         */
+        template<typename ListenerType, typename EventType>
+        [[nodiscard]] auto HasListenerOfType() -> bool
+        {
+            return GetStream<EventType>().template HasListenerOfType<ListenerType>();
+        }
+
         private:
         template<typename EventType>
         auto GetStream() -> InternalEventStream<EventType>&

src/eventbus/InternalEventStream.h

@@ -34,5 +34,26 @@ namespace ECFMP::EventBus {
                     this->subscriptions.end()
             );
         };
+
+        /**
+         * A method for testing only, shouldn't normally be used.
+         */
+        template<typename ListenerType>
+        [[nodiscard]] auto HasListenerOfType() -> bool
+        {
+            auto guard = std::lock_guard(this->mutex);
+            return std::any_of(
+                    this->subscriptions.begin(), this->subscriptions.end(),
+                    [](const EventSubscription<EventType>& subscription) {
+                        try {
+                            static_cast<void>(dynamic_cast<const ListenerType&>(*subscription.listener));
+                            return true;
+                        }
+                        catch (std::bad_cast&) {
+                            return false;
+                        }
+                    }
+            );
+        }
     };
 }// namespace ECFMP::EventBus

test/plugin/SdkFactoryTest.cpp

@@ -1,5 +1,8 @@
 #include "ECFMP/SdkFactory.h"
 #include "ECFMP/EventListeners.h"
+#include "ECFMP/eventbus/EventBus.h"
+#include "api/ApiDataDownloadedEvent.h"
+#include "api/ApiDataParser.h"
 #include "mock/MockHttpClient.h"
 #include "mock/MockLogger.h"
 
@@ -64,4 +67,13 @@ namespace ECFMPTest::Plugin {
                 ECFMP::Plugin::SdkConfigurationException
         );
     }
+
+    TEST_F(SdkFactoryTest, ItRegistersApiDataParserForApiDataEvents)
+    {
+        const auto instance = ECFMP::Plugin::SdkFactory::Build().WithHttpClient(std::move(http)).Instance();
+        auto hasListener =
+                instance->EventBus().HasListenerOfType<ECFMP::Api::ApiDataParser, ECFMP::Api::ApiDataDownloadedEvent>();
+        EXPECT_TRUE(hasListener);
+        instance->Destroy();
+    }
 }// namespace ECFMPTest::Plugin