Dispatcher.cpp

/************************************************************************
 * Copyright(c) 2021, One Unified. All rights reserved.                 *
 * email: info@oneunified.net                                           *
 *                                                                      *
 * This file is provided as is WITHOUT ANY WARRANTY                     *
 *  without even the implied warranty of                                *
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.                *
 *                                                                      *
 * This software may not be used nor distributed without proper license *
 * agreement.                                                           *
 *                                                                      *
 * See the file LICENSE.txt for redistribution information.             *
 ************************************************************************/

/*
 * File:    Dispatcher.cpp
 * Author:  raymond@burkholder.net
 * Project: TFIQFeed/Level2
 * Created on October 17, 2021 10:56
 */

#include <boost/spirit/include/qi.hpp>
#include <boost/spirit/include/qi_symbols.hpp>

#include "Dispatcher.h"

BOOST_FUSION_ADAPT_STRUCT(
  ou::tf::iqfeed::l2::SystemStatus,
  (ou::tf::iqfeed::l2::SystemStatus::ECmd, cmd)
  (ou::tf::iqfeed::l2::SystemStatus::vString_t, vString)
)

namespace qi = boost::spirit::qi;

namespace ou { // One Unified
namespace tf { // TradeFrame
namespace iqfeed { // IQFeed
namespace l2 { // level 2 data

template<typename Iterator>
struct SystemStatusParser: qi::grammar<Iterator, ou::tf::iqfeed::l2::SystemStatus()> {

  using ECmd = ou::tf::iqfeed::l2::SystemStatus::ECmd;

  SystemStatusParser(): SystemStatusParser::base_type( ruleStart ) {

    cmd.add
      ( "SERVER CONNECTED", ECmd::ServerConnected )
      ( "CURRENT PROTOCOL", ECmd::CurrentProtocol )
      ( "CLEAR DEPTH", ECmd::ClearDepth )
      ( "SERVER DISCONNECTED", ECmd::ServerDisconnected )
      ;

    ruleCmd     = cmd;
    ruleString  = +( qi::char_ - qi::char_( ',' ) );
    ruleStart
      %=
         qi::lit( 'S' ) >> qi::lit( ',' )
      >> ruleCmd
      >> -( qi::lit( ',' ) >> ruleString % ',' )
      >> -qi::lit( ',' )
      ;

  }

  qi::symbols<char, ECmd> cmd;

  qi::rule<Iterator, ECmd()> ruleCmd;
  qi::rule<Iterator, std::string()> ruleString;
  qi::rule<Iterator, ou::tf::iqfeed::l2::SystemStatus()> ruleStart;
};

bool ParseSystemStatus( const std::string& src, SystemStatus& status ) {

  SystemStatusParser<std::string::const_iterator> grammarSystemStatus;

  bool bOk( false );
  try {
    bOk = parse( src.begin(), src.end(), grammarSystemStatus, status );
  }
  catch( const std::runtime_error& e) {
    std::cout << e.what() << std::endl;
  }
  catch( const boost::exception& e) {
    std::cout << boost::diagnostic_information(e) << std::endl;
  }
  catch(...) {
    std::cerr << "error" << std::endl;
  }
  return bOk;
}

} // namespace l2
} // namesapce iqfeed
} // namespace tf
} // namespace ou