fix_to_batsboe_main_impl.hpp

Go to the documentation of this file.

/******************************************************************************
** Copyright © 2016 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 {
 
template<class Link> inline int
fix_to_batsboe_link<Link>::main(int argc, char const * const *argv) noexcept(true) {
   return base_t::main<link_t>(
      argc,
      argv,
      BATSBOE::create_program_options<link_t>(create_program_options()),
      [](boost::program_options::variables_map const &vm) {
         using conn_pol_t=typename link_t::exchg_link_t::conn_pol_t;
         using exchange_msg_details_t=typename link_t::exchg_link_t::exchange_msg_details_t;
 
         std::string const MIC_code=[]() {
            std::ostringstream ss;
            common::mic_codes::to_stream<exchange_msg_details_t::MIC_code>(ss);
            return ss.str();
         }();
         const std::string sess_sub_id(vm[(MIC_code+"_session_sub_id").c_str()].as<std::string>());
         BATSBOE::common::SessionSubID_t sess_sub_id_conv;
         std::memcpy(sess_sub_id_conv.data(), sess_sub_id.data(), std::min(sess_sub_id_conv.size(), sess_sub_id.size()));
         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()));
         // TODO Must be shared, as the link, also the processing rules require a reference to this object.
         std::shared_ptr<typename exchange_msg_details_t::SeqNum_t> seq_num(
            std::make_shared<typename exchange_msg_details_t::SeqNum_t>(
               vm[(MIC_code+"_sequence_number").c_str()].as<unsigned>()
            )
         );
 
         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(*seq_num)
            },
            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+"_gateway_port").c_str()].as<unsigned short>())
               ),
               typename conn_pol_t::logon_args_t{
                  vm[(MIC_code+"_sequence_number").c_str()].as<unsigned>(),
                  sess_sub_id_conv,
                  user_conv,
                  pass_conv,
                  vm[(MIC_code+"_no_unspec_replay").c_str()].as<bool>()
               },
               exchanges::BATSBOE::common::logoff_args_t{
                  *seq_num
               }
            ),
            typename link_t::exchg_to_client_proc_rules_t(*seq_num),
            seq_num
         );
      }
   );
}
 
} } }