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

//! Given some known good values (they came from adding `console.log(...)` in JS hyperdht)
//! Check that the signature RS creates from values is verified by JS
//! And likewise JS signature is verified by RS
use dht_rpc::IdBytes;
use rusty_nodejs_repl::Repl;
use test_utils::{Result, make_repl};

const VALUE: &[u8] = &[
    5, 206, 205, 109, 15, 42, 98, 66, 107, 27, 31, 54, 201, 136, 155, 42, 245, 234, 210, 154, 31,
    11, 151, 222, 135, 63, 208, 92, 4, 74, 24, 20, 109, 0, 49, 107, 254, 99, 36, 124, 108, 65, 174,
    60, 38, 12, 182, 110, 6, 215, 255, 19, 177, 141, 34, 177, 44, 213, 226, 206, 148, 246, 168,
    179, 176, 33, 117, 139, 191, 54, 19, 232, 12, 218, 55, 26, 107, 78, 178, 76, 252, 175, 89, 204,
    117, 165, 89, 32, 234, 143, 60, 157, 40, 233, 236, 239, 41, 8,
];
const TOKEN: [u8; 32] = [
    36, 6, 6, 155, 30, 71, 106, 67, 42, 98, 245, 4, 186, 36, 240, 5, 122, 103, 150, 70, 158, 158,
    55, 38, 154, 45, 194, 191, 37, 14, 50, 21,
];
const ID: [u8; 32] = [
    144, 142, 182, 97, 170, 104, 69, 6, 221, 242, 249, 208, 96, 76, 57, 128, 126, 140, 89, 26, 115,
    131, 139, 110, 211, 183, 214, 39, 134, 156, 128, 165,
];

const TARGET: &[u8] = &[
    104, 101, 108, 108, 111, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
    0, 0, 0, 0,
];

#[tokio::test]
async fn check_in_js_known_good_sig_created_in_js() -> Result<()> {
    let target: IdBytes = TryInto::<[u8; 32]>::try_into(TARGET).unwrap().into();

    let mut repl = make_repl().await;
    let _res = repl
        .run_tcp(
            "
Persistent = require('hyperdht/lib/persistent.js');
output(Persistent.prototype.verifyAnnounce.toString())
",
        )
        .await?;

    js_list_from_rs_vec(&mut repl, VALUE, "value").await?;
    js_list_from_rs_vec(&mut repl, target.0.as_slice(), "target").await?;
    js_list_from_rs_vec(&mut repl, &TOKEN, "token").await?;
    js_list_from_rs_vec(&mut repl, &ID, "id").await?;

    let res = repl
        .run_tcp(
            "
res = Persistent.prototype.verifyAnnounce({ value, target, token }, id);
output(res.toString());
",
        )
        .await?;

    assert_eq!(res, b"true");

    //println!("{}", String::from_utf8_lossy(&res));
    println!("{}", String::from_utf8_lossy(&res));
    Ok(())
}
async fn js_list_from_rs_vec(repl: &mut Repl, arr: &[u8], name: &str) -> Result<()> {
    let elments_str = arr
        .iter()
        .map(|e| format!("{e}"))
        .collect::<Vec<String>>()
        .join(",");
    let code = format!("{name} = Buffer.from([{elments_str}]);");
    repl.run_tcp(code).await?;
    Ok(())
}