camber 0.4.2

Opinionated async Rust for IO-bound services on top of Tokio
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

use super::rejection::SourceChain;

/// Strip surrounding double quotes from a header value (RFC 6265 / RFC 2616).
pub(crate) fn strip_quotes(v: &str) -> &str {
    match v.len() >= 2 && v.starts_with('"') && v.ends_with('"') {
        true => &v[1..v.len() - 1],
        false => v,
    }
}

/// Map reqwest errors to RuntimeError, detecting timeouts.
///
/// The whole cause chain is rendered into the message. `reqwest`'s own
/// `Display` states the kind and the URL and nothing else, and
/// `RuntimeError::Http` carries an `Arc<str>` with no source for a recorder to
/// walk — so a record built from `to_string` alone told an operator that a
/// request failed and never that the connection was refused, the name did not
/// resolve, the handshake was rejected, or the peer reset mid-head.
///
/// The walk itself is `SourceChain`, the one place this crate spells it.
/// Rendered eagerly here, unlike at the rejection record, because the value it
/// becomes is an owned `Arc<str>` on the error itself: the chain is walked
/// once, where the source is still reachable, and every later reader gets the
/// same text.
pub(crate) fn map_reqwest_error(e: reqwest::Error) -> crate::RuntimeError {
    match e.is_timeout() {
        true => crate::RuntimeError::Timeout,
        false => crate::RuntimeError::Http(SourceChain(&e).to_string().into()),
    }
}