Struct BlocklessHttp

pub struct BlocklessHttp { /* private fields */ }

Implementations

impl BlocklessHttp

pub fn open(url: &str, opts: &HttpOptions) -> Result<Self, HttpErrorKind>

Examples found in repository

examples/httpbin.rs (line 10)

fn main() {
    let mut opts = HttpOptions::new("GET", 30, 10);
    opts.headers = Some(std::collections::BTreeMap::from([(
        "X-Test".to_string(),
        "123".to_string(),
    )]));

    let http = BlocklessHttp::open("http://httpbin.org/anything", &opts);
    let http = http.unwrap();
    let body = http.get_all_body().unwrap();
    let body = String::from_utf8(body).unwrap();
    let bodies = match json::parse(&body).unwrap() {
        json::JsonValue::Object(o) => o,
        _ => panic!("must be object"),
    };

    let headers = match bodies.get("headers") {
        Some(json::JsonValue::Object(headers)) => headers,
        _ => panic!("must be array"),
    };
    headers.iter().for_each(|s| {
        println!("{} = {}", s.0, s.1);
    });
}

examples/coingecko_oracle.rs (lines 23-30)

fn main() {
    // read coin id from stdin
    let mut buf = [0; 1024];
    let len = read_stdin(&mut buf).unwrap();
    let coin_id = std::str::from_utf8(&buf[..len as usize])
        .unwrap_or_default()
        .trim();

    // perform http request
    let http_opts = HttpOptions::new("GET", 30, 10);
    let http_res = BlocklessHttp::open(
        format!(
            "https://api.coingecko.com/api/v3/simple/price?ids={}&vs_currencies=usd",
            coin_id
        )
        .as_str(),
        &http_opts,
    )
    .unwrap();
    let body = http_res.get_all_body().unwrap(); // e.g. {"bitcoin":{"usd":67675}}

    // println!("{}", String::from_utf8(body.clone()).unwrap());

    // parse the json response; extrac usd price
    let json: serde_json::Result<HashMap<String, HashMap<String, f64>>> =
        serde_json::from_slice(&body);
    let Ok(data) = json else {
        eprintln!("Failed to parse JSON");
        return;
    };
    let Some(coin_data) = data.get(coin_id) else {
        eprintln!("Coin not found in response.");
        return;
    };
    let Some(usd_price) = coin_data.get("usd") else {
        eprintln!("USD price not found for {}.", coin_id);
        return;
    };

    let coin_price = CoinPrice {
        id: coin_id.to_string(),
        price: (*usd_price * 1_000_000.0) as u64, // price in 6 decimals
        currency: "usd".to_string(),
    };
    println!("{}", json!(coin_price));
}

pub fn get_code(&self) -> u32

pub fn get_all_body(&self) -> Result<Vec<u8>, HttpErrorKind>

Examples found in repository

examples/httpbin.rs (line 12)

fn main() {
    let mut opts = HttpOptions::new("GET", 30, 10);
    opts.headers = Some(std::collections::BTreeMap::from([(
        "X-Test".to_string(),
        "123".to_string(),
    )]));

    let http = BlocklessHttp::open("http://httpbin.org/anything", &opts);
    let http = http.unwrap();
    let body = http.get_all_body().unwrap();
    let body = String::from_utf8(body).unwrap();
    let bodies = match json::parse(&body).unwrap() {
        json::JsonValue::Object(o) => o,
        _ => panic!("must be object"),
    };

    let headers = match bodies.get("headers") {
        Some(json::JsonValue::Object(headers)) => headers,
        _ => panic!("must be array"),
    };
    headers.iter().for_each(|s| {
        println!("{} = {}", s.0, s.1);
    });
}

examples/coingecko_oracle.rs (line 32)

fn main() {
    // read coin id from stdin
    let mut buf = [0; 1024];
    let len = read_stdin(&mut buf).unwrap();
    let coin_id = std::str::from_utf8(&buf[..len as usize])
        .unwrap_or_default()
        .trim();

    // perform http request
    let http_opts = HttpOptions::new("GET", 30, 10);
    let http_res = BlocklessHttp::open(
        format!(
            "https://api.coingecko.com/api/v3/simple/price?ids={}&vs_currencies=usd",
            coin_id
        )
        .as_str(),
        &http_opts,
    )
    .unwrap();
    let body = http_res.get_all_body().unwrap(); // e.g. {"bitcoin":{"usd":67675}}

    // println!("{}", String::from_utf8(body.clone()).unwrap());

    // parse the json response; extrac usd price
    let json: serde_json::Result<HashMap<String, HashMap<String, f64>>> =
        serde_json::from_slice(&body);
    let Ok(data) = json else {
        eprintln!("Failed to parse JSON");
        return;
    };
    let Some(coin_data) = data.get(coin_id) else {
        eprintln!("Coin not found in response.");
        return;
    };
    let Some(usd_price) = coin_data.get("usd") else {
        eprintln!("USD price not found for {}.", coin_id);
        return;
    };

    let coin_price = CoinPrice {
        id: coin_id.to_string(),
        price: (*usd_price * 1_000_000.0) as u64, // price in 6 decimals
        currency: "usd".to_string(),
    };
    println!("{}", json!(coin_price));
}

pub fn get_header(&self, header: &str) -> Result<String, HttpErrorKind>

pub fn close(self)

pub fn read_body(&self, buf: &mut [u8]) -> Result<u32, HttpErrorKind>

Trait Implementations

impl Drop for BlocklessHttp

fn drop(&mut self)

Executes the destructor for this type.