fix_to_links_main_impl.hpp

Go to the documentation of this file.

/******************************************************************************
** Copyright © 2017 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
*/
 
namespace isimud { namespace ISIMUD_VER_NAMESPACE { namespace exchanges {
 
inline int
fix_to_links::main(int argc, char const * const *argv) noexcept(true) {
   return base_t::main<link_t>(
      argc,
      argv,
      BATSBOE::create_program_options<exchanges::BATSBOE::EU::v1::link_t<exchanges::FIX::v5_0sp2::MsgTypes>>(
         BATSBOE::create_program_options<exchanges::BATSBOE::US::v1::link_t<exchanges::FIX::v5_0sp2::MsgTypes>>(
            MIT::create_program_options<exchanges::MIT::BIT::link_t<exchanges::FIX::v5_0sp2::MsgTypes>>(
               MIT::create_program_options<exchanges::MIT::JSE::link_t<exchanges::FIX::v5_0sp2::MsgTypes>>(
                  MIT::create_program_options<exchanges::MIT::LSE::link_t<exchanges::FIX::v5_0sp2::MsgTypes>>(
                     MIT::create_program_options<exchanges::MIT::OSLO::link_t<exchanges::FIX::v5_0sp2::MsgTypes>>(
                        MIT::create_program_options<exchanges::MIT::TRQ::link_t<exchanges::FIX::v5_0sp2::MsgTypes>>(
                           create_program_options()
                        )
                     )
                  )
               )
            )
         )
      ),
      [](boost::program_options::variables_map const &vm) {
         using conn_pol_t=typename link_t::exchg_link_t::conn_pol_t;
         using ref_data_t=typename link_t::client_link_t::proc_rules_t::ref_data;
         using exchange_msg_details_t=typename link_t::exchange_msg_details_t;
 
         auto const MIC_code_gen=[]() {
            std::ostringstream ss;
            common::mic_codes::to_stream<exchange_msg_details_t::MIC_code>(ss);
            return ss.str();
         };
         std::string const MIC_code=MIC_code_gen();
         std::ifstream ref_data_src(vm[(MIC_code+"_ref_data").c_str()].as<std::string>().c_str());
         const ref_data_t ref_data(ref_data_src);
 
         const std::string user(vm[(MIC_code+"_username").c_str()].as<std::string>());
         typename exchange_msg_details_t::UserName_t user_conv{};
         std::memcpy(user_conv.data(), user.data(), std::min(user_conv.size(), user.size()));
         const std::string pass(vm[(MIC_code+"_password").c_str()].as<std::string>());
         typename exchange_msg_details_t::Password_t pass_conv{};
         std::memcpy(pass_conv.data(), pass.data(), std::min(pass_conv.size(), pass.size()));
         const std::string new_pass(vm[(MIC_code+"_new_password").c_str()].as<std::string>());
         typename exchange_msg_details_t::Password_t new_pass_conv{};
         std::memcpy(new_pass_conv.data(), new_pass.data(), std::min(new_pass_conv.size(), new_pass.size()));
         const std::string reason(vm[(MIC_code+"_logout_reason").c_str()].as<std::string>());
         MIT::common::Reason_t reason_conv{};
         std::memcpy(reason_conv.data(), reason.data(), std::min(reason_conv.size(), reason.size()));
         return std::make_tuple(
            typename link_t::client_link_t::ctor_args{
               boost::asio::ip::address_v4::from_string(vm["client_address"].as<std::string>()),
               vm["client_port"].as<unsigned short>(),
               typename link_t::client_link_t::proc_rules_t(ref_data)
            },
            conn_pol_t(
               typename conn_pol_t::gateways_t(
                  std::make_pair(boost::asio::ip::address_v4::from_string(vm[(MIC_code+"_primary_gateway_address").c_str()].as<std::string>()), vm[(MIC_code+"_primary_gateway_port").c_str()].as<unsigned short>()),
                  std::make_pair(boost::asio::ip::address_v4::from_string(vm[(MIC_code+"_secondary_gateway_address").c_str()].as<std::string>()), vm[(MIC_code+"_secondary_gateway_port").c_str()].as<unsigned short>())
               ),
               typename conn_pol_t::logon_args_t{
                  user_conv,
                  pass_conv,
                  new_pass_conv
               },
               MIT::common::logoff_args_t{
                  reason_conv
               }
            ),
            typename link_t::exchg_to_client_proc_rules_t(ref_data)
         );
      }
   );
}
 
} } }