hyperdht 0.1.1

Rust implementation of hyperdht, peer announcements and connections on top of dht-rpc
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

use dht_rpc::{DhtConfig, Peer, QueryArgs, commands};
use test_utils::{Result, Testnet, log};

macro_rules! rpc_setup {
    () => {{
        let mut tn = Testnet::new().await?;
        let bs_addr = tn.get_node_i_address(1).await?;
        let rpc =
            dht_rpc::Rpc::with_config(DhtConfig::default().add_bootstrap_node(bs_addr)).await?;
        (tn, rpc)
    }};
}

// TODO move this to rpc crate. (Which requiress giving it it's own js-repl tests
#[tokio::test]
async fn test_async_rpc_request_ping() -> Result<()> {
    let (mut tn, rpc) = rpc_setup!();
    let _pub_key: Vec<u8> = tn
        .repl
        .run_tcp(
            "
server_addr = deferred();


server_node = testnet.nodes[testnet.nodes.length - 1];
server = server_node.createServer();
server.on('listening', () => {
    server_addr.resolve(server.address().port)
});

pub_key  = server_node.defaultKeyPair.publicKey;;
outputJson([...pub_key]);
",
        )
        .await?;
    let port: usize = tn
        .repl
        .json_run_tcp("outputJson(server.dht.io.serverSocket._port)")
        .await?;
    // For FIND_NODE test
    //let idbytes: Vec<u8> = tn
    //    .repl
    //    .json_run_tcp("outputJson([...server.dht.id])")
    //    .await?;
    //let idbytes: [u8; 32] = idbytes.try_into().unwrap();
    //let command = commands::PING_NAT;
    //let command = commands::FIND_NODE;
    //let x = rpc.request(command, Some(idbytes), None, destination, None).await?;
    //let command = commands::DOWN_HINT;
    let command = commands::PING;
    let addr = format!("127.0.0.1:{port}");
    let destination: Peer = addr.parse()?;
    let x = rpc.request(command, None, None, destination, None).await?;
    assert_eq!(x.request.command, command);
    Ok(())
}
#[tokio::test]
async fn test_async_rpc_query_find_node() -> Result<()> {
    let (mut tn, rpc) = rpc_setup!();
    let _pub_key: Vec<u8> = tn
        .repl
        .run_tcp(
            "
server_addr = deferred();


server_node = testnet.nodes[testnet.nodes.length - 1];
server = server_node.createServer();
server.on('listening', () => {
    server_addr.resolve(server.address().port)
});

pub_key  = server_node.defaultKeyPair.publicKey;;
outputJson([...pub_key]);
",
        )
        .await?;
    let _port: usize = tn
        .repl
        .json_run_tcp("outputJson(server.dht.io.serverSocket._port)")
        .await?;
    // For FIND_NODE test
    let idbytes: Vec<u8> = tn
        .repl
        .json_run_tcp("outputJson([...server.dht.id])")
        .await?;
    let idbytes: [u8; 32] = idbytes.try_into().unwrap();
    let command = hyperdht::commands::FIND_PEER;
    log();
    let _x = rpc.query(QueryArgs::new(command, idbytes.into())).await?;
    //assert_eq!(x.request.command, command);
    Ok(())
}