kitsune_p2p_proxy 0.0.7

Proxy transport module for kitsune-p2p
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

use ghost_actor::dependencies::tracing;
use kitsune_p2p_proxy::*;
use kitsune_p2p_types::config::KitsuneP2pTuningParams;
use kitsune_p2p_types::dependencies::ghost_actor;
use kitsune_p2p_types::transport::*;

fn init_tracing() {
    let _ = ghost_actor::dependencies::tracing::subscriber::set_global_default(
        tracing_subscriber::FmtSubscriber::builder()
            .with_env_filter(tracing_subscriber::EnvFilter::from_default_env())
            .finish(),
    );
}

#[tokio::test(flavor = "multi_thread")]
async fn test_no_proxy() {
    if let Err(e) = test_inner().await {
        panic!("{:?}", e);
    }
}

async fn test_inner() -> TransportResult<()> {
    init_tracing();

    const FAKE_ADDR: &'static str = "kitsune-proxy://FAKEFAKEFAKEFAKEFAKEFAKEFAKEFAKEFAKEFAKEFAK/kitsune-mem/h/FAKEFAKEFAKEFAKEFAKEF/--";

    let proxy_config =
        ProxyConfig::remote_proxy_client(TlsConfig::new_ephemeral().await?, FAKE_ADDR.into());

    let (bind, evt) = kitsune_p2p_types::transport_mem::spawn_bind_transport_mem().await?;
    let (_bind, _evt) =
        spawn_kitsune_proxy_listener(proxy_config, KitsuneP2pTuningParams::default(), bind, evt)
            .await?;

    tracing::warn!("TEST COMPLETE");

    Ok(())
}