mit_msm.cpp

Go to the documentation of this file.

/******************************************************************************
** Copyright © 2018 by J.M.McGuiness, isimud@hussar.me.uk
**
** This library is free software; you can redistribute it and/or
** modify it under the terms of the GNU Lesser General Public
** License as published by the Free Software Foundation; either
** version 2.1 of the License, or (at your option) any later version.
**
** This library is distributed in the hope that it will be useful,
** but WITHOUT ANY WARRANTY; without even the implied warranty of
** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
** Lesser General Public License for more details.
**
** You should have received a copy of the GNU Lesser General Public
** License along with this library; if not, write to the Free Software
** Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
 
#include "stdafx.h"
 
#define BOOST_TEST_MODULE isimud_tests
#include <boost/test/included/unit_test.hpp>
 
#include <boost/mpl/list.hpp>
 
#include "../exchanges/FIX/v5.0sp2/fix.hpp"
#include "../exchanges/MIT/BIT/messages.hpp"
/* TODO #include "../exchanges/MIT/JSE/messages.hpp"
#include "../exchanges/MIT/LSE/messages.hpp"
#include "../exchanges/MIT/OSLO/messages.hpp"
#include "../exchanges/MIT/TRQ/messages.hpp"
*/
#include "core/msm.hpp"
 
using namespace libjmmcg;
using namespace libisimud;
 
using msg_types=boost::mpl::list<
   exchanges::MIT::BIT::MsgTypes/* TODO,
   exchanges::MIT::JSE::MsgTypes,
   exchanges::MIT::LSE::MsgTypes,
   exchanges::MIT::OSLO::MsgTypes,
   exchanges::MIT::TRQ::MsgTypes*/
>;
 
template<class DestMsgsT>
struct data_with_payload {
   using dest_msg_details_t=DestMsgsT;
   typename dest_msg_details_t::MsgTypes_t state{};
   unsigned j{68};
};
 
template<
   class SrcMsgsT,
   class DestMsgsT,
   template<class> class MSMType,
   template<class, class> class MSMRowsType,
   template<class> class MachineT
>
struct assign_msm_states {
   using src_msg_details_t=SrcMsgsT;
   using dest_msg_details_t=DestMsgsT;
   template<class StateMachineT> using msm_t=MSMType<StateMachineT>;
   struct fn_event {
      using argument_type=data_with_payload<dest_msg_details_t>;
 
      explicit fn_event(unsigned &j)
      : j_(j) {}
 
      template<auto state, auto next>
      void operator()(argument_type &p) const noexcept(true) {
         p.state=next;
         p.j+=j_;
      }
 
   private:
      unsigned &j_;
   };
 
   struct state_machine_t final : msm_t<state_machine_t> {
      using base_t=msm_t<state_machine_t>;
      using row_t=MSMRowsType<typename src_msg_details_t::MsgType_t, typename dest_msg_details_t::MsgTypes_t>;
      using transition_table=typename base_t::template rows<
         typename row_t::template row<
            src_msg_details_t::NewOrder_t::static_type,
            fn_event,
            dest_msg_details_t::NewOrder_t::static_type
         >,
         typename row_t::template row<
            src_msg_details_t::OrderCancelRequest::static_type,
            fn_event,
            dest_msg_details_t::OrderCancelRequest::static_type
         >,
         typename row_t::template row<
            src_msg_details_t::OrderCancelReplace::static_type,
            fn_event,
            dest_msg_details_t::OrderCancelReplaceRequest::static_type
         >/* This next row breaks g++ v9.1.0... ,
         typename row_t::template row<
            src_msg_details_t::MatchAll,
            fn_event,
            dest_msg_details_t::Reject::static_type
         >*/
      >;
   };
   using machine=MachineT<state_machine_t>;
 
   assign_msm_states()
   : j(42), msm(j, j, j) {
   }
 
   void process(typename src_msg_details_t::MsgType_t state, data_with_payload<dest_msg_details_t> &p) noexcept(false) {
      msm.process(state, p);
   }
 
   unsigned j;
   machine msm;
};
 
BOOST_AUTO_TEST_SUITE(isimud)
 
BOOST_AUTO_TEST_SUITE(msm_tests)
 
BOOST_AUTO_TEST_SUITE(unroll)
 
BOOST_AUTO_TEST_CASE_TEMPLATE(start_state_assign_msm_states, msg, msg_types) {
   using assign_msm_states_t=assign_msm_states<
      exchanges::FIX::v5_0sp2::MsgTypes,
      msg,
      msm::unroll::state_transition_table,
      msm::unroll::row_types,
      msm::unroll::machine
   >;
   assign_msm_states_t msm;
   data_with_payload<msg> d;
   BOOST_CHECK_NO_THROW(msm.process(exchanges::FIX::v5_0sp2::MsgTypes::NewOrder_t::static_type, d));
   BOOST_CHECK_EQUAL(d.j, 68+42);
}
 
BOOST_AUTO_TEST_SUITE_END()
 
BOOST_AUTO_TEST_SUITE(hash)
 
BOOST_AUTO_TEST_CASE_TEMPLATE(start_state_assign_msm_states, msg, msg_types) {
   using assign_msm_states_t=assign_msm_states<
      exchanges::FIX::v5_0sp2::MsgTypes,
      msg,
      msm::hash::state_transition_table,
      msm::hash::row_types,
      msm::hash::machine
   >;
   assign_msm_states_t msm;
   data_with_payload<msg> d;
   BOOST_CHECK_NO_THROW(msm.process(exchanges::FIX::v5_0sp2::MsgTypes::NewOrder_t::static_type, d));
   BOOST_CHECK_EQUAL(d.state, assign_msm_states_t::dest_msg_details_t::NewOrder_t::static_type);
   BOOST_CHECK_EQUAL(d.j, 68+42);
}
 
BOOST_AUTO_TEST_SUITE_END()
 
BOOST_AUTO_TEST_SUITE_END()
 
BOOST_AUTO_TEST_SUITE_END()