clearstreet 0.1.26

Clear Street SDK for Rust
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 reqwest::{Response};
use crate::error::{Error, ErrorType};

fn parse<T: serde::de::DeserializeOwned>(text: String) -> Result<T, Error> {
    tracing::debug!("Response: {:?}", text);

    match serde_json::from_str::<T>(&text) {
        Ok(parsed) => Ok(parsed),
        Err(e) => {
            tracing::error!("Error parsing response: {}", e);
            Err(e.into())
        }
    }
}

pub async fn parse_response<T: serde::de::DeserializeOwned>(response: Response) -> Result<T, Error> {
    let text = response.text().await.map_err(|e| {
        tracing::error!("Error parsing response to text: {}", e);
        Error::new(ErrorType::ParseError, &e.to_string())
    })?;

    parse(text)
}

#[cfg(feature = "sync")]
pub fn parse_response_blocking<T: serde::de::DeserializeOwned>(response: reqwest::blocking::Response) -> Result<T, Error> {
    let text = response.text().map_err(|e| {
        tracing::error!("Error parsing response to text: {}", e);
        Error::new(ErrorType::ParseError, &e.to_string())
    })?;

    parse(text)
}