alpaca-data 0.25.1

Rust client for the Alpaca Market Data HTTP API
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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

#[path = "../../../tests/support/live/mod.rs"]
mod live_support;

use alpaca_data::{
    Client,
    options::{ChainRequest, SnapshotsRequest, options_underlying_symbol, preferred_feed},
};
use live_support::{AlpacaService, LiveTestEnv, discover_option_contracts};

#[tokio::test]
#[ignore = "slow live batching audit; run explicitly when validating option snapshot batching"]
async fn options_snapshots_all_absorbs_multi_batch_contract_lists() {
    let env = LiveTestEnv::load().expect("live test environment should load");
    if let Some(reason) = env.skip_reason_for_service(AlpacaService::Data) {
        eprintln!("skipping real API test: {reason}");
        return;
    }

    let service = env.data().expect("data config should exist");
    let client = Client::builder()
        .credentials(service.credentials().clone())
        .build()
        .expect("client should build from live service config");

    let contracts = discover_option_contracts(service, None, "SPY", 180)
        .await
        .expect("should discover a broad SPY contract slice");
    let symbols = contracts
        .into_iter()
        .take(101)
        .map(|contract| contract.symbol)
        .collect::<Vec<_>>();
    assert_eq!(
        symbols.len(),
        101,
        "SPY contract discover should yield >100 symbols"
    );

    let response = client
        .options()
        .snapshots_all(SnapshotsRequest {
            symbols: symbols.clone(),
            feed: Some(preferred_feed()),
            limit: Some(1000),
            page_token: None,
        })
        .await
        .expect("snapshots_all should absorb Alpaca's 100-symbol limit internally");

    assert_eq!(response.snapshots.len(), symbols.len());
}

#[tokio::test]
async fn options_chain_absorbs_brk_b_provider_symbol_rules() {
    let env = LiveTestEnv::load().expect("live test environment should load");
    if let Some(reason) = env.skip_reason_for_service(AlpacaService::Data) {
        eprintln!("skipping real API test: {reason}");
        return;
    }

    let service = env.data().expect("data config should exist");
    let client = Client::builder()
        .credentials(service.credentials().clone())
        .build()
        .expect("client should build from live service config");

    let request = ChainRequest {
        underlying_symbol: "BRK.B".to_owned(),
        feed: Some(preferred_feed()),
        r#type: None,
        strike_price_gte: None,
        strike_price_lte: None,
        expiration_date: None,
        expiration_date_gte: None,
        expiration_date_lte: None,
        root_symbol: Some("BRK.B".to_owned()),
        updated_since: None,
        limit: Some(8),
        page_token: None,
    };

    assert_eq!(
        options_underlying_symbol(&request.underlying_symbol),
        "BRKB"
    );

    let chain = client
        .options()
        .chain(request)
        .await
        .expect("BRK.B chain request should succeed through canonical symbol normalization");

    assert!(!chain.snapshots.is_empty());
    assert!(
        alpaca_data::options::ordered_snapshots(&chain.snapshots)
            .iter()
            .all(|(symbol, _)| symbol.starts_with("BRKB")),
        "BRK.B chain contracts should use the BRKB OCC root"
    );
}