rings-node 0.20.0

Rings is a structured peer-to-peer network implementation using WebRTC, Chord algorithm, and full WebAssembly (WASM) support.
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

use super::*;

fn options() -> OnionHttpProxyOptions {
    OnionHttpProxyOptions::new(
        SocketAddr::from(([127, 0, 0, 1], 0)),
        OnionServiceName::tcp(),
        0,
        false,
    )
}

#[test]
fn test_connect_request_line_parses_target() -> Result<()> {
    let target = parse_connect_request_line("CONNECT Example.COM:443 HTTP/1.1")?;

    assert_eq!(target.authority(), "example.com:443");
    Ok(())
}

#[test]
fn test_connect_request_line_rejects_plain_http_request() {
    assert!(matches!(
        parse_connect_request_line("GET http://example.com/ HTTP/1.1"),
        Err(Error::HttpRequestError(_))
    ));
}

#[test]
fn test_proxy_options_build_custom_tcp_service_config() -> Result<()> {
    let mut options = options();
    options.service = OnionServiceName::parse("web")?;

    let proxy = options.proxy_config()?;

    assert_eq!(proxy.exit_service(), "web");
    Ok(())
}

#[test]
fn test_proxy_options_reject_unbounded_connection_model() {
    let mut zero_connections = options();
    zero_connections.max_connections = 0;
    assert!(matches!(
        zero_connections.validate(),
        Err(Error::InvalidConfig(_))
    ));

    let mut zero_timeout = options();
    zero_timeout.header_timeout = Duration::ZERO;
    assert!(matches!(
        zero_timeout.validate(),
        Err(Error::InvalidConfig(_))
    ));
}