guilder-client-hyperliquid 0.6.3

Hyperliquid client for the guilder multi-exchange crypto trading library
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

use futures_util::StreamExt;
use guilder_abstraction::SubscribeMarketData;
use guilder_client_hyperliquid::HyperliquidClient;
use rust_decimal::Decimal;
use std::time::Duration;
use tokio::time::timeout;

/// Subscribes to BTC L2 snapshots and asserts at least one event arrives within 5 s.
#[tokio::test]
async fn test_subscribe_l2_snapshot_receives_events() {
    let client = HyperliquidClient::new();
    let mut stream = client.subscribe_l2_snapshot("BTC".to_string());

    let event = timeout(Duration::from_secs(5), stream.next()).await;
    let event = event
        .expect("timed out waiting for L2 snapshot")
        .expect("stream ended early")
        .expect("l2 snapshot should be ok");

    assert_eq!(event.symbol, "BTC");
    assert!(!event.bids.is_empty() || !event.asks.is_empty());
    assert!(event.bids.first().map(|level| level.price > Decimal::ZERO).unwrap_or(true));
}

/// Subscribes to BTC trade fills and asserts at least one event arrives within 30 s.
/// Trades may be infrequent so we allow a longer timeout.
#[tokio::test]
async fn test_subscribe_fill_receives_events() {
    let client = HyperliquidClient::new();
    let mut stream = client.subscribe_fill("BTC".to_string());

    let event = timeout(Duration::from_secs(30), stream.next()).await;
    let event = event
        .expect("timed out waiting for fill")
        .expect("stream ended early")
        .expect("fill event should be ok");

    assert_eq!(event.symbol, "BTC");
    assert!(event.price > Decimal::ZERO, "price should be positive");
    assert!(event.volume > Decimal::ZERO, "volume should be positive");
    assert!(event.timestamp_ms > 0, "timestamp should be positive");
}