dht-rpc 0.0.2

rust implementation of the DHT powering the hyperswarm stack
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

use std::{net::ToSocketAddrs, sync::OnceLock};

use futures::StreamExt;

use crate::{DEFAULT_BOOTSTRAP, DhtConfig, Peer, RpcInner};

use super::RpcEvent;

#[allow(unused)]
pub fn log() {
    static START_LOGS: OnceLock<()> = OnceLock::new();
    START_LOGS.get_or_init(|| {
        tracing_subscriber::fmt()
            .with_line_number(true)
            .without_time()
            // Reads `RUST_LOG` environment variable
            .with_env_filter(tracing_subscriber::EnvFilter::from_default_env())
            .init();
    });
}

#[tokio::test]
#[ignore] // slow??? also should be integration test
async fn bootstrap() -> crate::Result<()> {
    let conf = DhtConfig::default()
        .add_bootstrap_node(DEFAULT_BOOTSTRAP[0].to_socket_addrs()?.last().unwrap());

    let mut rpc = RpcInner::with_config(conf).await?;

    rpc.bootstrap();
    let mut i = 0;
    loop {
        if let Some(RpcEvent::QueryResult { .. }) = rpc.next().await {
            break;
        };
        dbg!(i);
        i += 1;
    }
    println!("# events {i}");

    Ok(())
}

#[tokio::test]
#[ignore]
async fn ping() -> crate::Result<()> {
    let conf = DhtConfig::default()
        .add_bootstrap_node(DEFAULT_BOOTSTRAP[0].to_socket_addrs()?.last().unwrap());

    let mut rpc = RpcInner::with_config(conf).await?;

    rpc.bootstrap();
    let mut i = 0;
    loop {
        if let Some(RpcEvent::QueryResult { .. }) = rpc.next().await {
            break;
        };
        i += 1;
    }
    log();

    rpc.ping(&Peer {
        addr: "170.187.185.104:60531".parse()?,
        id: None,
        referrer: None,
    });
    println!("PING_DONE");

    loop {
        let x = rpc.next().await;
        dbg!(x);
        dbg!(i);
        i += 1;
    }
}