1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40
// use std::collections::HashMap; // use std::env; use std::error::Error; // // use cfix::types::CTraderLogin; // use cfix::utilities::market_data::MarketDataManager; // #[async_std::main] async fn main() -> Result<(), Box<dyn Error>> { // dotenv::dotenv().ok(); // env_logger::Builder::from_env(env_logger::Env::default().default_filter_or("info")).init(); // // let host = env::var("CTRADER_FIX_HOST").unwrap(); // let username = env::var("CTRADER_FIX_USERNAME").unwrap(); // let password = env::var("CTRADER_FIX_PASSWORD").unwrap(); // let sendercompid = env::var("CTRADER_FIX_SENDERCOMPID").unwrap(); // // let login = CTraderLogin { // username, // password, // server: host, // sendercompid, // ssl: false, // heartbeat_interval: None, // }; // // // // let mut mdm = MarketDataManager::new(); // let symbols = mdm.get_onetime_symbol_list(login.clone()).await?; // // log::info!("{:?}", symbols); // // let mut mapping: HashMap<u32, String> = HashMap::new(); // mapping.insert(1, "eurusd".into()); // // let conn_id = mdm.connect(login, mapping).await?; // // mdm.subscribe_spot(conn_id, vec!["eurusd"]).await?; // Ok(()) }