ibc-relayer 0.32.2

Implementation of an IBC Relayer in Rust, as a library 
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

mod block_on;
pub use block_on::{block_on, spawn_blocking};

pub mod collate;
pub mod compat_mode;
pub mod debug_section;
pub mod diff;
pub mod excluded_sequences;
pub mod iter;
pub mod lock;
pub mod pretty;
pub mod profiling;
pub mod queue;
pub mod retry;
pub mod seq_range;
pub mod stream;
pub mod task;

/// Helper function to create a gRPC client.
pub async fn create_grpc_client<T>(
    grpc_addr: &tonic::transport::Uri,
    client_constructor: impl FnOnce(tonic::transport::Channel) -> T,
) -> Result<T, crate::error::Error> {
    let builder = tonic::transport::Channel::builder(grpc_addr.clone());

    // Don't configures TLS for the endpoint if using IPv6
    let builder = if grpc_addr.scheme() == Some(&http::uri::Scheme::HTTPS) {
        let domain = grpc_addr
            .host()
            .map(|d| d.replace(['[', ']'], ""))
            .ok_or_else(|| crate::error::Error::invalid_http_host(grpc_addr.to_string()))?;
        let tls_config = tonic::transport::ClientTlsConfig::new()
            .with_native_roots()
            .domain_name(domain);
        builder
            .tls_config(tls_config)
            .map_err(crate::error::Error::grpc_transport)?
    } else {
        builder
    };

    let channel = builder
        .connect()
        .await
        .map_err(crate::error::Error::grpc_transport)?;
    Ok(client_constructor(channel))
}