@@ -30,53 +30,20 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
3030 println ! ( "ORDERBOOK_QUOTER_SERVER_URI is not set" ) ;
3131 process:: exit ( 0 ) ;
3232 }
33- /*
34- let mut exchange_server_one_uri: String = "".to_string();
35- if let Ok(exchange_server_one_uri) = env::var("EXCHANGE_SERVER_1_URI") {
36- println!("exchange server 1 uri is: {}", exchange_server_one_uri);
37- } else {
38- println!("exchange server 1 uri is not set");
39- process::exit(0);
40- }
41- let mut exchange_server_two_uri: String = "".to_string();
42- if let Ok(exchange_server_two_uri) = env::var("EXCHANGE_SERVER_2_URI") {
43- println!("exchange server 2 uri is: {}", exchange_server_two_uri);
44- } else {
45- println!("exchange server 2 uri is not set");
46- process::exit(0);
47- }
48- */
49- // let mut client = QuoterClient::connect(env::var("ORDERBOOK_QUOTER_SERVER_URI").unwrap())
50- //
5133 let mut client = QuoterClient :: connect ( "http://[::1]:9090" ) . await . unwrap ( ) ;
52-
5334 let market_maker = MarketMaker :: new ( ) ;
5435 market_maker. stream_quotes ( & mut client, 50000 ) . await ;
5536 Ok ( ( ) )
5637}
5738
5839pub struct MarketMaker {
5940 agent : String ,
60- // exchanges: Vec<Exchange>,
61- // quote_producer: Sender<QuoterResponse>,
62- // quote_consumer: Receiver<QuoterResponse>,
6341}
6442
6543impl MarketMaker {
6644 fn new ( ) -> Self {
67- /*
68- let (producer, consumer) = channel(1000);
69- let mut exchanges: Vec<Exchange> = vec![];
70- for uri in exchange_uris {
71- let exchange = Exchange::new(uri);
72- exchanges.push(exchange);
73- }
74- */
7545 MarketMaker {
7646 agent : "market-maker-strategy-tbd" . to_string ( ) ,
77- // exchanges,
78- // quote_producer: producer,
79- // quote_consumer: consumer,
8047 }
8148 }
8249 async fn stream_quotes ( self , client : & mut QuoterClient < Channel > , num : usize ) {
0 commit comments