nostui 0.1.1

A TUI client for Nostr
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

use std::time::Duration;

use color_eyre::eyre::Result;

use nostr_sdk::prelude::*;

/// Default timeout for fetching contact lists from relays
const DEFAULT_CONTACT_LIST_TIMEOUT_SECS: u64 = 10;

pub struct Connection {
    keys: Keys,
    client: Client,
}

impl Connection {
    pub async fn new(keys: Keys, relays: Vec<String>) -> Result<Self> {
        let client = Client::new(keys.clone());

        for relay in relays {
            client.add_relay(&relay).await?;
        }
        client.connect().await;

        Ok(Self { keys, client })
    }

    pub async fn subscribe_timeline(
        &self,
    ) -> Result<tokio::sync::broadcast::Receiver<RelayPoolNotification>> {
        let followings = self
            .client
            .get_contact_list_public_keys(Duration::from_secs(DEFAULT_CONTACT_LIST_TIMEOUT_SECS))
            .await?;
        let timeline_filter = Filter::new()
            .authors(followings.clone())
            .kinds([
                Kind::TextNote,
                Kind::Repost,
                Kind::Reaction,
                Kind::ZapReceipt,
            ])
            .since(Timestamp::now() - Duration::new(60 * 5, 0)); // 5min
        let profile_filter = Filter::new().authors(followings).kinds([Kind::Metadata]);

        // Subscribe to both timeline and profile data concurrently
        tokio::try_join!(
            self.client.subscribe(timeline_filter, None),
            self.client.subscribe(profile_filter, None)
        )?;

        Ok(self.client.notifications())
    }

    pub async fn send(&mut self, event: Event) -> Result<()> {
        self.client.send_event(&event).await?;
        Ok(())
    }

    pub async fn close(self) {
        self.client.shutdown().await
    }
}