tentacle 0.7.5

Minimal implementation for a multiplexed p2p network framework.
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 super::Result;
use futures::{TryFutureExt, future::ok};
use std::{future::Future, pin::Pin, time::Duration};

use crate::service::TlsConfig;
use crate::{
    error::TransportErrorKind,
    multiaddr::Multiaddr,
    service::config::TcpSocketConfig,
    session::AsyncRw,
    transports::{TransportDial, TransportFuture, parse_tls_domain_name, tcp_dial},
    utils::{dns::DnsResolver, multiaddr_to_socketaddr},
};

use tokio_rustls::TlsConnector;
use tokio_rustls::rustls::pki_types::ServerName;

pub type TlsStream = Box<dyn AsyncRw + Send + Unpin + 'static>;

/// Tls connect
async fn connect(
    address: impl Future<Output = Result<Multiaddr>>,
    timeout: Duration,
    original: Option<Multiaddr>,
    config: TlsConfig,
    domain_name: String,
    tcp_config: TcpSocketConfig,
) -> Result<(Multiaddr, TlsStream)> {
    let tls_client_config = config
        .tls_client_config
        .ok_or_else(|| TransportErrorKind::TlsError("client config not found".to_string()))?;

    let addr = address.await?;
    match multiaddr_to_socketaddr(&addr) {
        Some(socket_address) => {
            let stream = tcp_dial(socket_address, tcp_config, timeout).await?;

            let domain_name = ServerName::try_from(domain_name)
                .map_err(|_| TransportErrorKind::TlsError("invalid dnsname".to_string()))?;
            let connector = TlsConnector::from(tls_client_config);
            Ok((
                original.unwrap_or(addr),
                Box::new(
                    connector
                        .connect(domain_name, stream)
                        .await
                        .map_err(TransportErrorKind::Io)?,
                ),
            ))
        }
        None => Err(TransportErrorKind::NotSupported(original.unwrap_or(addr))),
    }
}

/// Tcp transport
pub struct TlsTransport {
    timeout: Duration,
    config: TlsConfig,
    tcp_config: TcpSocketConfig,
}

impl TlsTransport {
    pub fn new(timeout: Duration, config: TlsConfig, tcp_config: TcpSocketConfig) -> Self {
        TlsTransport {
            timeout,
            config,
            tcp_config,
        }
    }
}

pub type TlsDialFuture =
    TransportFuture<Pin<Box<dyn Future<Output = Result<(Multiaddr, TlsStream)>> + Send>>>;

impl TransportDial for TlsTransport {
    type DialFuture = TlsDialFuture;

    fn dial(self, address: Multiaddr) -> Result<Self::DialFuture> {
        if let Some(domain_name) = parse_tls_domain_name(&address) {
            match DnsResolver::new(address.clone()) {
                Some(dns) => {
                    // Why do this?
                    // Because here need to save the original address as an index to open the specified protocol.
                    let task = connect(
                        dns.map_err(|(multiaddr, io_error)| {
                            TransportErrorKind::DnsResolverError(multiaddr, io_error)
                        }),
                        self.timeout,
                        Some(address),
                        self.config,
                        domain_name,
                        self.tcp_config,
                    );
                    Ok(TransportFuture::new(Box::pin(task)))
                }
                None => {
                    let dial = connect(
                        ok(address),
                        self.timeout,
                        None,
                        self.config,
                        domain_name,
                        self.tcp_config,
                    );
                    Ok(TransportFuture::new(Box::pin(dial)))
                }
            }
        } else {
            Err(TransportErrorKind::NotSupported(address))
        }
    }
}