volo 0.12.3

Volo is a high-performance and strong-extensibility Rust RPC framework that helps developers build microservices.
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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112

use std::{io, sync::Arc};

use native_tls::{Certificate, Identity};
use tokio::net::TcpStream;
use tokio_native_tls::{TlsAcceptor, TlsConnector};

use super::{Acceptor, Connector, TlsConnectorBuilder};

/// A wrapper for [`tokio_native_tls::TlsConnector`]
#[derive(Clone)]
pub struct NativeTlsConnector(pub(super) Arc<TlsConnector>);

/// A wrapper for [`tokio_native_tls::TlsAcceptor`]
#[derive(Clone)]
pub struct NativeTlsAcceptor(pub(super) Arc<TlsAcceptor>);

impl Default for NativeTlsConnector {
    fn default() -> Self {
        Self::build(TlsConnectorBuilder::default()).expect("Failed to create NativeTlsConnector")
    }
}

impl Connector for NativeTlsConnector {
    fn build(config: TlsConnectorBuilder) -> io::Result<Self> {
        let mut builder = native_tls::TlsConnector::builder();
        builder.disable_built_in_roots(!config.default_root_certs);
        for pem in config.pems {
            let cert = Certificate::from_pem(pem.as_ref())
                .map_err(|e| io::Error::new(io::ErrorKind::InvalidInput, e))?;
            builder.add_root_certificate(cert);
        }
        let alpn = config
            .alpn_protocols
            .iter()
            .map(AsRef::as_ref)
            .collect::<Vec<&str>>();
        builder.request_alpns(&alpn);
        let connector = builder
            .build()
            .map_err(|e| io::Error::new(io::ErrorKind::InvalidInput, e))?;
        Ok(Self(Arc::new(TlsConnector::from(connector))))
    }

    async fn connect(
        &self,
        server_name: &str,
        tcp_stream: TcpStream,
    ) -> io::Result<super::TlsStream> {
        tracing::trace!("NativeTlsConnector::connect({server_name})");
        match self.0.connect(server_name, tcp_stream).await {
            Ok(stream) => Ok(Into::into(stream)),
            Err(e) => Err(io::Error::new(io::ErrorKind::ConnectionRefused, e)),
        }
    }
}

impl Acceptor for NativeTlsAcceptor {
    fn from_pem(cert: Vec<u8>, key: Vec<u8>) -> io::Result<Self> {
        let identity = Identity::from_pkcs8(&cert, &key)
            .map_err(|e| io::Error::new(io::ErrorKind::InvalidInput, e))?;
        Ok(Self(Arc::new(
            native_tls::TlsAcceptor::builder(identity)
                .build()
                .map_err(|e| io::Error::new(io::ErrorKind::InvalidInput, e))?
                .into(),
        )))
    }

    async fn accept(&self, tcp_stream: TcpStream) -> io::Result<super::TlsStream> {
        tracing::trace!("NativeTlsAcceptor::accept");
        match self.0.accept(tcp_stream).await {
            Ok(stream) => Ok(Into::into(stream)),
            Err(e) => Err(io::Error::new(io::ErrorKind::ConnectionRefused, e)),
        }
    }
}

impl From<native_tls::TlsConnector> for super::TlsConnector {
    fn from(value: native_tls::TlsConnector) -> Self {
        Self::NativeTls(NativeTlsConnector(Arc::new(TlsConnector::from(value))))
    }
}

impl From<TlsConnector> for super::TlsConnector {
    fn from(value: TlsConnector) -> Self {
        Self::NativeTls(NativeTlsConnector(Arc::new(value)))
    }
}

impl From<Arc<TlsConnector>> for super::TlsConnector {
    fn from(value: Arc<TlsConnector>) -> Self {
        Self::NativeTls(NativeTlsConnector(value))
    }
}

impl From<native_tls::TlsAcceptor> for super::TlsAcceptor {
    fn from(value: native_tls::TlsAcceptor) -> Self {
        Self::NativeTls(NativeTlsAcceptor(Arc::new(TlsAcceptor::from(value))))
    }
}

impl From<TlsAcceptor> for super::TlsAcceptor {
    fn from(value: TlsAcceptor) -> Self {
        Self::NativeTls(NativeTlsAcceptor(Arc::new(value)))
    }
}

impl From<Arc<TlsAcceptor>> for super::TlsAcceptor {
    fn from(value: Arc<TlsAcceptor>) -> Self {
        Self::NativeTls(NativeTlsAcceptor(value))
    }
}