reactor.h

Go to the documentation of this file.

 
#pragma once
 
#include "../../pmr/stack_resource.h"
#include "../../protocol/endpoint.h"
#include "../../result.h"
#include "./executor.h"
#include "./protocol.h"
#include "./reactor_interface_adapter.h"
 
namespace emlabcpp::testing
{
 
class reactor
{
        protocol::channel_type channel_;
 
        std::string_view       suite_name_;
        std::string_view const suite_date_ = __DATE__ " " __TIME__;
 
        empty_node                  root_node_;
        pmr::stack_resource< 2048 > mem_;
 
        reactor_interface_adapter iface_;
 
        std::optional< executor > opt_exec_;
        bool                      boot_msg_fired_ = false;
 
public:
        explicit reactor(
            protocol::channel_type const chann,
            std::string_view const       suite_name,
            reactor_transmit_callback    tb )
          : channel_( chann )
          , suite_name_( suite_name )
          , iface_( chann, std::move( tb ) )
        {
        }
 
        reactor( reactor const& )            = delete;
        reactor( reactor&& )                 = delete;
        reactor& operator=( reactor const& ) = delete;
        reactor& operator=( reactor&& )      = delete;
 
        [[nodiscard]] constexpr protocol::channel_type get_channel() const
        {
                return channel_;
        }
 
        outcome on_msg( std::span< std::byte const > buffer );
        outcome on_msg( controller_reactor_variant const& var );
 
        void register_test( linked_list_node_base< test_interface >& test )
        {
                root_node_.link_as_next( test );
        }
 
        void tick();
 
private:
        outcome handle_message( get_property< msgid::SUITE_NAME > );
        outcome handle_message( get_property< msgid::SUITE_DATE > );
        outcome handle_message( get_property< msgid::COUNT > );
        outcome handle_message( get_test_name_request );
        outcome handle_message( exec_request );
};
 
}  // namespace emlabcpp::testing