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

use std::error::Error;
use yatis::*;
use t_types::*;

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>>{
    let token = std::env::var("SANDBOX_TOKEN").expect("need to set env var 'SANDBOX_TOKEN'");
    let api = SandboxApi::create_invest_service(token)?;
    let name = "yatis test sanbox 0.2.0".to_owned();
    let r = api.request(OpenSandboxAccountRequest{ name: Some(name.clone()) }).await?;
    let r = api.request(SandboxPayInRequest{ 
        account_id: r.account_id, 
        amount: Some(MoneyValue { currency: "RUB".to_string(), units: 50000, nano: 300000000 }) 
    }).await?;
    println!("{r:?}");
    let accounts = any_trade_algo(api.clone()).await?;
    for a in accounts {
        if a.name == name {
            let r = api.request(CloseSandboxAccountRequest{ account_id: a.id }).await;
            println!("{r:?}");
            break;
        }
    }
    Ok(())
}

async fn any_trade_algo(api: impl InvestApi) -> Result<Vec<Account>, tonic::Status> {
    let GetAccountsResponse { accounts } = api.request(GetAccountsRequest::default()).await?;
    println!("{accounts:?}");
    for a in accounts.clone() {
        println!("portfolio for {}:", a.name);
        let r = api.request(PortfolioRequest{ account_id: a.id, currency: None }).await?;
        for p in r.positions {
            println!("\t{}: {}", p.figi, p.quantity.unwrap());
        }
    }
    use futures::StreamExt;
    let (s, mut r) = futures::channel::mpsc::channel::<StreamResponse>(10);
    api.start_stream(PositionsStreamRequest{ accounts: vec![accounts[0].id.clone()], with_initial_positions: true, ping_settings: None }, s.clone()).await?;
    if let Some(res) = r.next().await {
        println!("{res:?}");
    }
    Ok(accounts)
}