feat: ws active asset ctx (#82)

# Overview
This PR adds -
- support for `activeAssetCtx`
- required structs
- example usage

Fixes #81

Author: namn-grg

src/bin/ws_active_asset_ctx.rs

@@ -0,0 +1,30 @@
+use hyperliquid_rust_sdk::{BaseUrl, InfoClient, Message, Subscription};
+use log::info;
+use tokio::{
+    spawn,
+    sync::mpsc::unbounded_channel,
+    time::{sleep, Duration},
+};
+
+#[tokio::main]
+async fn main() {
+    env_logger::init();
+    let mut info_client = InfoClient::new(None, Some(BaseUrl::Testnet)).await.unwrap();
+    let coin = "BTC".to_string();
+
+    let (sender, mut receiver) = unbounded_channel();
+    let subscription_id = info_client
+        .subscribe(Subscription::ActiveAssetCtx { coin }, sender)
+        .await
+        .unwrap();
+
+    spawn(async move {
+        sleep(Duration::from_secs(30)).await;
+        info!("Unsubscribing from active asset ctx");
+        info_client.unsubscribe(subscription_id).await.unwrap()
+    });
+
+    while let Some(Message::ActiveAssetCtx(active_asset_ctx)) = receiver.recv().await {
+        info!("Received active asset ctx: {active_asset_ctx:?}");
+    }
+}

src/ws/message_types.rs

@@ -55,3 +55,8 @@ pub struct Notification {
 pub struct WebData2 {
     pub data: WebData2Data,
 }
+
+#[derive(Deserialize, Clone, Debug)]
+pub struct ActiveAssetCtx {
+    pub data: ActiveAssetCtxData,
+}

src/ws/sub_structs.rs

@@ -1,5 +1,5 @@
 use ethers::types::H160;
-use serde::Deserialize;
+use serde::{Deserialize, Serialize};
 use std::collections::HashMap;
 
 #[derive(Deserialize, Clone, Debug)]
@@ -279,3 +279,45 @@ pub struct NotificationData {
 pub struct WebData2Data {
     pub user: H160,
 }
+
+#[derive(Deserialize, Clone, Debug)]
+#[serde(rename_all = "camelCase")]
+pub struct ActiveAssetCtxData {
+    pub coin: String,
+    pub ctx: AssetCtx,
+}
+
+#[derive(Deserialize, Serialize, Clone, Debug)]
+#[serde(rename_all = "camelCase")]
+#[serde(untagged)]
+pub enum AssetCtx {
+    Perps(PerpsAssetCtx),
+    Spot(SpotAssetCtx),
+}
+
+#[derive(Deserialize, Serialize, Clone, Debug)]
+#[serde(rename_all = "camelCase")]
+pub struct SharedAssetCtx {
+    pub day_ntl_vlm: String,
+    pub prev_day_px: String,
+    pub mark_px: String,
+    pub mid_px: Option<String>,
+}
+
+#[derive(Deserialize, Serialize, Clone, Debug)]
+#[serde(rename_all = "camelCase")]
+pub struct PerpsAssetCtx {
+    #[serde(flatten)]
+    pub shared: SharedAssetCtx,
+    pub funding: String,
+    pub open_interest: String,
+    pub oracle_px: String,
+}
+
+#[derive(Deserialize, Serialize, Clone, Debug)]
+#[serde(rename_all = "camelCase")]
+pub struct SpotAssetCtx {
+    #[serde(flatten)]
+    pub shared: SharedAssetCtx,
+    pub circulating_supply: String,
+}

src/ws/ws_manager.rs

@@ -1,7 +1,8 @@
 use crate::{
     prelude::*,
     ws::message_types::{AllMids, Candle, L2Book, OrderUpdates, Trades, User},
-    Error, Notification, UserFills, UserFundings, UserNonFundingLedgerUpdates, WebData2,
+    ActiveAssetCtx, Error, Notification, UserFills, UserFundings, UserNonFundingLedgerUpdates,
+    WebData2,
 };
 use futures_util::{stream::SplitSink, SinkExt, StreamExt};
 use log::{error, info, warn};
@@ -50,16 +51,17 @@ pub(crate) struct WsManager {
 #[serde(rename_all = "camelCase")]
 pub enum Subscription {
     AllMids,
-    Trades { coin: String },
+    Notification { user: H160 },
+    WebData2 { user: H160 },
+    Candle { coin: String, interval: String },
     L2Book { coin: String },
+    Trades { coin: String },
+    OrderUpdates { user: H160 },
     UserEvents { user: H160 },
     UserFills { user: H160 },
-    Candle { coin: String, interval: String },
-    OrderUpdates { user: H160 },
     UserFundings { user: H160 },
     UserNonFundingLedgerUpdates { user: H160 },
-    Notification { user: H160 },
-    WebData2 { user: H160 },
+    ActiveAssetCtx { coin: String },
 }
 
 #[derive(Deserialize, Clone, Debug)]
@@ -80,6 +82,7 @@ pub enum Message {
     UserNonFundingLedgerUpdates(UserNonFundingLedgerUpdates),
     Notification(Notification),
     WebData2(WebData2),
+    ActiveAssetCtx(ActiveAssetCtx),
     Pong,
 }
 
@@ -258,6 +261,12 @@ impl WsManager {
                 user: web_data2.data.user,
             })
             .map_err(|e| Error::JsonParse(e.to_string())),
+            Message::ActiveAssetCtx(active_asset_ctx) => {
+                serde_json::to_string(&Subscription::ActiveAssetCtx {
+                    coin: active_asset_ctx.data.coin.clone(),
+                })
+                .map_err(|e| Error::JsonParse(e.to_string()))
+            }
             Message::SubscriptionResponse | Message::Pong => Ok(String::default()),
             Message::NoData => Ok("".to_string()),
             Message::HyperliquidError(err) => Ok(format!("hyperliquid error: {err:?}")),