deribit 0.3.3

Rust client for deribit. Please look at tests/examples for detailed usages.
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

use anyhow::Error;
use deribit::{
    models::{
        HeartbeatType, PublicSubscribeRequest, SetHeartbeatRequest, SubscriptionParams, TestRequest,
    },
    DeribitBuilder,
};
use dotenv::dotenv;
use env_logger::init;
use fehler::throws;
use futures::StreamExt;

#[throws(Error)]
#[tokio::main]
async fn main() {
    let _ = dotenv();
    init();

    let drb = DeribitBuilder::default()
        .subscription_buffer_size(100000usize)
        .build()
        .unwrap();

    let (mut client, mut subscription) = drb.connect().await?;

    let req = PublicSubscribeRequest::new(&[
        "book.BTC-PERPETUAL.5.20.100ms".into(),
        "book.BTC-PERPETUAL.raw".into(),
        "deribit_price_index.eth_usd".into(),
        "deribit_price_ranking.eth_usd".into(),
        "estimated_expiration_price.btc_usd".into(),
        "markprice.options.btc_usd".into(),
        "perpetual.BTC-PERPETUAL.raw".into(),
        "quote.BTC-PERPETUAL".into(),
        "ticker.BTC-PERPETUAL.raw".into(),
        "trades.BTC-PERPETUAL.raw".into(),
    ]);

    let _ = client.call(req).await?.await?;

    client
        .call(SetHeartbeatRequest::with_interval(30))
        .await?
        .await?;

    while let Some(m) = subscription.next().await {
        if let SubscriptionParams::Heartbeat {
            r#type: HeartbeatType::TestRequest,
        } = m?.params
        {
            client.call(TestRequest::default()).await?.await?;
        }
    }
}