hrpc 0.33.29

Common code for hRPC.
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

use std::{
    error::Error as StdError,
    fmt::{self, Display, Formatter},
};

use http::{HeaderMap, Uri};

#[cfg(feature = "http_hyper_client")]
pub mod hyper;
use crate::common::extensions::Extensions;

#[cfg(feature = "http_hyper_client")]
pub use self::hyper::{Hyper, HyperError};

#[cfg(feature = "http_wasm_client")]
pub mod wasm;
#[cfg(feature = "http_wasm_client")]
pub use self::wasm::{Wasm, WasmError};

/// Clones HTTP extensions that will be added from a hRPC request to a HTTP
/// request. Intended for use with [`crate::client::layer::backoff`].
pub fn clone_http_extensions(from: &Extensions, to: &mut Extensions) {
    if let Some(header_map) = from.get::<HeaderMap>().cloned() {
        to.insert(header_map);
    }
}

/// Check if a URI is a valid server URI or not.
fn check_uri(uri: Uri) -> Result<Uri, InvalidServerUrl> {
    matches!(uri.scheme_str(), Some("https" | "http"))
        .then(|| uri)
        .ok_or(InvalidServerUrl::InvalidScheme)
}

/// Map a scheme that can be `https` or `http` to `wss` or `ws` respectively.
fn map_scheme_to_ws(scheme: &str) -> Option<&'static str> {
    match scheme {
        "https" => Some("wss"),
        "http" => Some("ws"),
        _ => None,
    }
}

#[derive(Debug)]
/// Errors that can occur while parsing a URL when creating a client.
pub enum InvalidServerUrl {
    /// Occurs if URL scheme isn't `http` or `https`.
    InvalidScheme,
}

impl Display for InvalidServerUrl {
    fn fmt(&self, f: &mut Formatter) -> fmt::Result {
        match self {
            InvalidServerUrl::InvalidScheme => {
                write!(f, "invalid scheme, expected `http` or `https`")
            }
        }
    }
}

impl StdError for InvalidServerUrl {}