myutil 7.3.0

Rust Util Collections
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
87
88
89
90
91

#![allow(missing_docs)]

use crate::*;
use reqwest::{
    blocking::{Client, ClientBuilder},
    StatusCode,
};
use std::{env, sync::LazyLock, time::Duration};

static TIME_OUT: LazyLock<Duration> = LazyLock::new(|| {
    let secs = if let Ok(t) = env::var("RUC_HTTP_TIMEOUT") {
        pnk!(t.parse::<u64>())
    } else {
        3
    };
    Duration::from_secs(secs)
});

pub fn get(
    url: &str,
    headers: Option<&[(&'static str, &'static str)]>,
) -> Result<(StatusCode, Vec<u8>)> {
    let mut builder = http_cli().get(url);
    if let Some(headers) = headers {
        for (h, v) in headers.iter().copied() {
            builder = builder.header(h, v);
        }
    }
    let resp = builder.send().c(d!(url))?;
    let code = resp.status();
    let msg = resp.bytes().c(d!())?;
    Ok((code, msg.into()))
}

pub fn get_resp_str(
    url: &str,
    headers: Option<&[(&'static str, &'static str)]>,
) -> Result<(StatusCode, String)> {
    get(url, headers)
        .c(d!())
        .map(|(code, msg)| (code, String::from_utf8_lossy(&msg).into_owned()))
}

pub fn post(
    url: &str,
    body: &[u8],
    headers: Option<&[(&'static str, &'static str)]>,
) -> Result<(StatusCode, Vec<u8>)> {
    let mut builder = http_cli().post(url);
    if let Some(headers) = headers {
        for (h, v) in headers.iter().copied() {
            builder = builder.header(h, v);
        }
    }
    let resp = builder.body(body.to_owned()).send().c(d!(url))?;
    let code = resp.status();
    let msg = resp.bytes().c(d!())?;
    Ok((code, msg.into()))
}

/// # Example
///
/// ```no_run
///    use ruc::*;
///
///    let url = "http://......";
///    let req = "...".as_bytes();
///    ruc::http::post_resp_str(
///        url,
///        req,
///        Some(&[("Content-Type", "application/json")]),
///    )
///    .unwrap();
/// ```
pub fn post_resp_str(
    url: &str,
    body: &[u8],
    headers: Option<&[(&'static str, &'static str)]>,
) -> Result<(StatusCode, String)> {
    post(url, body, headers)
        .c(d!())
        .map(|(code, msg)| (code, String::from_utf8_lossy(&msg).into_owned()))
}

fn http_cli() -> Client {
    ClientBuilder::new()
        .timeout(*TIME_OUT)
        .http1_only()
        .build()
        .unwrap()
}