oxarchive 1.7.0

Rust SDK for async 0xArchive market data clients
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 oxarchive::resources::trades::GetTradesParams;
use oxarchive::OxArchive;

#[tokio::main]
async fn main() -> oxarchive::Result<()> {
    let api_key = std::env::var("OXARCHIVE_API_KEY").expect("Set OXARCHIVE_API_KEY");
    let client = OxArchive::new(api_key)?;

    // Paginate through BTC trades for a 24-hour window
    let mut all_trades = vec![];
    let mut cursor = None;
    let mut page = 0u32;

    loop {
        let result = client
            .hyperliquid
            .trades
            .list(
                "BTC",
                GetTradesParams {
                    start: 1704067200000_i64.into(), // 2024-01-01 00:00 UTC
                    end: 1704153600000_i64.into(),   // 2024-01-02 00:00 UTC
                    cursor,
                    limit: Some(1000),
                    side: None,
                },
            )
            .await?;

        page += 1;
        let count = result.data.len();
        all_trades.extend(result.data);
        println!("Page {page}: fetched {count} trades (total: {})", all_trades.len());

        cursor = result.next_cursor;
        if cursor.is_none() {
            break;
        }
    }

    println!("\nTotal BTC trades in 24h window: {}", all_trades.len());

    Ok(())
}