alpacars 0.1.2

Async Rust SDK for Alpaca Markets 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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146

//! Crypto Trading Basic — mirrors alpaca-py/examples/crypto-trading-basic.ipynb
//!
//! Run with:
//!   APCA_API_KEY_ID=<key> APCA_API_SECRET_KEY=<secret> cargo run --example crypto_trading_basic

use alpacars::data::historical::crypto::{CryptoBarsRequest, CryptoHistoricalDataClient, CryptoLatestRequest};
use alpacars::trading::client::TradingClient;
use alpacars::trading::enums::{AssetClass, AssetStatus, OrderSide, TimeInForce};
use alpacars::trading::requests::{
    ClosePositionRequest, GetAssetsRequest, GetOrdersRequest, OrderRequest,
};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let api_key = std::env::var("APCA_API_KEY_ID").expect("APCA_API_KEY_ID not set");
    let secret_key = std::env::var("APCA_API_SECRET_KEY").expect("APCA_API_SECRET_KEY not set");

    // ── Trading client (paper) ────────────────────────────────────────────────
    let trading = TradingClient::new(&api_key, &secret_key, true)?;

    // ── Account info ─────────────────────────────────────────────────────────
    let account = trading.get_account().await?;
    println!("Account status : {:?}", account.status);
    println!("Buying power   : {:?}", account.buying_power);

    // ── List active crypto assets ────────────────────────────────────────────
    let assets = trading
        .get_all_assets(Some(&GetAssetsRequest {
            status: Some(AssetStatus::Active),
            asset_class: Some(AssetClass::Crypto),
            ..Default::default()
        }))
        .await?;
    println!("Active crypto assets: {}", assets.len());

    // ── Place orders on BTC/USD ──────────────────────────────────────────────

    // Market order — 0.01 BTC
    let market_order = trading
        .submit_order(&OrderRequest::market("BTC/USD", OrderSide::Buy, "0.01"))
        .await?;
    println!("Market order id: {:?}", market_order.id);

    // Market order — $1.11 notional
    let notional_order = trading
        .submit_order(&OrderRequest::market_notional("BTC/USD", OrderSide::Buy, "1.11"))
        .await?;
    println!("Notional order id: {:?}", notional_order.id);

    // Limit order
    let limit_order = trading
        .submit_order(&OrderRequest::limit(
            "BTC/USD",
            OrderSide::Buy,
            "0.01",
            "60000.00",
            TimeInForce::Gtc,
        ))
        .await?;
    println!("Limit order id: {:?}", limit_order.id);

    // Stop-limit order
    let stop_limit_order = trading
        .submit_order(&OrderRequest::stop_limit(
            "BTC/USD",
            OrderSide::Sell,
            "0.01",
            "58000.00",
            "57900.00",
        ))
        .await?;
    println!("Stop-limit order id: {:?}", stop_limit_order.id);

    // ── Query orders ─────────────────────────────────────────────────────────
    let all_orders = trading
        .get_orders(Some(&GetOrdersRequest {
            status: Some(alpacars::trading::enums::QueryOrderStatus::All),
            ..Default::default()
        }))
        .await?;
    println!("Total orders: {}", all_orders.len());

    let open_orders = trading
        .get_orders(Some(&GetOrdersRequest {
            status: Some(alpacars::trading::enums::QueryOrderStatus::Open),
            ..Default::default()
        }))
        .await?;
    println!("Open orders: {}", open_orders.len());

    // ── Cancel all open orders ───────────────────────────────────────────────
    let cancelled = trading.cancel_orders().await?;
    println!("Cancelled {} order(s).", cancelled.len());

    // ── Positions ────────────────────────────────────────────────────────────
    let positions = trading.get_all_positions().await?;
    println!("Open positions: {}", positions.len());

    // Note: Alpaca uses "BTCUSD" (no slash) for position queries
    match trading.get_open_position("BTCUSD").await {
        Ok(pos) => {
            println!("BTC/USD position: qty={} market_value={:?}", pos.qty, pos.market_value);

            // Close the BTC position
            trading
                .close_position(
                    "BTCUSD",
                    Some(&ClosePositionRequest {
                        percentage: Some("100".to_string()),
                        qty: None,
                    }),
                )
                .await?;
            println!("BTC/USD position closed.");
        }
        Err(e) => println!("No BTC/USD position: {}", e),
    }

    // ── Historical data ───────────────────────────────────────────────────────
    // CryptoHistoricalDataClient does not require auth for free data
    let data_client = CryptoHistoricalDataClient::new(Some(&api_key), Some(&secret_key))?;

    let bars = data_client
        .get_crypto_bars(&CryptoBarsRequest {
            symbols: vec!["BTC/USD".to_string(), "ETH/USD".to_string()],
            ..Default::default()
        })
        .await?;
    for (sym, sym_bars) in &bars {
        if let Some(last) = sym_bars.last() {
            println!("{} latest bar: open={} close={}", sym, last.open, last.close);
        }
    }

    let latest_quote = data_client
        .get_crypto_latest_quote(&CryptoLatestRequest {
            symbols: vec!["BTC/USD".to_string()],
            ..Default::default()
        })
        .await?;
    if let Some(q) = latest_quote.get("BTC/USD") {
        println!("BTC/USD latest ask: {} bid: {}", q.ask_price, q.bid_price);
    }

    Ok(())
}