yog 0.0.76

yog: the standalone server for litany loops — the world, the balls and the conversations, behind one wire
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

//! The lines themselves: each says counts, seqs, nonces and families, and no
//! line built from addresses ever carries one.

use super::*;
use std::net::{Ipv4Addr, Ipv6Addr};

fn endpoints() -> Vec<SocketAddr> {
    vec![
        SocketAddr::new(IpAddr::V4(Ipv4Addr::new(203, 0, 113, 7)), 7737),
        SocketAddr::new(IpAddr::V6(Ipv6Addr::LOCALHOST), 7738),
        SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), 7739),
    ]
}

#[test]
fn every_line_is_the_house_shape_and_names_no_address() {
    let ips: Vec<IpAddr> = endpoints().iter().map(SocketAddr::ip).collect();
    let lines = [
        started(7737, 6881),
        published(1_700_000_000, 3, 2),
        not_published(),
        poll_failed(),
        unverified(4),
        unopened(5),
        seen(7),
        opened(7, &endpoints()),
        landed(7, &ips),
        expired(7, Duration::from_secs(20)),
        ended(7),
        accepted(ips.first().copied()),
        refused(ips.get(1).copied()),
    ];
    for line in &lines {
        assert!(line.starts_with("yog: rendezvous: "), "{line}");
        for addr in ["203.0.113", "127.0.0.1", "::1"] {
            assert!(!line.contains(addr), "{line} names {addr}");
        }
    }
    assert_eq!(
        opened(7, &endpoints()),
        "yog: rendezvous: call nonce 7 opened — 3 endpoint(s) (1 v6, 2 v4) — punch started"
    );
    assert_eq!(
        published(9, 2, 0),
        "yog: rendezvous: presence published — seq 9, 2 endpoint(s), 0 ack(s)"
    );
}

#[test]
fn families_count_v6_first_and_say_none_for_nothing() {
    assert_eq!(families(&[]), "none");
    assert_eq!(families(&[IpAddr::V6(Ipv6Addr::LOCALHOST)]), "1 v6");
    assert_eq!(families(&[IpAddr::V4(Ipv4Addr::LOCALHOST)]), "1 v4");
}

#[test]
fn an_accepted_stream_says_its_family_only() {
    let v6 = Some(IpAddr::V6(Ipv6Addr::LOCALHOST));
    assert_eq!(
        accepted(v6),
        "yog: rendezvous: stream accepted on the punch port (v6) — served"
    );
    assert_eq!(
        refused(None),
        "yog: rendezvous: stream on the punch port (family unknown) refused at the handshake — dropped"
    );
}

#[test]
fn the_engine_sink_writes_a_line() {
    stderr()("yog: rendezvous: a line the suite says on stderr");
}