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

use crate::{
    multiaddr::Multiaddr,
    runtime::TcpStream,
    service::config::TcpSocketConfig,
    transports::{Result, TransportDial, TransportFuture, onion_dial},
};
use futures::future::ok;
use std::{future::Future, pin::Pin, time::Duration};

/// Onion connect
async fn connect(
    onion_address: impl Future<Output = Result<Multiaddr>>,
    timeout: Duration,
    tcp_config: TcpSocketConfig,
) -> Result<(Multiaddr, TcpStream)> {
    let onion_addr = onion_address.await?;
    let stream = onion_dial(onion_addr.clone(), tcp_config, timeout).await?;
    Ok((onion_addr, stream))
}

/// Onion transport
pub struct OnionTransport {
    timeout: Duration,
    tcp_config: TcpSocketConfig,
}

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

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

impl TransportDial for OnionTransport {
    type DialFuture = OnionDialFuture;

    fn dial(self, address: Multiaddr) -> Result<Self::DialFuture> {
        let dial = connect(ok(address), self.timeout, self.tcp_config);
        Ok(TransportFuture::new(Box::pin(dial)))
    }
}