yatis 0.2.1

Yet Another T-bank Investment Sdk
Documentation 
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use std::time::Duration;

use futures::StreamExt;
use yatis::pool::ApiPool;
use yatis::requestor::Requestor;
use yatis::stream_response::StreamResponse;
use yatis::Api;
use yatis::t_types::*;
use yatis::InvestApi;
use yatis::InvestService;


#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    simplelog::SimpleLogger::init(log::LevelFilter::Info, simplelog::Config::default())?;
    let token = std::env::var("TOKEN")?;
    let api = Api::create_invest_service(token)?;
    let pool = ApiPool::new(api.clone());
    pool.add(api.clone());
    pool.add(api);
    let handle = tokio::spawn(async move {trading_algo(pool).await});
    tokio::time::sleep(Duration::from_secs(180)).await;
    handle.abort();
    Ok(())
}

async fn trading_algo(pool: impl InvestApi) -> Result<(), tonic::Status> {
    let accounts = pool.request(GetAccountsRequest::default()).await?;
    let portfolio = pool.request(PortfolioRequest { account_id: accounts.accounts[0].id.clone(), currency: None }).await?;
    let t: ShareResponse = pool.request(InstrumentRequest { id_type: InstrumentIdType::Ticker.into(), class_code: Some("TQBR".to_string()), id: "T".to_string() }).await?;
    log::info!("t share: {t:?}");
    let t = t.instrument.unwrap().uid;
    portfolio.total_amount_portfolio.as_ref().map(|m|print!("total {m}"));
    portfolio.daily_yield.as_ref().map(|m|print!(", daily yeld {m}"));
    println!();
    portfolio.positions.iter().for_each(|p|{
        println!(
            "{}, figi: {}, uid: {}, count: {}, price: {}", 
            p.instrument_type, p.figi, p.instrument_uid, p.quantity.unwrap_or_default(), 
            p.current_price.as_ref().cloned().unwrap_or_default()
        );
    });
    let (s,mut r) = futures::channel::mpsc::channel::<StreamResponse>(10);
    
    pool.start_stream(MarketDataServerSideStreamRequest{ 
        subscribe_candles_request: None, 
        subscribe_order_book_request: None, 
        subscribe_trades_request: None, 
        subscribe_info_request: None, 
        subscribe_last_price_request: Some(SubscribeLastPriceRequest{
            subscription_action: SubscriptionAction::Subscribe.into(), 
            instruments: vec![LastPriceInstrument{instrument_id: t.clone(), ..Default::default() }]
        }), 
        ping_settings: Some(PingDelaySettings { ping_delay_ms: Some(5000) }),
    }, s).await?;
    log::info!("initializing sequence completed");
    loop {
        let response = r.next().await.unwrap();
        log::info!("{response:?}");  
    }
}