rhyperliquid 0.2.0

Rust SDK and client for the Hyperliquid exchange API
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

use alloy::primitives::SignatureError;
use std::{result::Result as StdResult, string::FromUtf8Error, sync::mpsc::SendError};
use thiserror::Error;
use tokio::sync::broadcast::error::RecvError;

use crate::{api::StreamMessage, types::ws::SubscriptionKey};

#[derive(Error, Debug)]
pub enum SubscriptionError {
    #[error("Subscription already exist for method {method}")]
    SubscriptionExist { method: String },
    #[error("Caller not subscribed to the {0} feed.")]
    MissingSubscription(SubscriptionKey),
}

#[derive(Error, Debug)]
pub enum HyperliquidError {
    #[error("{0}")]
    NetworkError(#[from] reqwest::Error),
    #[error("Failed to parse response body: {0}")]
    InvalidResponse(String),
    #[error("API error {status}: {body}")]
    Api { status: u16, body: String },
    #[error("Invalid request parameters for method '{method}' for parameter '{parameter}'.")]
    InvalidRequestParameter {
        method: String,
        parameter: String,
        reason: String,
    },
    #[error("{0}")]
    SubscriptionError(#[from] SubscriptionError),
    #[error("Function requires wallet/signer.")]
    SignerRequired,
    #[error("{0}")]
    SendError(#[from] SendError<StreamMessage>),
    #[error("{0}")]
    RecvError(#[from] RecvError),
    #[error("{0}")]
    WebSocketError(String),
    #[error("{0}")]
    AlloySignError(#[from] alloy::signers::Error),
    #[error("{0}")]
    RmpSerde(#[from] rmp_serde::encode::Error),
    #[error("{0}")]
    FromUtf8Error(#[from] FromUtf8Error),
    #[error("{0}")]
    IoError(#[from] std::io::Error),
    #[error("{0}")]
    TungsteniteError(#[from] tokio_tungstenite::tungstenite::Error),
    #[error("{0}")]
    SignatureError(#[from] SignatureError),
    #[error("Missing configuration for parameter {parameter}")]
    MissingConfiguration { parameter: String },
    #[error("{0}")]
    JsonSerialization(#[from] serde_json::Error),
    #[error["{0}"]]
    Internal(String),
    #[error["{0}"]]
    InvalidPrice(String),
    #[error["{0}"]]
    SignatureFailure(String),
    #[error["{0}"]]
    Wallet(String),
    #[error["{0}"]]
    GenericParse(String),
}

impl<T> From<tokio::sync::mpsc::error::SendError<T>> for HyperliquidError {
    fn from(e: tokio::sync::mpsc::error::SendError<T>) -> Self {
        Self::WebSocketError(format!("Channel send failed: {}", e))
    }
}

pub type Result<T> = StdResult<T, HyperliquidError>;