iris-chat 0.1.62

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

use super::*;
use crate::update_announcements::{register_update_providers, shared_update_providers};

type Provider = Arc<dyn nostr_pubsub::NostrEventSubscriber>;

/// Message-server ownership follows the account, independently of its mesh.
#[derive(Default)]
pub(in crate::core) struct UpdateSources {
    key: Option<(String, String, Vec<String>)>,
    relay_urls: Vec<String>,
    relay: Option<Provider>,
    providers: Vec<Provider>,
}

impl UpdateSources {
    pub(in crate::core) fn new(relay_urls: Vec<String>) -> Self {
        register_update_providers(&[], relay_urls.clone());
        Self {
            relay_urls,
            ..Self::default()
        }
    }
}

#[cfg(test)]
mod tests;

impl AppCore {
    pub(in crate::core) fn reconcile_update_sources(&mut self) {
        let Some(logged_in) = &self.logged_in else {
            self.update_sources.relay_urls = self.preferences.nostr_relay_urls.clone();
            self.clear_update_sources();
            return;
        };
        let relays = logged_in
            .relay_urls
            .iter()
            .map(ToString::to_string)
            .collect::<Vec<_>>();
        let key = (
            logged_in.owner_pubkey.to_hex(),
            logged_in.device_keys.public_key().to_hex(),
            relays.clone(),
        );
        if self.update_sources.key.as_ref() != Some(&key) {
            let (mut providers, error) = self.runtime.block_on(shared_update_providers(
                None,
                Some(logged_in.client.clone()),
                relays.clone(),
            ));
            self.update_sources.key = Some(key);
            self.update_sources.relay_urls = relays;
            self.update_sources.relay = providers.pop();
            if let Some(error) = error {
                self.push_debug_log("update.message_servers.start.error", error);
            }
        }
        let peer = self
            .device_sync
            .as_ref()
            .and_then(|runtime| runtime.pubsub.as_ref())
            .cloned();
        self.register_update_sources(peer.as_ref());
    }

    pub(super) fn register_update_sources(&mut self, peer: Option<&Arc<FipsPubsubClient>>) {
        self.update_sources.providers = peer
            .map(|client| Arc::new(client.fresh_subscriber()) as Provider)
            .into_iter()
            .chain(self.update_sources.relay.clone())
            .collect();
        register_update_providers(
            &self.update_sources.providers,
            self.update_sources.relay_urls.clone(),
        );
    }

    pub(in crate::core) fn clear_update_sources(&mut self) {
        // Retain the last explicit server policy after providers expire, but
        // never retain an old account's client across logout or replacement.
        crate::update_announcements::register_update_blob_store(None);
        self.update_sources.key = None;
        self.update_sources.relay = None;
        self.update_sources.providers.clear();
        register_update_providers(&[], self.update_sources.relay_urls.clone());
    }
}