iris-chat 0.1.67

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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121

// Offline members recover their own recipient-specific ratchet carrier from
// the sender's durable queue. Another group member never serves shared group traffic.

use super::*;

#[test]
fn private_group_recipient_delivery_survives_sender_restart_while_member_offline() {
    let mut farm = GroupScaleFarm::new(&[1, 1, 1]);
    farm.pump();
    let members = farm.owners[1..]
        .iter()
        .map(|owner| owner.public_key().to_hex())
        .collect::<Vec<_>>();
    farm.devices[0]
        .core
        .create_group("offline private group", &members);
    let group_id = farm.devices[0].core.groups.keys().next().unwrap().clone();
    let chat_id = group_chat_id(&group_id);
    farm.pump();
    for device in &mut farm.devices {
        device.core.accept_message_request(&chat_id);
    }
    farm.send(0, &chat_id, "private group bootstrap");
    farm.pump();
    farm.devices[2].online = false;
    let body = "attachment message while C is offline";
    let (message_id, _) = farm.send(0, &chat_id, body);
    let pending = farm.devices[0]
        .core
        .pending_relay_publishes
        .values()
        .filter(|pending| pending.inner_event_id.as_deref() == Some(message_id.as_str()))
        .filter_map(|pending| serde_json::from_str::<Event>(&pending.event_json).ok())
        .collect::<Vec<_>>();
    assert_eq!(
        pending.len(),
        1,
        "offline and online members read the same signed event"
    );
    let carrier = pending[0].clone();
    assert!(farm.devices[0]
        .core
        .protocol_engine
        .as_ref()
        .unwrap()
        .is_known_group_sender_event_author(carrier.pubkey));
    let wire = serde_json::to_string(&carrier).unwrap();
    for device in &farm.devices {
        assert!(!wire.contains(&device.keys.public_key().to_hex()));
    }
    for owner in &farm.owners {
        assert!(!wire.contains(&owner.public_key().to_hex()));
    }
    assert!(!wire.contains(&group_id));
    assert!(!farm.devices[2].core.threads[&chat_id]
        .messages
        .iter()
        .any(|message| message.id == message_id));
    assert!(
        !farm.history.iter().any(|event| event.id == carrier.id),
        "restart occurs before the recipient carrier has reached any relay"
    );

    let owner = farm.owners[0].clone();
    let keys = farm.devices[0].keys.clone();
    let path = farm.devices[0].core.data_dir.to_string_lossy().into_owned();
    farm.devices[0].core.preferences.nostr_relay_urls.clear();
    farm.devices[0].core.preferences.nearby_lan_enabled = false;
    farm.devices[0].core.preferences.nearby_bluetooth_enabled = false;
    farm.devices[0].core.persist_app_state().unwrap();
    farm.devices[0].core.stop_device_sync_now();
    let placeholder = logged_in_test_core("private-group-restart-placeholder", &owner, &keys);
    let previous = std::mem::replace(&mut farm.devices[0].core, placeholder);
    drop(previous);
    let mut restored = logged_in_test_core_at_data_dir(&owner, &keys, path);
    restored
        .start_session_inner(
            owner.public_key(),
            Some(owner.clone()),
            keys,
            true,
            true,
            true,
        )
        .unwrap();
    restored.stop_device_sync_now();
    let recovered = restored
        .pending_relay_publishes
        .get(&carrier.id.to_hex())
        .expect("sender restart retains C's exact queued private carrier");
    assert_eq!(
        serde_json::from_str::<Event>(&recovered.event_json).unwrap(),
        carrier
    );
    farm.devices[0].core = restored;
    farm.devices[2].online = true;
    farm.pump();
    for _ in 0..2 {
        farm.devices[2].core.handle_relay_event(carrier.clone());
    }
    let received = farm.devices[2].core.threads[&chat_id]
        .messages
        .iter()
        .filter(|message| message.id == message_id)
        .collect::<Vec<_>>();
    assert_eq!(
        received.len(),
        1,
        "restarted queue and duplicate delivery display exactly once"
    );
    assert_eq!(received[0].body, body);
    assert_eq!(
        received[0].source_event_id.as_deref(),
        Some(carrier.id.to_hex().as_str())
    );
    assert_eq!(
        received[0].author_owner_pubkey_hex.as_deref(),
        Some(owner.public_key().to_hex().as_str())
    );
    assert!(!received[0].is_outgoing);
}