iris-chat 0.1.50

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

use super::*;

impl AppCore {
    pub(super) fn group_snapshot_restores_removed_member(
        &self,
        current: &GroupSnapshot,
        incoming: &GroupSnapshot,
    ) -> bool {
        incoming.revision <= current.revision
            && self.logged_in.as_ref().is_some_and(|local| {
                let includes_local = |group: &GroupSnapshot| {
                    group
                        .members
                        .iter()
                        .any(|member| member.to_bytes() == local.owner_pubkey.to_bytes())
                };
                !includes_local(current) && includes_local(incoming)
            })
    }

    pub(super) fn is_removed_from_group(&self, chat_id: &str) -> bool {
        let Some(group) = parse_group_id_from_chat_id(chat_id).and_then(|id| self.groups.get(&id))
        else {
            return false;
        };
        self.logged_in.as_ref().is_some_and(|local| {
            !group
                .members
                .iter()
                .any(|member| member.to_bytes() == local.owner_pubkey.to_bytes())
        })
    }

    pub(super) fn reject_removed_group_send(&mut self, chat_id: &str) -> bool {
        if !self.is_removed_from_group(chat_id) {
            return false;
        }
        self.state.toast = Some("You’re no longer in this group.".to_string());
        self.emit_state();
        true
    }

    pub(super) fn discard_removed_group_publications(&mut self) {
        let removed = self
            .pending_relay_publishes
            .values()
            .filter(|pending| {
                pending.inner_event_id.is_some()
                    && pending
                        .chat_id
                        .as_deref()
                        .is_some_and(|id| self.is_removed_from_group(id))
            })
            .map(|pending| pending.event_id.clone())
            .collect::<Vec<_>>();
        for event_id in removed {
            // Keep membership controls so removal can still reach other devices.
            self.forget_pending_relay_publish(&event_id);
            if let Some(mesh) = &self.device_sync {
                if let Ok(mut outbox) = mesh.nearby_outbox.write() {
                    outbox.forget(&event_id);
                }
            }
        }
    }
}