dhan-rs 0.1.7

Unofficial Rust client library for the DhanHQ Broker API v2 — orders, market data, WebSocket feeds, and more
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

//! Binary to connect to DhanHQ Market Feed WebSocket and subscribe to
//! NIFTY 50 (IDX_I:13) and HDFC Bank (NSE_EQ:1333) for inspecting live data.
//!
//! # Usage
//!
//! ```sh
//! export DHAN_CLIENT_ID="your-client-id"
//! export DHAN_ACCESS_TOKEN="your-access-token"
//! cargo run --bin ws_check --features cli
//! ```

use std::env;
use std::time::Duration;

use dhan_rs::types::enums::FeedRequestCode;
use dhan_rs::ws::market_feed::{Instrument, MarketFeedStream};
use futures_util::StreamExt;
use tokio::time;

#[tokio::main]
async fn main() -> dhan_rs::error::Result<()> {
    tracing_subscriber::fmt()
        .with_env_filter(
            tracing_subscriber::EnvFilter::try_from_default_env()
                .unwrap_or_else(|_| tracing_subscriber::EnvFilter::new("info")),
        )
        .init();

    let client_id = env::var("DHAN_CLIENT_ID").expect("set DHAN_CLIENT_ID env var before running");
    let access_token =
        env::var("DHAN_ACCESS_TOKEN").expect("set DHAN_ACCESS_TOKEN env var before running");

    println!("Connecting to DhanHQ Market Feed WebSocket…");
    let mut stream = MarketFeedStream::connect(&client_id, &access_token).await?;

    // Subscribe to NIFTY 50 index (Ticker mode — indices don't support Full)
    let index_instruments = vec![Instrument::new("IDX_I", "13")];
    println!("Subscribing to IDX_I:13 NIFTY 50 (Ticker)…");
    stream
        .subscribe(FeedRequestCode::SubscribeTicker, &index_instruments)
        .await?;

    // Subscribe to HDFC Bank on NSE (Full mode — equity with depth)
    let equity_instruments = vec![Instrument::new("NSE_EQ", "1333")];
    println!("Subscribing to NSE_EQ:1333 HDFC Bank (Full)…");
    stream
        .subscribe(FeedRequestCode::SubscribeFull, &equity_instruments)
        .await?;

    println!("Listening for events for 10 seconds…");
    println!("(Note: data only arrives during market hours 9:15–15:30 IST)\n");

    let deadline = time::sleep(Duration::from_secs(10));
    tokio::pin!(deadline);

    loop {
        tokio::select! {
            _ = &mut deadline => {
                println!("\n10 seconds elapsed — disconnecting…");
                break;
            }
            event = stream.next() => {
                match event {
                    Some(Ok(e)) => println!("{e:#?}"),
                    Some(Err(e)) => eprintln!("Error: {e}"),
                    None => {
                        println!("Stream ended by server");
                        break;
                    }
                }
            }
        }
    }

    stream.disconnect().await?;
    println!("Done.");

    Ok(())
}