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

use crate::*;

use futures_util::TryFutureExt;
use serde::Deserialize;

pub type GenericError = Box<dyn std::error::Error + Send + Sync>;

#[allow(non_snake_case)]
#[derive(Deserialize, Default, Clone, Debug)]
pub struct BinanceTicker {
    pub symbol: String,
    pub price: Decimal,
}

pub struct BinanceApi {}

impl BinanceApi {
    pub async fn fetch_spot_prices(
        symbol: Option<String>,
    ) -> Result<Vec<BinanceTicker>, GenericError> {
        let mut binance_spot: Vec<BinanceTicker> =
            reqwest::get("https://www.binance.com/api/v3/ticker/price")
                .and_then(|r| r.json())
                .await?;
        if let Some(symbol) = symbol {
            binance_spot = binance_spot
                .into_iter()
                .filter(|x| x.symbol == symbol)
                .collect()
        }
        Ok(binance_spot)
    }
}