Struct HyperliquidWsFeed 

pub struct HyperliquidWsFeed {
    ws_url: String,
    coins: Vec<String>,
    prices: Arc<RwLock<HashMap<String, PriceEntry>>>,
}

Shared WebSocket price feed for Hyperliquid oracle prices.

One instance serves multiple oracle consumers. Subscribes to activeAssetCtx for each configured coin and stores the latest oracle price.

Fields

ws_url: String

coins: Vec<String>

prices: Arc<RwLock<HashMap<String, PriceEntry>>>

Implementations

impl HyperliquidWsFeed

pub fn new(ws_url: String, coins: Vec<String>) -> Self

pub fn new_mock( coins: Vec<String>, default_prices: &HashMap<String, f64>, ) -> Self

Create a mock feed with default prices for each coin. Used in test mode so that CatalogManager can create markets without a live WS connection. Prices are refreshed on every get_price call so they never go stale.

pub async fn refresh_mock_timestamps(&self)

Refresh the updated_at timestamp on all mock prices so they never go stale. Called periodically in test mode since get_price returns None after 10s.

pub async fn get_price(&self, coin: &str) -> Option<f64>

Get the latest oracle price for a coin.

Returns None if no price has been received or if the price is stale (>10s old).

pub async fn get_prev_day_price(&self, coin: &str) -> Option<f64>

Get the latest previous-day price for a coin from the WS feed.

pub async fn start(&self, shutdown_rx: Receiver<()>)

Start the WebSocket feed. Runs until shutdown signal.

Auto-reconnects with exponential backoff on disconnection.

async fn run_connection( ws_url: &str, coins: &[String], prices: &Arc<RwLock<HashMap<String, PriceEntry>>>, )

async fn handle_message( text: &str, prices: &Arc<RwLock<HashMap<String, PriceEntry>>>, )

Trait Implementations

impl Service for HyperliquidWsFeed

fn name(&self) -> &'static str

fn owner(&self) -> ServiceOwner

fn run<'async_trait>( self: Arc<Self>, shutdown: ShutdownRx, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait,

fn initialize<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,