iris-chat 0.1.65

Iris Chat command line client and shared encrypted chat core
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
94
95
96
97
98
99

use super::*;

#[test]
fn relay_publish_burst_does_not_replay_acknowledged_nearby_backlog() {
    let transport_keys = Keys::generate();
    let owner = Keys::generate();
    let device = Keys::generate();
    let recipient = Keys::generate().public_key();
    let recipient_npub = recipient.to_bech32().unwrap();
    let mut core = logged_in_test_core("nearby-publish-burst", &owner, &device);
    let mut config = fips_core::Config::new();
    config.node.control.enabled = false;
    config.node.discovery.lan.enabled = false;
    config.node.discovery.nostr.enabled = false;
    let endpoint = Arc::new(core.runtime.block_on(async {
        fips_core::FipsEndpoint::builder()
            .config(config)
            .without_system_tun()
            .bind()
            .await
            .unwrap()
    }));
    let (tcp, _records) = DeviceSyncTcpSender::test_channel(4, 1024);
    core.install_device_sync_sender_for_test(endpoint.clone(), tcp, Vec::new());
    core.device_sync.as_mut().unwrap().nearby_enabled = true;
    core.preferences.nearby_enabled = true;
    core.preferences.nearby_mailbag_enabled = true;
    // Keep server work in flight while new protocol responses are enqueued.
    core.logged_in.as_mut().unwrap().relay_urls =
        vec![RelayUrl::parse("ws://127.0.0.1:1").unwrap()];
    core.relay_transport_runtime.publish_drain_in_flight = true;
    core.relay_transport_runtime.publish_drain_started_at = Some(Instant::now());
    let event = EventBuilder::new(Kind::Custom(1060), "earlier control")
        .tag(nostr::Tag::parse(["v", "2"]).unwrap())
        .tag(nostr::Tag::parse(["header", "test"]).unwrap())
        .sign_with_keys(&transport_keys)
        .unwrap();
    assert!(core.publish_pairwise_runtime_event_for_test(
        event.clone(),
        APPCORE_PROTOCOL_LABEL,
        None,
        recipient,
    ));
    let outbox = core.device_sync.as_ref().unwrap().nearby_outbox.clone();
    outbox
        .write()
        .unwrap()
        .acknowledge(&recipient_npub, &event.id.to_hex());
    for index in 0..20 {
        let next = EventBuilder::new(Kind::Custom(1060), format!("new control {index}"))
            .tag(nostr::Tag::parse(["v", "2"]).unwrap())
            .tag(nostr::Tag::parse(["header", "test"]).unwrap())
            .sign_with_keys(&transport_keys)
            .unwrap();
        assert!(core.publish_pairwise_runtime_event_for_test(
            next,
            APPCORE_PROTOCOL_LABEL,
            None,
            recipient,
        ));
    }
    let pending = outbox.read().unwrap().pending_for_link(&recipient_npub, 1);
    assert_eq!(
        pending.len(),
        20,
        "new packets must still be sent immediately"
    );
    assert!(
        !pending.iter().any(|(id, _)| id == &event.id.to_hex()),
        "each new publication must not resurrect the entire nearby backlog"
    );
    assert_eq!(
        core.pending_relay_publishes.len(),
        21,
        "nearby delivery must preserve outstanding server persistence"
    );
    core.relay_transport_runtime.nearby_replay_started_at =
        Some(Instant::now() - Duration::from_secs(3));
    core.retry_pending_relay_publishes("scheduled_retry");
    assert_eq!(
        outbox
            .read()
            .unwrap()
            .pending_for_link(&recipient_npub, 1)
            .len(),
        20,
        "server persistence retries must not resend to a peer that acknowledged the event"
    );
    assert_eq!(
        outbox
            .read()
            .unwrap()
            .pending_for_link("later-peer", 1)
            .len(),
        0,
        "private retries must never send another recipient's envelope to a later peer"
    );
    core.runtime.block_on(endpoint.shutdown()).unwrap();
}