switchboard-utils 0.10.0

Switchboard utilities for custom functions and OracleJob protobuf definitions
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
80
81
82
83
84
85
86

use crate::*;

use futures_util::TryFutureExt;

use serde::Deserialize;

#[allow(dead_code)]
#[derive(Debug, Deserialize, Clone)]
struct HuobiMarketData {
    pub ch: String,
    pub status: String,
    pub ts: i64,
    pub tick: HuobiTickerInfo,
}

#[derive(Debug, Clone, Deserialize)]
pub struct HuobiTickerInfo {
    pub id: i64,
    pub version: i64,
    pub open: f64,
    pub close: f64,
    pub low: f64,
    pub high: f64,
    pub amount: f64,
    pub vol: f64,
    pub count: i64,
    pub bid: (f64, f64),
    pub ask: (f64, f64),
}

pub struct HuobiApi {}

impl HuobiApi {
    // https://api.huobi.pro/market/detail/merged?symbol=btcusdt
    fn get_ticker_url(ticker: &str, url: Option<&str>) -> String {
        format!(
            "{}/market/detail/merged?symbol={}",
            url.unwrap_or("https://api.huobi.pro"),
            ticker
        )
    }

    pub async fn fetch_ticker(ticker: &str, url: Option<&str>) -> Result<HuobiTickerInfo, SbError> {
        let ticker_url = HuobiApi::get_ticker_url(ticker, url);

        let response: HuobiMarketData = reqwest::get(&ticker_url)
            .and_then(|r| r.json())
            .await
            .map_err(handle_reqwest_err)?;

        Ok(response.tick)
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    const MOCK_HUOBI_RESPONSE: &str = r#"{"ch":"market.btcusdt.detail.merged","status":"ok","ts":1696450585149,"tick":{"id":330331957961,"version":330331957961,"open":27346.88,"close":27703.8,"low":27204.95,"high":27835.9,"amount":4105.804118401724,"vol":1.1280903302844201E8,"count":557808,"bid":[27699.26,1.218876],"ask":[27699.27,0.32722]}}"#;

    #[tokio::test]
    async fn test_huobi_api() {
        // Request a new server from the pool
        let mut server = mockito::Server::new();
        let server_url = server.url();

        // Create a mock
        let _mock = server
            .mock("GET", "/market/detail/merged?symbol=btcusdt")
            .with_status(201)
            .with_header("content-type", "application/json")
            .with_body(MOCK_HUOBI_RESPONSE)
            .create();

        let _ticker = HuobiApi::fetch_ticker("btcusdt", Some(server_url.as_str()))
            .await
            .unwrap();
        // TODO: fix test
        // println!("{:?}", ticker);

        // verify the mock was called
        // mock.assert();
        //
        // assert_eq!(ticker.open, 27346.88);
    }
}