controller_interface_adapter.h

Go to the documentation of this file.

 
#pragma once
 
#include "../../static_function.h"
#include "./controller_interface.h"
 
namespace emlabcpp::testing
{
 
class controller_interface_adapter
{
        protocol::channel_type channel_;
        controller_interface&  iface_;
 
        static_function< bool( reactor_controller_variant const& ), 32 > reply_cb_;
        controller_transmit_callback                                     send_cb_;
 
public:
        explicit controller_interface_adapter(
            protocol::channel_type const channel,
            controller_interface&        iface,
            controller_transmit_callback send_cb )
          : channel_( channel )
          , iface_( iface )
          , send_cb_( std::move( send_cb ) )
        {
        }
 
        result send( controller_reactor_variant const& var )
        {
                using h        = protocol::handler< controller_reactor_group >;
                auto const msg = h::serialize( var );
                return send_cb_( channel_, msg );
        }
 
        controller_interface* operator->()
        {
                return &iface_;
        }
 
        controller_interface& operator*()
        {
                return iface_;
        }
 
        void set_reply_cb( static_function< bool( reactor_controller_variant const& ), 32 > cb )
        {
                reply_cb_ = std::move( cb );
        }
 
        bool on_msg_with_cb( reactor_controller_variant const& var )
        {
                if ( !reply_cb_ )
                        return false;
                return reply_cb_( var );
        }
 
        void report_error( error_variant const& var )
        {
                iface_.on_error( var );
        }
};
 
}  // namespace emlabcpp::testing