chore: bump version

* add empty state

* .

* update welcome panel

.github/workflows/release.yml

@@ -157,7 +157,7 @@ jobs:
         uses: softprops/action-gh-release@v2
         with:
           tag_name: ${{ steps.version.outputs.tag }}
-          name: Release ${{ steps.version.outputs.tag }}
+          name: ${{ steps.version.outputs.tag }}
           draft: true
           prerelease: false
           generate_release_notes: true

Cargo.toml

@@ -4,7 +4,7 @@ members = ["crates/*"]
 default-members = ["crates/coop"]
 
 [workspace.package]
-version = "0.2.6"
+version = "0.2.8"
 edition = "2021"
 publish = false
 

assets/icons/server.svg

@@ -0,0 +1,4 @@
+<svg xmlns="http://www.w3.org/2000/svg" width="24" height="24" fill="none" viewBox="0 0 24 24">
+  <path stroke="currentColor" stroke-linecap="square" stroke-linejoin="round" stroke-width="1.5" d="M21.25 12V6.75a2 2 0 0 0-2-2H4.75a2 2 0 0 0-2 2V12m18.5 0H2.75m18.5 0v5.25a2 2 0 0 1-2 2H4.75a2 2 0 0 1-2-2V12"/>
+  <path fill="currentColor" stroke="currentColor" stroke-width=".5" d="M6.5 14.875a.75.75 0 1 1 0 1.5.75.75 0 0 1 0-1.5Zm0-7.25a.75.75 0 1 1 0 1.5.75.75 0 0 1 0-1.5Z"/>
+</svg>

crates/client_keys/src/lib.rs

@@ -1,5 +1,7 @@
+use std::sync::atomic::Ordering;
+
 use global::constants::KEYRING_URL;
-use global::first_run;
+use global::css;
 use gpui::{App, AppContext, Context, Entity, Global, Subscription, Window};
 use nostr_sdk::prelude::*;
 use smallvec::{smallvec, SmallVec};
@@ -59,6 +61,7 @@ impl ClientKeys {
             return;
         }
 
+        let css = css();
         let read_client_keys = cx.read_credentials(KEYRING_URL);
 
         cx.spawn_in(window, async move |this, cx| {
@@ -73,7 +76,7 @@ impl ClientKeys {
                     this.set_keys(Some(keys), false, true, cx);
                 })
                 .ok();
-            } else if *first_run() {
+            } else if css.is_first_run.load(Ordering::Acquire) {
                 // If this is the first run, generate new keys and use them for the client keys
                 this.update(cx, |this, cx| {
                     this.new_keys(cx);

crates/coop/Cargo.toml

@@ -14,7 +14,7 @@ product-name = "Coop"
 description = "Chat Freely, Stay Private on Nostr"
 identifier = "su.reya.coop"
 category = "SocialNetworking"
-version = "0.2.6"
+version = "0.2.8"
 out-dir = "../../dist"
 before-packaging-command = "cargo build --release"
 resources = ["Cargo.toml", "src"]

crates/coop/src/actions.rs

@@ -2,7 +2,7 @@ use std::sync::Mutex;
 
 use gpui::{actions, App};
 
-actions!(coop, [DarkMode, Settings, Logout, Quit]);
+actions!(coop, [ReloadMetadata, DarkMode, Settings, Logout, Quit]);
 actions!(sidebar, [Reload, RelayStatus]);
 
 pub fn load_embedded_fonts(cx: &App) {

crates/coop/src/chatspace.rs

@@ -9,12 +9,11 @@ use auto_update::AutoUpdater;
 use client_keys::ClientKeys;
 use common::display::ReadableProfile;
 use common::event::EventUtils;
-use flume::{Receiver, Sender};
 use global::constants::{
     ACCOUNT_IDENTIFIER, BOOTSTRAP_RELAYS, DEFAULT_SIDEBAR_WIDTH, METADATA_BATCH_LIMIT,
     METADATA_BATCH_TIMEOUT, SEARCH_RELAYS,
 };
-use global::{css, ingester, nostr_client, AuthRequest, Notice, Signal, UnwrappingStatus};
+use global::{css, nostr_client, AuthRequest, Notice, SignalKind, UnwrappingStatus};
 use gpui::prelude::FluentBuilder;
 use gpui::{
     div, px, rems, App, AppContext, AsyncWindowContext, Axis, Context, Entity, InteractiveElement,
@@ -42,7 +41,7 @@ use ui::notification::Notification;
 use ui::popup_menu::PopupMenuExt;
 use ui::{h_flex, v_flex, ContextModal, Disableable, IconName, Root, Sizable, StyledExt};
 
-use crate::actions::{DarkMode, Logout, Settings};
+use crate::actions::{DarkMode, Logout, ReloadMetadata, Settings};
 use crate::views::compose::compose_button;
 use crate::views::setup_relay::setup_nip17_relay;
 use crate::views::{
@@ -64,18 +63,22 @@ pub fn new_account(window: &mut Window, cx: &mut App) {
 }
 
 pub struct ChatSpace {
-    // Workspace
+    // App's Title Bar
     title_bar: Entity<TitleBar>,
+
+    // App's Dock Area
     dock: Entity<DockArea>,
 
-    // Temporarily store all authentication requests
+    // All authentication requests
-    auth_requests: HashMap<AuthRequest, bool>,
+    auth_requests: HashMap<RelayUrl, AuthRequest>,
 
     // Local state to determine if the user has set up NIP-17 relays
-    has_nip17_relays: bool,
+    nip17_relays: bool,
 
-    // System
+    // All subscriptions for observing the app state
     _subscriptions: SmallVec<[Subscription; 3]>,
+
+    // All long running tasks
     _tasks: SmallVec<[Task<()>; 5]>,
 }
 
@@ -88,7 +91,6 @@ impl ChatSpace {
         let title_bar = cx.new(|_| TitleBar::new());
         let dock = cx.new(|cx| DockArea::new(window, cx));
 
-        let (pubkey_tx, pubkey_rx) = flume::bounded::<PublicKey>(1024);
         let mut subscriptions = smallvec![];
         let mut tasks = smallvec![];
 
@@ -143,7 +145,7 @@ impl ChatSpace {
                     .await
                     .expect("Failed connect the bootstrap relays. Please restart the application.");
 
-                Self::process_nostr_events(&pubkey_tx)
+                Self::process_nostr_events()
                     .await
                     .expect("Failed to handle nostr events. Please restart the application.");
             }),
@@ -167,7 +169,7 @@ impl ChatSpace {
         tasks.push(
             // Listen all metadata requests then batch them into single subscription
             cx.background_spawn(async move {
-                Self::process_batching_metadata(&pubkey_rx).await;
+                Self::process_batching_metadata().await;
             }),
         );
 
@@ -182,7 +184,7 @@ impl ChatSpace {
             dock,
             title_bar,
             auth_requests: HashMap::new(),
-            has_nip17_relays: true,
+            nip17_relays: true,
             _subscriptions: subscriptions,
             _tasks: tasks,
         }
@@ -211,75 +213,80 @@ impl ChatSpace {
 
     async fn observe_signer() {
         let client = nostr_client();
-        let ingester = ingester();
+        let css = css();
+        let stream_timeout = Duration::from_secs(5);
         let loop_duration = Duration::from_secs(1);
-        let mut is_sent_signal = false;
-        let mut identity: Option<PublicKey> = None;
 
         loop {
-            if let Some(public_key) = identity {
+            let Ok(signer) = client.signer().await else {
-                let nip65 = Filter::new().kind(Kind::RelayList).author(public_key);
+                smol::Timer::after(loop_duration).await;
+                continue;
+            };
 
-                if client.database().count(nip65).await.unwrap_or(0) > 0 {
+            let Ok(public_key) = signer.get_public_key().await else {
-                    let dm_relays = Filter::new().kind(Kind::InboxRelays).author(public_key);
+                smol::Timer::after(loop_duration).await;
+                continue;
+            };
 
-                    match client.database().query(dm_relays).await {
+            // Notify the app that the signer has been set.
-                        Ok(events) => {
+            css.signal.send(SignalKind::SignerSet(public_key)).await;
-                            if let Some(event) = events.first_owned() {
-                                let relay_urls = nip17::extract_relay_list(&event).collect_vec();
 
-                                if relay_urls.is_empty() {
+            // Subscribe to the NIP-65 relays for the public key.
-                                    if !is_sent_signal {
+            let filter = Filter::new()
-                                        ingester.send(Signal::DmRelayNotFound).await;
+                .kind(Kind::RelayList)
-                                        is_sent_signal = true;
+                .author(public_key)
-                                    }
+                .limit(1);
+
+            let mut nip65_found = false;
+
+            match client
+                .stream_events_from(BOOTSTRAP_RELAYS, filter, stream_timeout)
+                .await
+            {
+                Ok(mut stream) => {
+                    if stream.next().await.is_some() {
+                        nip65_found = true;
                     } else {
-                                    break;
+                        // Timeout
-                                }
+                        css.signal.send(SignalKind::RelaysNotFound).await;
-                            } else if !is_sent_signal {
-                                ingester.send(Signal::DmRelayNotFound).await;
-                                is_sent_signal = true;
-                            } else {
-                                break;
                     }
                 }
                 Err(e) => {
-                            log::error!("Database query error: {e}");
+                    log::error!("Error fetching NIP-65 Relay: {e:?}");
-                            if !is_sent_signal {
+                    css.signal.send(SignalKind::RelaysNotFound).await;
-                                ingester.send(Signal::DmRelayNotFound).await;
-                                is_sent_signal = true;
                 }
-                        }
+            };
-                    }
+
-                } else {
+            if nip65_found {
-                    log::error!("Database error.");
+                // Subscribe to the NIP-17 relays for the public key.
+                let filter = Filter::new()
+                    .kind(Kind::InboxRelays)
+                    .author(public_key)
+                    .limit(1);
+
+                match client.stream_events(filter, stream_timeout).await {
+                    Ok(mut stream) => {
+                        if stream.next().await.is_some() {
                             break;
-                }
                         } else {
-                // Wait for signer set
+                            // Timeout
-                if let Ok(signer) = client.signer().await {
+                            css.signal.send(SignalKind::RelaysNotFound).await;
-                    if let Ok(public_key) = signer.get_public_key().await {
-                        identity = Some(public_key);
-
-                        // Notify the app that the signer has been set.
-                        ingester.send(Signal::SignerSet(public_key)).await;
-
-                        // Subscribe to the NIP-65 relays for the public key.
-                        if let Err(e) = Self::fetch_nip65_relays(public_key).await {
-                            log::error!("Failed to fetch NIP-65 relays: {e}");
                         }
                     }
+                    Err(e) => {
+                        log::error!("Error fetching NIP-17 Relay: {e:?}");
+                        css.signal.send(SignalKind::RelaysNotFound).await;
                     }
+                };
             }
 
-            smol::Timer::after(loop_duration).await;
+            break;
         }
     }
 
     async fn observe_giftwrap() {
         let client = nostr_client();
         let css = css();
-        let ingester = ingester();
         let loop_duration = Duration::from_secs(20);
         let mut is_start_processing = false;
         let mut total_loops = 0;
@@ -299,14 +306,14 @@ impl ChatSpace {
                         Ordering::Relaxed,
                     );
 
-                    let signal = Signal::GiftWrapProcess(UnwrappingStatus::Processing);
+                    let signal = SignalKind::GiftWrapStatus(UnwrappingStatus::Processing);
-                    ingester.send(signal).await;
+                    css.signal.send(signal).await;
                 } else {
                     // Only run further if we are already processing
                     // Wait until after 2 loops to prevent exiting early while events are still being processed
                     if is_start_processing && total_loops >= 2 {
-                        let signal = Signal::GiftWrapProcess(UnwrappingStatus::Complete);
+                        let signal = SignalKind::GiftWrapStatus(UnwrappingStatus::Complete);
-                        ingester.send(signal).await;
+                        css.signal.send(signal).await;
 
                         // Reset the counter
                         is_start_processing = false;
@@ -319,7 +326,8 @@ impl ChatSpace {
         }
     }
 
-    async fn process_batching_metadata(rx: &Receiver<PublicKey>) {
+    async fn process_batching_metadata() {
+        let css = css();
         let timeout = Duration::from_millis(METADATA_BATCH_TIMEOUT);
         let mut processed_pubkeys: HashSet<PublicKey> = HashSet::new();
         let mut batch: HashSet<PublicKey> = HashSet::new();
@@ -334,7 +342,7 @@ impl ChatSpace {
         loop {
             let futs = smol::future::or(
                 async move {
-                    if let Ok(public_key) = rx.recv_async().await {
+                    if let Ok(public_key) = css.ingester.receiver().recv_async().await {
                         BatchEvent::PublicKey(public_key)
                     } else {
                         BatchEvent::Closed
@@ -369,9 +377,8 @@ impl ChatSpace {
         }
     }
 
-    async fn process_nostr_events(pubkey_tx: &Sender<PublicKey>) -> Result<(), Error> {
+    async fn process_nostr_events() -> Result<(), Error> {
         let client = nostr_client();
-        let ingester = ingester();
         let css = css();
 
         let mut processed_events: HashSet<EventId> = HashSet::new();
@@ -385,6 +392,14 @@ impl ChatSpace {
 
             match message {
                 RelayMessage::Event { event, .. } => {
+                    // Keep track of which relays have seen this event
+                    css.seen_on_relays
+                        .write()
+                        .await
+                        .entry(event.id)
+                        .or_insert_with(HashSet::new)
+                        .insert(relay_url);
+
                     // Skip events that have already been processed
                     if !processed_events.insert(event.id) {
                         continue;
@@ -398,9 +413,6 @@ impl ChatSpace {
 
                                 // Fetch user's contact list event
                                 Self::fetch_single_event(Kind::ContactList, event.pubkey).await;
-
-                                // Fetch user's inbox relays event
-                                Self::fetch_single_event(Kind::InboxRelays, event.pubkey).await;
                             }
                         }
                         Kind::InboxRelays => {
@@ -411,16 +423,18 @@ impl ChatSpace {
                                     for relay in relays.clone().into_iter() {
                                         if client.add_relay(relay).await.is_err() {
                                             let notice = Notice::RelayFailed(relay.clone());
-                                            ingester.send(Signal::Notice(notice)).await;
+                                            css.signal.send(SignalKind::Notice(notice)).await;
                                         }
                                         if client.connect_relay(relay).await.is_err() {
                                             let notice = Notice::RelayFailed(relay.clone());
-                                            ingester.send(Signal::Notice(notice)).await;
+                                            css.signal.send(SignalKind::Notice(notice)).await;
                                         }
                                     }
 
                                     // Subscribe to gift wrap events only in the current user's NIP-17 relays
                                     Self::fetch_gift_wrap(relays, event.pubkey).await;
+                                } else {
+                                    css.signal.send(SignalKind::RelaysNotFound).await;
                                 }
                             }
                         }
@@ -439,25 +453,28 @@ impl ChatSpace {
                             }
                         }
                         Kind::Metadata => {
-                            ingester.send(Signal::Metadata(event.into_owned())).await;
+                            let metadata = Metadata::from_json(&event.content).unwrap_or_default();
+                            let profile = Profile::new(event.pubkey, metadata);
+
+                            css.signal.send(SignalKind::NewProfile(profile)).await;
                         }
                         Kind::GiftWrap => {
-                            Self::unwrap_gift_wrap(&event, pubkey_tx).await;
+                            Self::unwrap_gift_wrap(&event).await;
                         }
                         _ => {}
                     }
                 }
                 RelayMessage::EndOfStoredEvents(subscription_id) => {
                     if *subscription_id == css.gift_wrap_sub_id {
-                        let signal = Signal::GiftWrapProcess(UnwrappingStatus::Processing);
+                        let signal = SignalKind::GiftWrapStatus(UnwrappingStatus::Processing);
-                        ingester.send(signal).await;
+                        css.signal.send(signal).await;
                     }
                 }
                 RelayMessage::Auth { challenge } => {
                     if challenges.insert(challenge.clone()) {
                         let req = AuthRequest::new(challenge, relay_url);
                         // Send a signal to the ingester to handle the auth request
-                        ingester.send(Signal::Auth(req)).await;
+                        css.signal.send(SignalKind::Auth(req)).await;
                     }
                 }
                 RelayMessage::Ok {
@@ -483,17 +500,16 @@ impl ChatSpace {
     }
 
     async fn process_nostr_signals(view: WeakEntity<ChatSpace>, cx: &mut AsyncWindowContext) {
-        let ingester = ingester();
+        let css = css();
-        let signals = ingester.signals();
         let mut is_open_proxy_modal = false;
 
-        while let Ok(signal) = signals.recv_async().await {
+        while let Ok(signal) = css.signal.receiver().recv_async().await {
             cx.update(|window, cx| {
                 let registry = Registry::global(cx);
                 let settings = AppSettings::global(cx);
 
                 match signal {
-                    Signal::SignerSet(public_key) => {
+                    SignalKind::SignerSet(public_key) => {
                         window.close_modal(cx);
 
                         // Setup the default layout for current workspace
@@ -513,7 +529,7 @@ impl ChatSpace {
                             this.load_rooms(window, cx);
                         });
                     }
-                    Signal::SignerUnset => {
+                    SignalKind::SignerUnset => {
                         // Setup the onboarding layout for current workspace
                         view.update(cx, |this, cx| {
                             this.set_onboarding_layout(window, cx);
@@ -525,7 +541,7 @@ impl ChatSpace {
                             this.reset(cx);
                         });
                     }
-                    Signal::Auth(req) => {
+                    SignalKind::Auth(req) => {
                         let url = &req.url;
                         let auto_auth = AppSettings::get_auto_auth(cx);
                         let is_authenticated = AppSettings::read_global(cx).is_authenticated(url);
@@ -543,7 +559,7 @@ impl ChatSpace {
                         })
                         .ok();
                     }
-                    Signal::ProxyDown => {
+                    SignalKind::ProxyDown => {
                         if !is_open_proxy_modal {
                             is_open_proxy_modal = true;
 
@@ -553,28 +569,28 @@ impl ChatSpace {
                             .ok();
                         }
                     }
-                    Signal::GiftWrapProcess(status) => {
+                    SignalKind::GiftWrapStatus(status) => {
                         registry.update(cx, |this, cx| {
                             this.set_unwrapping_status(status, cx);
                         });
                     }
-                    Signal::Metadata(event) => {
+                    SignalKind::NewProfile(profile) => {
                         registry.update(cx, |this, cx| {
-                            this.insert_or_update_person(event, cx);
+                            this.insert_or_update_person(profile, cx);
                         });
                     }
-                    Signal::Message((gift_wrap_id, event)) => {
+                    SignalKind::NewMessage((gift_wrap_id, event)) => {
                         registry.update(cx, |this, cx| {
                             this.event_to_message(gift_wrap_id, event, window, cx);
                         });
                     }
-                    Signal::DmRelayNotFound => {
+                    SignalKind::RelaysNotFound => {
                         view.update(cx, |this, cx| {
-                            this.set_no_nip17_relays(cx);
+                            this.set_required_relays(cx);
                         })
                         .ok();
                     }
-                    Signal::Notice(msg) => {
+                    SignalKind::Notice(msg) => {
                         window.push_notification(msg.as_str(), cx);
                     }
                 };
@@ -603,6 +619,7 @@ impl ChatSpace {
         }
     }
 
+    /// Fetches gift wrap events for a given public key and relays
     pub async fn fetch_gift_wrap(relays: Vec<&RelayUrl>, public_key: PublicKey) {
         let client = nostr_client();
         let sub_id = css().gift_wrap_sub_id.clone();
@@ -617,23 +634,6 @@ impl ChatSpace {
         }
     }
 
-    /// Fetches NIP-65 relay list for a given public key
-    pub async fn fetch_nip65_relays(public_key: PublicKey) -> Result<(), Error> {
-        let client = nostr_client();
-        let css = css();
-
-        let filter = Filter::new()
-            .kind(Kind::RelayList)
-            .author(public_key)
-            .limit(1);
-
-        client
-            .subscribe_to(BOOTSTRAP_RELAYS, filter, css.auto_close_opts)
-            .await?;
-
-        Ok(())
-    }
-
     /// Fetches metadata for a list of public keys
     async fn fetch_metadata_for_pubkeys(public_keys: HashSet<PublicKey>) {
         if public_keys.is_empty() {
@@ -696,9 +696,8 @@ impl ChatSpace {
     }
 
     /// Unwraps a gift-wrapped event and processes its contents.
-    async fn unwrap_gift_wrap(target: &Event, pubkey_tx: &Sender<PublicKey>) {
+    async fn unwrap_gift_wrap(target: &Event) {
         let client = nostr_client();
-        let ingester = ingester();
         let css = css();
         let mut message: Option<Event> = None;
 
@@ -719,16 +718,17 @@ impl ChatSpace {
         if let Some(event) = message {
             // Send all pubkeys to the metadata batch to sync data
             for public_key in event.all_pubkeys() {
-                pubkey_tx.send_async(public_key).await.ok();
+                css.ingester.send(public_key).await;
             }
 
             match event.created_at >= css.init_at {
                 // New message: send a signal to notify the UI
                 true => {
-                    // Prevent notification if the event was sent by Coop
+                    // A small delay to prevent UI flickering
-                    if !css.sent_ids.read().await.contains(&target.id) {
+                    smol::Timer::after(Duration::from_millis(200)).await;
-                        ingester.send(Signal::Message((target.id, event))).await;
+                    css.signal
-                    }
+                        .send(SignalKind::NewMessage((target.id, event)))
+                        .await;
                 }
                 // Old message: Coop is probably processing the user's messages during initial load
                 false => {
@@ -939,20 +939,20 @@ impl ChatSpace {
     }
 
     fn reopen_auth_request(&mut self, window: &mut Window, cx: &mut Context<Self>) {
-        for req in self.auth_requests.clone().into_iter() {
+        for (_, request) in self.auth_requests.clone().into_iter() {
-            self.open_auth_request(req.0, window, cx);
+            self.open_auth_request(request, window, cx);
         }
     }
 
     fn push_auth_request(&mut self, req: &AuthRequest, cx: &mut Context<Self>) {
-        self.auth_requests.insert(req.to_owned(), false);
+        self.auth_requests.insert(req.url.clone(), req.to_owned());
         cx.notify();
     }
 
     fn sending_auth_request(&mut self, challenge: &str, cx: &mut Context<Self>) {
-        for (req, status) in self.auth_requests.iter_mut() {
+        for (_, req) in self.auth_requests.iter_mut() {
             if req.challenge == challenge {
-                *status = true;
+                req.sending = true;
                 cx.notify();
             }
         }
@@ -962,16 +962,16 @@ impl ChatSpace {
         if let Some(req) = self
             .auth_requests
             .iter()
-            .find(|(req, _)| req.challenge == challenge)
+            .find(|(_, req)| req.challenge == challenge)
         {
-            req.1.to_owned()
+            req.1.sending
         } else {
             false
         }
     }
 
     fn remove_auth_request(&mut self, challenge: &str, cx: &mut Context<Self>) {
-        self.auth_requests.retain(|r, _| r.challenge != challenge);
+        self.auth_requests.retain(|_, r| r.challenge != challenge);
         cx.notify();
     }
 
@@ -1023,8 +1023,8 @@ impl ChatSpace {
         });
     }
 
-    fn set_no_nip17_relays(&mut self, cx: &mut Context<Self>) {
+    fn set_required_relays(&mut self, cx: &mut Context<Self>) {
-        self.has_nip17_relays = false;
+        self.nip17_relays = false;
         cx.notify();
     }
 
@@ -1051,21 +1051,15 @@ impl ChatSpace {
 
         cx.spawn_in(window, async move |this, cx| {
             if let Ok((secret, profile)) = task.await {
-                cx.update(|window, cx| {
+                this.update_in(cx, |this, window, cx| {
-                    this.update(cx, |this, cx| {
                     this.set_account_layout(secret, profile, window, cx);
                 })
                 .ok();
-                })
-                .ok();
             } else {
-                cx.update(|window, cx| {
+                this.update_in(cx, |this, window, cx| {
-                    this.update(cx, |this, cx| {
                     this.set_onboarding_layout(window, cx);
                 })
                 .ok();
-                })
-                .ok();
             }
         })
         .detach();
@@ -1090,10 +1084,54 @@ impl ChatSpace {
         }
     }
 
+    fn on_reload_metadata(
+        &mut self,
+        _ev: &ReloadMetadata,
+        window: &mut Window,
+        cx: &mut Context<Self>,
+    ) {
+        let task: Task<Result<(), Error>> = cx.background_spawn(async move {
+            let client = nostr_client();
+            let css = css();
+
+            let filter = Filter::new().kind(Kind::PrivateDirectMessage);
+
+            let pubkeys: Vec<PublicKey> = client
+                .database()
+                .query(filter)
+                .await?
+                .into_iter()
+                .flat_map(|event| event.all_pubkeys())
+                .unique()
+                .collect();
+
+            let filter = Filter::new()
+                .kind(Kind::Metadata)
+                .limit(pubkeys.len())
+                .authors(pubkeys);
+
+            client
+                .subscribe_to(BOOTSTRAP_RELAYS, filter, css.auto_close_opts)
+                .await?;
+
+            Ok(())
+        });
+
+        cx.spawn_in(window, async move |_, cx| {
+            if task.await.is_ok() {
+                cx.update(|window, cx| {
+                    window.push_notification(t!("common.refreshed"), cx);
+                })
+                .ok();
+            }
+        })
+        .detach();
+    }
+
     fn on_sign_out(&mut self, _e: &Logout, _window: &mut Window, cx: &mut Context<Self>) {
         cx.background_spawn(async move {
             let client = nostr_client();
-            let ingester = ingester();
+            let css = css();
 
             let filter = Filter::new()
                 .kind(Kind::ApplicationSpecificData)
@@ -1106,7 +1144,7 @@ impl ChatSpace {
             client.reset().await;
 
             // Notify the channel about the signer being unset
-            ingester.send(Signal::SignerUnset).await;
+            css.signal.send(SignalKind::SignerUnset).await;
         })
         .detach();
     }
@@ -1236,7 +1274,6 @@ impl ChatSpace {
         cx: &mut Context<Self>,
     ) -> impl IntoElement {
         let proxy = AppSettings::get_proxy_user_avatars(cx);
-        let is_auto_auth = AppSettings::read_global(cx).is_auto_auth();
         let updating = AutoUpdater::read_global(cx).status.is_updating();
         let updated = AutoUpdater::read_global(cx).status.is_updated();
         let auth_requests = self.auth_requests.len();
@@ -1275,7 +1312,7 @@ impl ChatSpace {
                         }),
                 )
             })
-            .when(auth_requests > 0 && !is_auto_auth, |this| {
+            .when(auth_requests > 0, |this| {
                 this.child(
                     h_flex()
                         .id("requests")
@@ -1295,7 +1332,7 @@ impl ChatSpace {
                         })),
                 )
             })
-            .when(!self.has_nip17_relays, |this| {
+            .when(!self.nip17_relays, |this| {
                 this.child(setup_nip17_relay(t!("relays.button")))
             })
             .child(
@@ -1309,6 +1346,8 @@ impl ChatSpace {
                         this.menu(t!("user.dark_mode"), Box::new(DarkMode))
                             .menu(t!("user.settings"), Box::new(Settings))
                             .separator()
+                            .menu(t!("user.reload_metadata"), Box::new(ReloadMetadata))
+                            .separator()
                             .menu(t!("user.sign_out"), Box::new(Logout))
                     }),
             )
@@ -1329,7 +1368,7 @@ impl ChatSpace {
 
             this._tasks.push(cx.background_spawn(async move {
                 let client = nostr_client();
-                let ingester = ingester();
+                let css = css();
 
                 if proxy.start().await.is_ok() {
                     webbrowser::open(&url).ok();
@@ -1360,7 +1399,7 @@ impl ChatSpace {
 
                             break;
                         } else {
-                            ingester.send(Signal::ProxyDown).await;
+                            css.signal.send(SignalKind::ProxyDown).await;
                         }
                         smol::Timer::after(Duration::from_secs(1)).await;
                     }
@@ -1429,6 +1468,7 @@ impl Render for ChatSpace {
             .on_action(cx.listener(Self::on_dark_mode))
             .on_action(cx.listener(Self::on_sign_out))
             .on_action(cx.listener(Self::on_open_profile))
+            .on_action(cx.listener(Self::on_reload_metadata))
             .relative()
             .size_full()
             .child(

crates/coop/src/main.rs

@@ -2,7 +2,7 @@ use std::sync::Arc;
 
 use assets::Assets;
 use global::constants::{APP_ID, APP_NAME};
-use global::{css, ingester, nostr_client};
+use global::{css, nostr_client};
 use gpui::{
     point, px, size, AppContext, Application, Bounds, KeyBinding, Menu, MenuItem, SharedString,
     TitlebarOptions, WindowBackgroundAppearance, WindowBounds, WindowDecorations, WindowKind,
@@ -26,9 +26,6 @@ fn main() {
     // Initialize the Nostr client
     let _client = nostr_client();
 
-    // Initialize the ingester
-    let _ingester = ingester();
-
     // Initialize the coop simple storage
     let _css = css();
 

crates/coop/src/views/account.rs

@@ -5,7 +5,7 @@ use client_keys::ClientKeys;
 use common::display::ReadableProfile;
 use common::handle_auth::CoopAuthUrlHandler;
 use global::constants::{ACCOUNT_IDENTIFIER, BUNKER_TIMEOUT};
-use global::{ingester, nostr_client, Signal};
+use global::{css, nostr_client, SignalKind};
 use gpui::prelude::FluentBuilder;
 use gpui::{
     div, relative, rems, svg, AnyElement, App, AppContext, Context, Entity, EventEmitter,
@@ -248,7 +248,7 @@ impl Account {
             // Reset the nostr client in the background
             cx.background_spawn(async move {
                 let client = nostr_client();
-                let ingester = ingester();
+                let css = css();
 
                 let filter = Filter::new()
                     .kind(Kind::ApplicationSpecificData)
@@ -261,7 +261,7 @@ impl Account {
                 client.unset_signer().await;
 
                 // Notify the channel about the signer being unset
-                ingester.send(Signal::SignerUnset).await;
+                css.signal.send(SignalKind::SignerUnset).await;
             }),
         );
     }

crates/coop/src/views/chat/mod.rs

@@ -1,3 +1,5 @@
+use std::collections::HashMap;
+
 use anyhow::anyhow;
 use common::display::{ReadableProfile, ReadableTimestamp};
 use common::nip96::nip96_upload;
@@ -29,7 +31,7 @@ use ui::dock_area::panel::{Panel, PanelEvent};
 use ui::emoji_picker::EmojiPicker;
 use ui::input::{InputEvent, InputState, TextInput};
 use ui::modal::ModalButtonProps;
-use ui::popup_menu::PopupMenu;
+use ui::popup_menu::{PopupMenu, PopupMenuExt};
 use ui::text::RenderedText;
 use ui::{
     h_flex, v_flex, ContextModal, Disableable, Icon, IconName, InteractiveElementExt, Sizable,
@@ -40,7 +42,7 @@ mod subject;
 
 #[derive(Action, Clone, PartialEq, Eq, Deserialize)]
 #[action(namespace = chat, no_json)]
-pub struct ChangeSubject(pub String);
+pub struct SeenOn(pub EventId);
 
 pub fn init(room: Entity<Room>, window: &mut Window, cx: &mut App) -> Entity<Chat> {
     cx.new(|cx| Chat::new(room, window, cx))
@@ -49,6 +51,9 @@ pub fn init(room: Entity<Room>, window: &mut Window, cx: &mut App) -> Entity<Cha
 pub struct Chat {
     // Chat Room
     room: Entity<Room>,
+    relays: Entity<HashMap<PublicKey, Vec<RelayUrl>>>,
+
+    // Messages
     list_state: ListState,
     messages: BTreeSet<Message>,
     rendered_texts_by_id: BTreeMap<EventId, RenderedText>,
@@ -67,14 +72,20 @@ pub struct Chat {
     focus_handle: FocusHandle,
     image_cache: Entity<RetainAllImageCache>,
 
-    _subscriptions: SmallVec<[Subscription; 2]>,
+    _subscriptions: SmallVec<[Subscription; 4]>,
-    _tasks: SmallVec<[Task<()>; 1]>,
+    _tasks: SmallVec<[Task<()>; 2]>,
 }
 
 impl Chat {
     pub fn new(room: Entity<Room>, window: &mut Window, cx: &mut Context<Self>) -> Self {
         let attachments = cx.new(|_| vec![]);
         let replies_to = cx.new(|_| vec![]);
+
+        let relays = cx.new(|_| {
+            let this: HashMap<PublicKey, Vec<RelayUrl>> = HashMap::new();
+            this
+        });
+
         let input = cx.new(|cx| {
             InputState::new(window, cx)
                 .placeholder(t!("chat.placeholder"))
@@ -89,11 +100,35 @@ impl Chat {
         let messages = BTreeSet::from([Message::system()]);
         let list_state = ListState::new(messages.len(), ListAlignment::Bottom, px(1024.));
 
+        let connect_relays = room.read(cx).connect_relays(cx);
         let load_messages = room.read(cx).load_messages(cx);
 
         let mut subscriptions = smallvec![];
         let mut tasks = smallvec![];
 
+        tasks.push(
+            // Load all messages belonging to this room
+            cx.spawn_in(window, async move |this, cx| {
+                match connect_relays.await {
+                    Ok(relays) => {
+                        this.update(cx, |this, cx| {
+                            this.relays.update(cx, |this, cx| {
+                                *this = relays;
+                                cx.notify();
+                            });
+                        })
+                        .ok();
+                    }
+                    Err(e) => {
+                        cx.update(|window, cx| {
+                            window.push_notification(e.to_string(), cx);
+                        })
+                        .ok();
+                    }
+                };
+            }),
+        );
+
         tasks.push(
             // Load all messages belonging to this room
             cx.spawn_in(window, async move |this, cx| {
@@ -139,7 +174,7 @@ impl Chat {
                 match signal {
                     RoomSignal::NewMessage((gift_wrap_id, event)) => {
                         if !this.is_sent_by_coop(gift_wrap_id) {
-                            this.insert_message(event, false, cx);
+                            this.insert_message(Message::user(event), false, cx);
                         }
                     }
                     RoomSignal::Refresh => {
@@ -149,6 +184,33 @@ impl Chat {
             }),
         );
 
+        subscriptions.push(
+            // Observe the messaging relays of the room's members
+            cx.observe_in(&relays, window, |this, entity, _window, cx| {
+                for (public_key, urls) in entity.read(cx).clone().into_iter() {
+                    if urls.is_empty() {
+                        let profile = Registry::read_global(cx).get_person(&public_key, cx);
+                        let content = t!("chat.nip17_not_found", u = profile.name());
+
+                        this.insert_warning(content, cx);
+                    }
+                }
+            }),
+        );
+
+        subscriptions.push(
+            // Observe when user close chat panel
+            cx.on_release_in(window, move |this, window, cx| {
+                this.disconnect_relays(cx);
+                this.messages.clear();
+                this.rendered_texts_by_id.clear();
+                this.reports_by_id.clear();
+                this.image_cache.update(cx, |this, cx| {
+                    this.clear(window, cx);
+                });
+            }),
+        );
+
         Self {
             id: room.read(cx).id.to_string().into(),
             image_cache: RetainAllImageCache::new(cx),
@@ -156,6 +218,7 @@ impl Chat {
             uploading: false,
             rendered_texts_by_id: BTreeMap::new(),
             reports_by_id: BTreeMap::new(),
+            relays,
             messages,
             room,
             list_state,
@@ -167,6 +230,20 @@ impl Chat {
         }
     }
 
+    /// Disconnect all relays when the user closes the chat panel
+    fn disconnect_relays(&mut self, cx: &mut App) {
+        let relays = self.relays.read(cx).clone();
+
+        cx.background_spawn(async move {
+            let client = nostr_client();
+
+            for relay in relays.values().flatten() {
+                client.disconnect_relay(relay).await.ok();
+            }
+        })
+        .detach();
+    }
+
     /// Load all messages belonging to this room
     fn load_messages(&mut self, window: &mut Window, cx: &mut Context<Self>) {
         let load_messages = self.room.read(cx).load_messages(cx);
@@ -260,7 +337,7 @@ impl Chat {
 
         cx.defer_in(window, |this, window, cx| {
             // Optimistically update message list
-            this.insert_message(temp_message, true, cx);
+            this.insert_message(Message::user(temp_message), true, cx);
 
             // Remove all replies
             this.remove_all_replies(cx);
@@ -307,6 +384,75 @@ impl Chat {
         .detach();
     }
 
+    fn resend_message(&mut self, id: &EventId, window: &mut Window, cx: &mut Context<Self>) {
+        if let Some(reports) = self.reports_by_id.get(id).cloned() {
+            if let Some(message) = self.message(id) {
+                let backup = AppSettings::get_backup_messages(cx);
+                let id_clone = id.to_owned();
+                let message = message.content.to_owned();
+                let task = self.room.read(cx).resend(reports, message, backup, cx);
+
+                cx.spawn_in(window, async move |this, cx| {
+                    match task.await {
+                        Ok(reports) => {
+                            if !reports.is_empty() {
+                                this.update(cx, |this, cx| {
+                                    this.reports_by_id.entry(id_clone).and_modify(|this| {
+                                        *this = reports;
+                                    });
+                                    cx.notify();
+                                })
+                                .ok();
+                            }
+                        }
+                        Err(e) => {
+                            cx.update(|window, cx| {
+                                window.push_notification(e.to_string(), cx);
+                            })
+                            .ok();
+                        }
+                    };
+                })
+                .detach();
+            }
+        }
+    }
+
+    /// Insert a message into the chat panel
+    fn insert_message<E>(&mut self, m: E, scroll: bool, cx: &mut Context<Self>)
+    where
+        E: Into<Message>,
+    {
+        let old_len = self.messages.len();
+
+        // Extend the messages list with the new events
+        if self.messages.insert(m.into()) {
+            self.list_state.splice(old_len..old_len, 1);
+
+            if scroll {
+                self.list_state.scroll_to(ListOffset {
+                    item_ix: self.list_state.item_count(),
+                    offset_in_item: px(0.0),
+                });
+                cx.notify();
+            }
+        }
+    }
+
+    /// Convert and insert a vector of nostr events into the chat panel
+    fn insert_messages(&mut self, events: Vec<Event>, cx: &mut Context<Self>) {
+        for event in events.into_iter() {
+            let m = Message::user(event);
+            self.insert_message(m, false, cx);
+        }
+        cx.notify();
+    }
+
+    fn insert_warning(&mut self, content: impl Into<String>, cx: &mut Context<Self>) {
+        let m = Message::warning(content.into());
+        self.insert_message(m, true, cx);
+    }
+
     /// Check if a message failed to send by its ID
     fn is_sent_failed(&self, id: &EventId) -> bool {
         self.reports_by_id
@@ -338,35 +484,6 @@ impl Chat {
         })
     }
 
-    /// Convert and insert a nostr event into the chat panel
-    fn insert_message<E>(&mut self, event: E, scroll: bool, cx: &mut Context<Self>)
-    where
-        E: Into<RenderedMessage>,
-    {
-        let old_len = self.messages.len();
-
-        // Extend the messages list with the new events
-        if self.messages.insert(Message::user(event)) {
-            self.list_state.splice(old_len..old_len, 1);
-
-            if scroll {
-                self.list_state.scroll_to(ListOffset {
-                    item_ix: self.list_state.item_count(),
-                    offset_in_item: px(0.0),
-                });
-                cx.notify();
-            }
-        }
-    }
-
-    /// Convert and insert a vector of nostr events into the chat panel
-    fn insert_messages(&mut self, events: Vec<Event>, cx: &mut Context<Self>) {
-        for event in events.into_iter() {
-            self.insert_message(event, false, cx);
-        }
-        cx.notify();
-    }
-
     fn profile(&self, public_key: &PublicKey, cx: &Context<Self>) -> Profile {
         let registry = Registry::read_global(cx);
         registry.get_person(public_key, cx)
@@ -525,6 +642,34 @@ impl Chat {
             .into_any_element()
     }
 
+    fn render_warning(&mut self, ix: usize, content: String, cx: &mut Context<Self>) -> AnyElement {
+        div()
+            .id(ix)
+            .relative()
+            .w_full()
+            .py_1()
+            .px_3()
+            .bg(cx.theme().warning_background)
+            .child(
+                h_flex()
+                    .gap_3()
+                    .text_sm()
+                    .text_color(cx.theme().warning_foreground)
+                    .child(Avatar::new("brand/system.png").size(rems(2.)))
+                    .child(SharedString::from(content)),
+            )
+            .child(
+                div()
+                    .absolute()
+                    .left_0()
+                    .top_0()
+                    .w(px(2.))
+                    .h_full()
+                    .bg(cx.theme().warning_active),
+            )
+            .into_any_element()
+    }
+
     fn render_message_not_found(&self, ix: usize, cx: &Context<Self>) -> AnyElement {
         div()
             .id(ix)
@@ -585,9 +730,7 @@ impl Chat {
                             .flex_initial()
                             .overflow_hidden()
                             .child(
-                                div()
+                                h_flex()
-                                    .flex()
-                                    .items_center()
                                     .gap_2()
                                     .text_sm()
                                     .text_color(cx.theme().text_placeholder)
@@ -609,7 +752,23 @@ impl Chat {
                             })
                             .child(text)
                             .when(is_sent_failed, |this| {
-                                this.child(self.render_message_reports(&id, cx))
+                                this.child(
+                                    h_flex()
+                                        .gap_1()
+                                        .child(self.render_message_reports(&id, cx))
+                                        .child(
+                                            Button::new(SharedString::from(id.to_hex()))
+                                                .label(t!("common.resend"))
+                                                .danger()
+                                                .xsmall()
+                                                .rounded()
+                                                .on_click(cx.listener(
+                                                    move |this, _, window, cx| {
+                                                        this.resend_message(&id, window, cx);
+                                                    },
+                                                )),
+                                        ),
+                                )
                             }),
                     ),
             )
@@ -677,15 +836,17 @@ impl Chat {
     }
 
     fn render_message_sent(&self, id: &EventId, _cx: &Context<Self>) -> impl IntoElement {
-        div().id("").child(shared_t!("chat.sent")).when_some(
+        div()
-            self.sent_reports(id).cloned(),
+            .id(SharedString::from(id.to_hex()))
-            |this, reports| {
+            .child(shared_t!("chat.sent"))
+            .when_some(self.sent_reports(id).cloned(), |this, reports| {
                 this.on_click(move |_e, window, cx| {
                     let reports = reports.clone();
 
                     window.open_modal(cx, move |this, _window, cx| {
-                        this.title(shared_t!("chat.reports")).child(
+                        this.show_close(true)
-                            v_flex().pb_4().gap_4().children({
+                            .title(shared_t!("chat.reports"))
+                            .child(v_flex().pb_4().gap_4().children({
                                 let mut items = Vec::with_capacity(reports.len());
 
                                 for report in reports.iter() {
@@ -693,30 +854,29 @@ impl Chat {
                                 }
 
                                 items
-                            }),
+                            }))
-                        )
                     });
                 })
-            },
+            })
-        )
     }
 
     fn render_message_reports(&self, id: &EventId, cx: &Context<Self>) -> impl IntoElement {
         h_flex()
-            .id("")
+            .id(SharedString::from(id.to_hex()))
-            .gap_1()
+            .gap_0p5()
             .text_color(cx.theme().danger_foreground)
             .text_xs()
             .italic()
-            .child(Icon::new(IconName::Info).small())
+            .child(Icon::new(IconName::Info).xsmall())
             .child(shared_t!("chat.sent_failed"))
             .when_some(self.sent_reports(id).cloned(), |this, reports| {
                 this.on_click(move |_e, window, cx| {
                     let reports = reports.clone();
 
                     window.open_modal(cx, move |this, _window, cx| {
-                        this.title(shared_t!("chat.reports")).child(
+                        this.show_close(true)
-                            v_flex().pb_4().gap_4().children({
+                            .title(shared_t!("chat.reports"))
+                            .child(v_flex().gap_4().pb_4().w_full().children({
                                 let mut items = Vec::with_capacity(reports.len());
 
                                 for report in reports.iter() {
@@ -724,8 +884,7 @@ impl Chat {
                                 }
 
                                 items
-                            }),
+                            }))
-                        )
                     });
                 })
             })
@@ -739,6 +898,7 @@ impl Chat {
 
         v_flex()
             .gap_2()
+            .w_full()
             .child(
                 h_flex()
                     .gap_2()
@@ -752,7 +912,7 @@ impl Chat {
                             .child(name.clone()),
                     ),
             )
-            .when(report.nip17_relays_not_found, |this| {
+            .when(report.relays_not_found, |this| {
                 this.child(
                     h_flex()
                         .flex_wrap()
@@ -773,7 +933,7 @@ impl Chat {
                         ),
                 )
             })
-            .when_some(report.local_error.clone(), |this, error| {
+            .when_some(report.error.clone(), |this, error| {
                 this.child(
                     h_flex()
                         .flex_wrap()
@@ -788,38 +948,36 @@ impl Chat {
                         .child(div().flex_1().w_full().text_center().child(error)),
                 )
             })
-            .when_some(report.output.clone(), |this, output| {
+            .when_some(report.status.clone(), |this, output| {
                 this.child(
                     v_flex()
                         .gap_2()
-                        .text_xs()
+                        .w_full()
                         .children({
                             let mut items = Vec::with_capacity(output.failed.len());
 
                             for (url, msg) in output.failed.into_iter() {
                                 items.push(
-                                    h_flex()
+                                    v_flex()
-                                        .gap_1()
+                                        .gap_0p5()
-                                        .justify_between()
+                                        .py_1()
-                                        .text_sm()
+                                        .px_2()
+                                        .w_full()
+                                        .rounded(cx.theme().radius)
+                                        .bg(cx.theme().elevated_surface_background)
                                         .child(
                                             div()
-                                                .flex_1()
+                                                .text_xs()
-                                                .py_0p5()
+                                                .font_semibold()
-                                                .px_2()
+                                                .line_height(relative(1.25))
-                                                .bg(cx.theme().elevated_surface_background)
+                                                .child(SharedString::from(url.to_string())),
-                                                .rounded_sm()
-                                                .child(url.to_string()),
                                         )
                                         .child(
                                             div()
-                                                .flex_1()
+                                                .text_sm()
-                                                .py_0p5()
-                                                .px_2()
-                                                .bg(cx.theme().danger_background)
                                                 .text_color(cx.theme().danger_foreground)
-                                                .rounded_sm()
+                                                .line_height(relative(1.25))
-                                                .child(msg.to_string()),
+                                                .child(SharedString::from(msg.to_string())),
                                         ),
                                 )
                             }
@@ -831,27 +989,25 @@ impl Chat {
 
                             for url in output.success.into_iter() {
                                 items.push(
-                                    h_flex()
+                                    v_flex()
-                                        .gap_1()
+                                        .gap_0p5()
-                                        .justify_between()
+                                        .py_1()
-                                        .text_sm()
+                                        .px_2()
+                                        .w_full()
+                                        .rounded(cx.theme().radius)
+                                        .bg(cx.theme().elevated_surface_background)
                                         .child(
                                             div()
-                                                .flex_1()
+                                                .text_xs()
-                                                .py_0p5()
+                                                .font_semibold()
-                                                .px_2()
+                                                .line_height(relative(1.25))
-                                                .bg(cx.theme().elevated_surface_background)
+                                                .child(SharedString::from(url.to_string())),
-                                                .rounded_sm()
-                                                .child(url.to_string()),
                                         )
                                         .child(
                                             div()
-                                                .flex_1()
+                                                .text_sm()
-                                                .py_0p5()
-                                                .px_2()
-                                                .bg(cx.theme().secondary_background)
                                                 .text_color(cx.theme().secondary_foreground)
-                                                .rounded_sm()
+                                                .line_height(relative(1.25))
                                                 .child(shared_t!("chat.sent_success")),
                                         ),
                                 )
@@ -875,31 +1031,6 @@ impl Chat {
     }
 
     fn render_actions(&self, id: &EventId, cx: &Context<Self>) -> impl IntoElement {
-        let groups = vec![
-            Button::new("reply")
-                .icon(IconName::Reply)
-                .tooltip(t!("chat.reply_button"))
-                .small()
-                .ghost()
-                .on_click({
-                    let id = id.to_owned();
-                    cx.listener(move |this, _event, _window, cx| {
-                        this.reply_to(&id, cx);
-                    })
-                }),
-            Button::new("copy")
-                .icon(IconName::Copy)
-                .tooltip(t!("chat.copy_message_button"))
-                .small()
-                .ghost()
-                .on_click({
-                    let id = id.to_owned();
-                    cx.listener(move |this, _event, _window, cx| {
-                        this.copy_message(&id, cx);
-                    })
-                }),
-        ];
-
         h_flex()
             .p_0p5()
             .gap_1()
@@ -912,7 +1043,45 @@ impl Chat {
             .border_1()
             .border_color(cx.theme().border)
             .bg(cx.theme().background)
-            .children(groups)
+            .child(
+                Button::new("reply")
+                    .icon(IconName::Reply)
+                    .tooltip(t!("chat.reply_button"))
+                    .small()
+                    .ghost()
+                    .on_click({
+                        let id = id.to_owned();
+                        cx.listener(move |this, _event, _window, cx| {
+                            this.reply_to(&id, cx);
+                        })
+                    }),
+            )
+            .child(
+                Button::new("copy")
+                    .icon(IconName::Copy)
+                    .tooltip(t!("chat.copy_message_button"))
+                    .small()
+                    .ghost()
+                    .on_click({
+                        let id = id.to_owned();
+                        cx.listener(move |this, _event, _window, cx| {
+                            this.copy_message(&id, cx);
+                        })
+                    }),
+            )
+            .child(div().flex_shrink_0().h_4().w_px().bg(cx.theme().border))
+            .child(
+                Button::new("seen-on")
+                    .icon(IconName::Ellipsis)
+                    .small()
+                    .ghost()
+                    .popup_menu({
+                        let id = id.to_owned();
+                        move |this, _window, _cx| {
+                            this.menu(t!("common.seen_on"), Box::new(SeenOn(id)))
+                        }
+                    }),
+            )
             .group_hover("", |this| this.visible())
     }
 
@@ -921,7 +1090,7 @@ impl Chat {
         let path: SharedString = url.to_string().into();
 
         div()
-            .id("")
+            .id(SharedString::from(url.to_string()))
             .relative()
             .w_16()
             .child(
@@ -1088,6 +1257,62 @@ impl Chat {
                 .ok();
             })
     }
+
+    fn on_open_seen_on(&mut self, ev: &SeenOn, window: &mut Window, cx: &mut Context<Self>) {
+        let id = ev.0;
+
+        let task: Task<Result<Vec<RelayUrl>, Error>> = cx.background_spawn(async move {
+            let client = nostr_client();
+            let css = css();
+            let mut relays: Vec<RelayUrl> = vec![];
+
+            let filter = Filter::new()
+                .kind(Kind::ApplicationSpecificData)
+                .event(id)
+                .limit(1);
+
+            if let Some(event) = client.database().query(filter).await?.first_owned() {
+                if let Some(Ok(id)) = event.tags.identifier().map(EventId::parse) {
+                    if let Some(urls) = css.seen_on_relays.read().await.get(&id).cloned() {
+                        relays.extend(urls);
+                    }
+                }
+            }
+
+            Ok(relays)
+        });
+
+        cx.spawn_in(window, async move |_, cx| {
+            if let Ok(urls) = task.await {
+                cx.update(|window, cx| {
+                    window.open_modal(cx, move |this, _window, cx| {
+                        this.title(shared_t!("common.seen_on")).child(
+                            v_flex().pb_4().gap_2().children({
+                                let mut items = Vec::with_capacity(urls.len());
+
+                                for url in urls.clone().into_iter() {
+                                    items.push(
+                                        h_flex()
+                                            .h_8()
+                                            .px_2()
+                                            .bg(cx.theme().elevated_surface_background)
+                                            .rounded(cx.theme().radius)
+                                            .font_semibold()
+                                            .text_xs()
+                                            .child(url.to_string()),
+                                    )
+                                }
+
+                                items
+                            }),
+                        )
+                    });
+                })
+                .ok();
+            }
+        })
+        .detach();
+    }
 }
 
 impl Panel for Chat {
@@ -1134,6 +1359,7 @@ impl Focusable for Chat {
 impl Render for Chat {
     fn render(&mut self, window: &mut Window, cx: &mut Context<Self>) -> impl IntoElement {
         v_flex()
+            .on_action(cx.listener(Self::on_open_seen_on))
             .image_cache(self.image_cache.clone())
             .size_full()
             .child(
@@ -1151,6 +1377,9 @@ impl Render for Chat {
 
                                     this.render_message(ix, rendered, text, cx)
                                 }
+                                Message::Warning(content, _) => {
+                                    this.render_warning(ix, content.to_owned(), cx)
+                                }
                                 Message::System(_) => this.render_announcement(ix, cx),
                             }
                         } else {

crates/coop/src/views/compose.rs

@@ -22,7 +22,7 @@ use smallvec::{smallvec, SmallVec};
 use smol::Timer;
 use theme::ActiveTheme;
 use ui::avatar::Avatar;
-use ui::button::{Button, ButtonRounded, ButtonVariants};
+use ui::button::{Button, ButtonVariants};
 use ui::input::{InputEvent, InputState, TextInput};
 use ui::notification::Notification;
 use ui::{h_flex, v_flex, ContextModal, Disableable, Icon, IconName, Sizable, StyledExt};
@@ -34,7 +34,7 @@ pub fn compose_button() -> impl IntoElement {
             .ghost_alt()
             .cta()
             .small()
-            .rounded(ButtonRounded::Full)
+            .rounded()
             .on_click(move |_, window, cx| {
                 let compose = cx.new(|cx| Compose::new(window, cx));
                 let title = SharedString::new(t!("sidebar.direct_messages"));

crates/coop/src/views/edit_profile.rs

@@ -164,7 +164,7 @@ impl EditProfile {
         .detach();
     }
 
-    pub fn set_metadata(&mut self, cx: &mut Context<Self>) -> Task<Result<Option<Event>, Error>> {
+    pub fn set_metadata(&mut self, cx: &mut Context<Self>) -> Task<Result<Option<Profile>, Error>> {
         let avatar = self.avatar_input.read(cx).value().to_string();
         let name = self.name_input.read(cx).value().to_string();
         let bio = self.bio_input.read(cx).value().to_string();
@@ -189,7 +189,14 @@ impl EditProfile {
         cx.background_spawn(async move {
             let client = nostr_client();
             let output = client.set_metadata(&new_metadata).await?;
-            let event = client.database().event_by_id(&output.val).await?;
+            let event = client
+                .database()
+                .event_by_id(&output.val)
+                .await?
+                .map(|event| {
+                    let metadata = Metadata::from_json(&event.content).unwrap_or_default();
+                    Profile::new(event.pubkey, metadata)
+                });
 
             Ok(event)
         })

crates/coop/src/views/new_account.rs

@@ -14,7 +14,7 @@ use settings::AppSettings;
 use smol::fs;
 use theme::ActiveTheme;
 use ui::avatar::Avatar;
-use ui::button::{Button, ButtonRounded, ButtonVariants};
+use ui::button::{Button, ButtonVariants};
 use ui::dock_area::panel::{Panel, PanelEvent};
 use ui::input::{InputState, TextInput};
 use ui::modal::ModalButtonProps;
@@ -352,7 +352,7 @@ impl Render for NewAccount {
                                             .label(t!("common.upload"))
                                             .ghost()
                                             .small()
-                                            .rounded(ButtonRounded::Full)
+                                            .rounded()
                                             .disabled(self.submitting || self.uploading)
                                             .loading(self.uploading)
                                             .on_click(cx.listener(move |this, _, window, cx| {

crates/coop/src/views/preferences.rs

@@ -10,7 +10,7 @@ use registry::Registry;
 use settings::AppSettings;
 use theme::ActiveTheme;
 use ui::avatar::Avatar;
-use ui::button::{Button, ButtonRounded, ButtonVariants};
+use ui::button::{Button, ButtonVariants};
 use ui::input::{InputState, TextInput};
 use ui::modal::ModalButtonProps;
 use ui::switch::Switch;
@@ -41,28 +41,28 @@ impl Preferences {
     fn open_edit_profile(&self, window: &mut Window, cx: &mut Context<Self>) {
         let view = edit_profile::init(window, cx);
         let weak_view = view.downgrade();
-        let title = SharedString::new(t!("profile.title"));
 
         window.open_modal(cx, move |modal, _window, _cx| {
             let weak_view = weak_view.clone();
 
             modal
                 .confirm()
-                .title(title.clone())
+                .title(shared_t!("profile.title"))
                 .child(view.clone())
                 .button_props(ModalButtonProps::default().ok_text(t!("common.update")))
                 .on_ok(move |_, window, cx| {
                     weak_view
                         .update(cx, |this, cx| {
                             let set_metadata = this.set_metadata(cx);
+                            let registry = Registry::global(cx);
 
                             cx.spawn_in(window, async move |_, cx| {
                                 match set_metadata.await {
-                                    Ok(event) => {
+                                    Ok(profile) => {
-                                        if let Some(event) = event {
+                                        if let Some(profile) = profile {
                                             cx.update(|_, cx| {
-                                                Registry::global(cx).update(cx, |this, cx| {
+                                                registry.update(cx, |this, cx| {
-                                                    this.insert_or_update_person(event, cx);
+                                                    this.insert_or_update_person(profile, cx);
                                                 });
                                             })
                                             .ok();
@@ -169,7 +169,7 @@ impl Render for Preferences {
                                     .label("Messaging Relays")
                                     .xsmall()
                                     .ghost_alt()
-                                    .rounded(ButtonRounded::Full)
+                                    .rounded()
                                     .on_click(cx.listener(move |this, _e, window, cx| {
                                         this.open_relays(window, cx);
                                     })),

crates/coop/src/views/screening.rs

@@ -17,7 +17,7 @@ use settings::AppSettings;
 use smallvec::{smallvec, SmallVec};
 use theme::ActiveTheme;
 use ui::avatar::Avatar;
-use ui::button::{Button, ButtonRounded, ButtonVariants};
+use ui::button::{Button, ButtonVariants};
 use ui::indicator::Indicator;
 use ui::{h_flex, v_flex, ContextModal, Icon, IconName, Sizable, StyledExt};
 
@@ -29,10 +29,9 @@ pub struct Screening {
     profile: Profile,
     verified: bool,
     followed: bool,
-    dm_relays: Option<bool>,
     last_active: Option<Timestamp>,
     mutual_contacts: Vec<Profile>,
-    _tasks: SmallVec<[Task<()>; 4]>,
+    _tasks: SmallVec<[Task<()>; 3]>,
 }
 
 impl Screening {
@@ -83,24 +82,6 @@ impl Screening {
             activity
         });
 
-        let relay_check = cx.background_spawn(async move {
-            let client = nostr_client();
-            let mut relay = false;
-
-            let filter = Filter::new()
-                .kind(Kind::InboxRelays)
-                .author(public_key)
-                .limit(1);
-
-            if let Ok(mut stream) = client.stream_events(filter, Duration::from_secs(2)).await {
-                while stream.next().await.is_some() {
-                    relay = true
-                }
-            }
-
-            relay
-        });
-
         let addr_check = if let Some(address) = profile.metadata().nip05 {
             Some(Tokio::spawn(cx, async move {
                 nip05_verify(public_key, &address).await.unwrap_or(false)
@@ -136,19 +117,6 @@ impl Screening {
             }),
         );
 
-        tasks.push(
-            // Run the relay check in the background
-            cx.spawn_in(window, async move |this, cx| {
-                let relay = relay_check.await;
-
-                this.update(cx, |this, cx| {
-                    this.dm_relays = Some(relay);
-                    cx.notify();
-                })
-                .ok();
-            }),
-        );
-
         tasks.push(
             // Run the NIP-05 verification in the background
             cx.spawn_in(window, async move |this, cx| {
@@ -168,7 +136,6 @@ impl Screening {
             profile,
             verified: false,
             followed: false,
-            dm_relays: None,
             last_active: None,
             mutual_contacts: vec![],
             _tasks: tasks,
@@ -301,7 +268,7 @@ impl Render for Screening {
                                     .label(t!("profile.njump"))
                                     .secondary()
                                     .small()
-                                    .rounded(ButtonRounded::Full)
+                                    .rounded()
                                     .on_click(cx.listener(move |this, _e, window, cx| {
                                         this.open_njump(window, cx);
                                     })),
@@ -311,7 +278,7 @@ impl Render for Screening {
                                     .tooltip(t!("screening.report"))
                                     .icon(IconName::Report)
                                     .danger()
-                                    .rounded(ButtonRounded::Full)
+                                    .rounded()
                                     .on_click(cx.listener(move |this, _e, window, cx| {
                                         this.report(window, cx);
                                     })),
@@ -363,7 +330,7 @@ impl Render for Screening {
                                                     .icon(IconName::Info)
                                                     .xsmall()
                                                     .ghost()
-                                                    .rounded(ButtonRounded::Full)
+                                                    .rounded()
                                                     .tooltip(t!("screening.active_tooltip")),
                                             ),
                                     )
@@ -435,7 +402,7 @@ impl Render for Screening {
                                                     .icon(IconName::Info)
                                                     .xsmall()
                                                     .ghost()
-                                                    .rounded(ButtonRounded::Full)
+                                                    .rounded()
                                                     .on_click(cx.listener(
                                                         move |this, _, window, cx| {
                                                             this.mutual_contacts(window, cx);
@@ -456,37 +423,6 @@ impl Render for Screening {
                                             }),
                                     ),
                             ),
-                    )
-                    .child(
-                        h_flex()
-                            .items_start()
-                            .gap_2()
-                            .child(status_badge(self.dm_relays, cx))
-                            .child(
-                                v_flex()
-                                    .w_full()
-                                    .text_sm()
-                                    .child({
-                                        if self.dm_relays == Some(true) {
-                                            shared_t!("screening.relay_found")
-                                        } else {
-                                            shared_t!("screening.relay_empty")
-                                        }
-                                    })
-                                    .child(
-                                        div()
-                                            .w_full()
-                                            .line_clamp(1)
-                                            .text_color(cx.theme().text_muted)
-                                            .child({
-                                                if self.dm_relays == Some(true) {
-                                                    shared_t!("screening.relay_found_desc")
-                                                } else {
-                                                    shared_t!("screening.relay_empty_desc")
-                                                }
-                                            }),
-                                    ),
-                            ),
                     ),
             )
     }

crates/coop/src/views/setup_relay.rs

@@ -14,7 +14,7 @@ use nostr_sdk::prelude::*;
 use registry::Registry;
 use smallvec::{smallvec, SmallVec};
 use theme::ActiveTheme;
-use ui::button::{Button, ButtonRounded, ButtonVariants};
+use ui::button::{Button, ButtonVariants};
 use ui::input::{InputEvent, InputState, TextInput};
 use ui::modal::ModalButtonProps;
 use ui::{h_flex, v_flex, ContextModal, IconName, Sizable, StyledExt};
@@ -33,7 +33,7 @@ where
             .label(label)
             .warning()
             .xsmall()
-            .rounded(ButtonRounded::Full)
+            .rounded()
             .on_click(move |_, window, cx| {
                 let view = cx.new(|cx| SetupRelay::new(Kind::InboxRelays, window, cx));
                 let weak_view = view.downgrade();

crates/coop/src/views/sidebar/mod.rs

@@ -9,9 +9,9 @@ use global::constants::{BOOTSTRAP_RELAYS, SEARCH_RELAYS};
 use global::{css, nostr_client, UnwrappingStatus};
 use gpui::prelude::FluentBuilder;
 use gpui::{
-    div, uniform_list, AnyElement, App, AppContext, Context, Entity, EventEmitter, FocusHandle,
+    div, relative, uniform_list, AnyElement, App, AppContext, Context, Entity, EventEmitter,
-    Focusable, InteractiveElement, IntoElement, ParentElement, Render, RetainAllImageCache,
+    FocusHandle, Focusable, InteractiveElement, IntoElement, ParentElement, Render,
-    SharedString, Styled, Subscription, Task, Window,
+    RetainAllImageCache, SharedString, Styled, Subscription, Task, Window,
 };
 use gpui_tokio::Tokio;
 use i18n::{shared_t, t};
@@ -23,7 +23,7 @@ use registry::{Registry, RegistryEvent};
 use settings::AppSettings;
 use smallvec::{smallvec, SmallVec};
 use theme::ActiveTheme;
-use ui::button::{Button, ButtonRounded, ButtonVariants};
+use ui::button::{Button, ButtonVariants};
 use ui::dock_area::panel::{Panel, PanelEvent};
 use ui::input::{InputEvent, InputState, TextInput};
 use ui::popup_menu::{PopupMenu, PopupMenuExt};
@@ -669,6 +669,7 @@ impl Focusable for Sidebar {
 impl Render for Sidebar {
     fn render(&mut self, _window: &mut Window, cx: &mut Context<Self>) -> impl IntoElement {
         let registry = Registry::read_global(cx);
+        let loading = registry.unwrapping_status.read(cx) != &UnwrappingStatus::Complete;
 
         // Get rooms from either search results or the chat registry
         let rooms = if let Some(results) = self.local_result.read(cx).as_ref() {
@@ -688,7 +689,7 @@ impl Render for Sidebar {
         let mut total_rooms = rooms.len();
 
         // Add 3 dummy rooms to display as skeletons
-        if registry.unwrapping_status.read(cx) != &UnwrappingStatus::Complete {
+        if loading {
             total_rooms += 3
         }
 
@@ -752,7 +753,7 @@ impl Render for Sidebar {
                                     .cta()
                                     .bold()
                                     .secondary()
-                                    .rounded(ButtonRounded::Full)
+                                    .rounded()
                                     .selected(self.filter(&RoomKind::Ongoing, cx))
                                     .on_click(cx.listener(|this, _, _, cx| {
                                         this.set_filter(RoomKind::Ongoing, cx);
@@ -773,7 +774,7 @@ impl Render for Sidebar {
                                     .cta()
                                     .bold()
                                     .secondary()
-                                    .rounded(ButtonRounded::Full)
+                                    .rounded()
                                     .selected(!self.filter(&RoomKind::Ongoing, cx))
                                     .on_click(cx.listener(|this, _, _, cx| {
                                         this.set_filter(RoomKind::default(), cx);
@@ -791,7 +792,7 @@ impl Render for Sidebar {
                                             .icon(IconName::Ellipsis)
                                             .xsmall()
                                             .ghost()
-                                            .rounded(ButtonRounded::Full)
+                                            .rounded()
                                             .popup_menu(move |this, _window, _cx| {
                                                 this.menu(
                                                     t!("sidebar.reload_menu"),
@@ -805,6 +806,57 @@ impl Render for Sidebar {
                                     ),
                             ),
                     )
+                    .when(!loading && total_rooms == 0, |this| {
+                        this.map(|this| {
+                            if self.filter(&RoomKind::Ongoing, cx) {
+                                this.child(
+                                    v_flex()
+                                        .py_2()
+                                        .gap_1p5()
+                                        .items_center()
+                                        .justify_center()
+                                        .text_center()
+                                        .child(
+                                            div()
+                                                .text_sm()
+                                                .font_semibold()
+                                                .line_height(relative(1.25))
+                                                .child(shared_t!("sidebar.no_conversations")),
+                                        )
+                                        .child(
+                                            div()
+                                                .text_xs()
+                                                .text_color(cx.theme().text_muted)
+                                                .line_height(relative(1.25))
+                                                .child(shared_t!("sidebar.no_conversations_label")),
+                                        ),
+                                )
+                            } else {
+                                this.child(
+                                    v_flex()
+                                        .py_2()
+                                        .gap_1p5()
+                                        .items_center()
+                                        .justify_center()
+                                        .text_center()
+                                        .child(
+                                            div()
+                                                .text_sm()
+                                                .font_semibold()
+                                                .line_height(relative(1.25))
+                                                .child(shared_t!("sidebar.no_requests")),
+                                        )
+                                        .child(
+                                            div()
+                                                .text_xs()
+                                                .text_color(cx.theme().text_muted)
+                                                .line_height(relative(1.25))
+                                                .child(shared_t!("sidebar.no_requests_label")),
+                                        ),
+                                )
+                            }
+                        })
+                    })
                     .child(
                         uniform_list(
                             "rooms",

crates/coop/src/views/welcome.rs

@@ -1,12 +1,13 @@
 use gpui::{
     div, svg, AnyElement, App, AppContext, Context, Entity, EventEmitter, FocusHandle, Focusable,
-    IntoElement, ParentElement, Render, SharedString, Styled, Window,
+    InteractiveElement, IntoElement, ParentElement, Render, SharedString,
+    StatefulInteractiveElement, Styled, Window,
 };
 use theme::ActiveTheme;
 use ui::button::Button;
 use ui::dock_area::panel::{Panel, PanelEvent};
 use ui::popup_menu::PopupMenu;
-use ui::StyledExt;
+use ui::{v_flex, StyledExt};
 
 pub fn init(window: &mut Window, cx: &mut App) -> Entity<Welcome> {
     Welcome::new(window, cx)
@@ -14,8 +15,7 @@ pub fn init(window: &mut Window, cx: &mut App) -> Entity<Welcome> {
 
 pub struct Welcome {
     name: SharedString,
-    closable: bool,
+    version: SharedString,
-    zoomable: bool,
     focus_handle: FocusHandle,
 }
 
@@ -25,10 +25,11 @@ impl Welcome {
     }
 
     fn view(_window: &mut Window, cx: &mut Context<Self>) -> Self {
+        let version = SharedString::from(format!("Version: {}", env!("CARGO_PKG_VERSION")));
+
         Self {
+            version,
             name: "Welcome".into(),
-            closable: true,
-            zoomable: true,
             focus_handle: cx.focus_handle(),
         }
     }
@@ -39,16 +40,15 @@ impl Panel for Welcome {
         self.name.clone()
     }
 
-    fn title(&self, _cx: &App) -> AnyElement {
+    fn title(&self, cx: &App) -> AnyElement {
-        "👋".into_any_element()
+        div()
-    }
+            .child(
-
+                svg()
-    fn closable(&self, _cx: &App) -> bool {
+                    .path("brand/coop.svg")
-        self.closable
+                    .size_4()
-    }
+                    .text_color(cx.theme().element_background),
-
+            )
-    fn zoomable(&self, _cx: &App) -> bool {
+            .into_any_element()
-        self.zoomable
     }
 
     fn popup_menu(&self, menu: PopupMenu, _cx: &App) -> PopupMenu {
@@ -76,23 +76,37 @@ impl Render for Welcome {
             .items_center()
             .justify_center()
             .child(
-                div()
+                v_flex()
-                    .flex()
+                    .gap_2()
-                    .flex_col()
                     .items_center()
-                    .gap_1()
+                    .justify_center()
                     .child(
                         svg()
                             .path("brand/coop.svg")
                             .size_12()
                             .text_color(cx.theme().elevated_surface_background),
                     )
+                    .child(
+                        v_flex()
+                            .items_center()
+                            .justify_center()
+                            .text_center()
                             .child(
                                 div()
-                            .child("coop on nostr")
-                            .text_color(cx.theme().text_placeholder)
                                     .font_semibold()
-                            .text_sm(),
+                                    .text_color(cx.theme().text_muted)
+                                    .child("coop on nostr"),
+                            )
+                            .child(
+                                div()
+                                    .id("version")
+                                    .text_color(cx.theme().text_placeholder)
+                                    .text_xs()
+                                    .child(self.version.clone())
+                                    .on_click(|_, _window, cx| {
+                                        cx.open_url("https://github.com/lumehq/coop/releases");
+                                    }),
+                            ),
                     ),
             )
     }

crates/global/src/constants.rs

@@ -37,7 +37,7 @@ pub const NOSTR_CONNECT_RELAY: &str = "wss://relay.nsec.app";
 pub const RELAY_RETRY: u64 = 2;
 
 /// Default retry count for sending messages
-pub const SEND_RETRY: u64 = 5;
+pub const SEND_RETRY: u64 = 10;
 
 /// Default timeout (in seconds) for Nostr Connect
 pub const NOSTR_CONNECT_TIMEOUT: u64 = 200;

crates/global/src/lib.rs

@@ -13,16 +13,18 @@ use crate::paths::support_dir;
 pub mod constants;
 pub mod paths;
 
-#[derive(Debug, Clone, Hash, PartialEq, Eq, PartialOrd, Ord)]
+#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord)]
 pub struct AuthRequest {
-    pub challenge: String,
     pub url: RelayUrl,
+    pub challenge: String,
+    pub sending: bool,
 }
 
 impl AuthRequest {
     pub fn new(challenge: impl Into<String>, url: RelayUrl) -> Self {
         Self {
             challenge: challenge.into(),
+            sending: false,
             url,
         }
     }
@@ -55,7 +57,7 @@ pub enum UnwrappingStatus {
 
 /// Signals sent through the global event channel to notify UI
 #[derive(Debug)]
-pub enum Signal {
+pub enum SignalKind {
     /// A signal to notify UI that the client's signer has been set
     SignerSet(PublicKey),
 
@@ -68,26 +70,55 @@ pub enum Signal {
     /// A signal to notify UI that the browser proxy service is down
     ProxyDown,
 
-    /// A signal to notify UI that a new metadata event has been received
+    /// A signal to notify UI that a new profile has been received
-    Metadata(Event),
+    NewProfile(Profile),
 
     /// A signal to notify UI that a new gift wrap event has been received
-    Message((EventId, Event)),
+    NewMessage((EventId, Event)),
 
-    /// A signal to notify UI that gift wrap process status has changed
+    /// A signal to notify UI that no DM relays for current user was found
-    GiftWrapProcess(UnwrappingStatus),
+    RelaysNotFound,
 
-    /// A signal to notify UI that no DM relay for current user was found
+    /// A signal to notify UI that gift wrap status has changed
-    DmRelayNotFound,
+    GiftWrapStatus(UnwrappingStatus),
 
     /// A signal to notify UI that there are errors or notices occurred
     Notice(Notice),
 }
 
+#[derive(Debug)]
+pub struct Signal {
+    rx: Receiver<SignalKind>,
+    tx: Sender<SignalKind>,
+}
+
+impl Default for Signal {
+    fn default() -> Self {
+        Self::new()
+    }
+}
+
+impl Signal {
+    pub fn new() -> Self {
+        let (tx, rx) = flume::bounded::<SignalKind>(2048);
+        Self { rx, tx }
+    }
+
+    pub fn receiver(&self) -> &Receiver<SignalKind> {
+        &self.rx
+    }
+
+    pub async fn send(&self, kind: SignalKind) {
+        if let Err(e) = self.tx.send_async(kind).await {
+            log::error!("Failed to send signal: {e}");
+        }
+    }
+}
+
 #[derive(Debug)]
 pub struct Ingester {
-    rx: Receiver<Signal>,
+    rx: Receiver<PublicKey>,
-    tx: Sender<Signal>,
+    tx: Sender<PublicKey>,
 }
 
 impl Default for Ingester {
@@ -98,31 +129,47 @@ impl Default for Ingester {
 
 impl Ingester {
     pub fn new() -> Self {
-        let (tx, rx) = flume::bounded::<Signal>(2048);
+        let (tx, rx) = flume::bounded::<PublicKey>(1024);
         Self { rx, tx }
     }
 
-    pub fn signals(&self) -> &Receiver<Signal> {
+    pub fn receiver(&self) -> &Receiver<PublicKey> {
         &self.rx
     }
 
-    pub async fn send(&self, signal: Signal) {
+    pub async fn send(&self, public_key: PublicKey) {
-        if let Err(e) = self.tx.send_async(signal).await {
+        if let Err(e) = self.tx.send_async(public_key).await {
-            log::error!("Failed to send signal: {e}");
+            log::error!("Failed to send public key: {e}");
         }
     }
 }
 
-/// A simple storage to store all runtime states that using across the application.
+/// A simple storage to store all states that using across the application.
 #[derive(Debug)]
 pub struct CoopSimpleStorage {
     pub init_at: Timestamp,
+
+    pub last_used_at: Option<Timestamp>,
+
+    pub is_first_run: AtomicBool,
+
     pub gift_wrap_sub_id: SubscriptionId,
+
     pub gift_wrap_processing: AtomicBool,
+
     pub auto_close_opts: Option<SubscribeAutoCloseOptions>,
+
+    pub seen_on_relays: RwLock<HashMap<EventId, HashSet<RelayUrl>>>,
+
     pub sent_ids: RwLock<HashSet<EventId>>,
+
     pub resent_ids: RwLock<Vec<Output<EventId>>>,
+
     pub resend_queue: RwLock<HashMap<EventId, RelayUrl>>,
+
+    pub signal: Signal,
+
+    pub ingester: Ingester,
 }
 
 impl Default for CoopSimpleStorage {
@@ -133,13 +180,23 @@ impl Default for CoopSimpleStorage {
 
 impl CoopSimpleStorage {
     pub fn new() -> Self {
+        let init_at = Timestamp::now();
+        let first_run = first_run();
+        let opts = SubscribeAutoCloseOptions::default().exit_policy(ReqExitPolicy::ExitOnEOSE);
+
+        let signal = Signal::default();
+        let ingester = Ingester::default();
+
         Self {
-            init_at: Timestamp::now(),
+            init_at,
+            signal,
+            ingester,
+            last_used_at: None,
+            is_first_run: AtomicBool::new(first_run),
             gift_wrap_sub_id: SubscriptionId::new("inbox"),
             gift_wrap_processing: AtomicBool::new(false),
-            auto_close_opts: Some(
+            auto_close_opts: Some(opts),
-                SubscribeAutoCloseOptions::default().exit_policy(ReqExitPolicy::ExitOnEOSE),
+            seen_on_relays: RwLock::new(HashMap::new()),
-            ),
             sent_ids: RwLock::new(HashSet::new()),
             resent_ids: RwLock::new(Vec::new()),
             resend_queue: RwLock::new(HashMap::new()),
@@ -148,9 +205,7 @@ impl CoopSimpleStorage {
 }
 
 static NOSTR_CLIENT: OnceLock<Client> = OnceLock::new();
-static INGESTER: OnceLock<Ingester> = OnceLock::new();
 static COOP_SIMPLE_STORAGE: OnceLock<CoopSimpleStorage> = OnceLock::new();
-static FIRST_RUN: OnceLock<bool> = OnceLock::new();
 
 pub fn nostr_client() -> &'static Client {
     NOSTR_CLIENT.get_or_init(|| {
@@ -175,16 +230,11 @@ pub fn nostr_client() -> &'static Client {
     })
 }
 
-pub fn ingester() -> &'static Ingester {
-    INGESTER.get_or_init(Ingester::new)
-}
-
 pub fn css() -> &'static CoopSimpleStorage {
     COOP_SIMPLE_STORAGE.get_or_init(CoopSimpleStorage::new)
 }
 
-pub fn first_run() -> &'static bool {
+fn first_run() -> bool {
-    FIRST_RUN.get_or_init(|| {
     let flag = support_dir().join(format!(".{}-first_run", env!("CARGO_PKG_VERSION")));
 
     if !flag.exists() {
@@ -195,5 +245,4 @@ pub fn first_run() -> &'static bool {
     } else {
         false // Not first run
     }
-    })
 }

crates/registry/src/lib.rs

@@ -155,21 +155,19 @@ impl Registry {
     }
 
     /// Insert or update a person
-    pub fn insert_or_update_person(&mut self, event: Event, cx: &mut App) {
+    pub fn insert_or_update_person(&mut self, profile: Profile, cx: &mut App) {
-        let public_key = event.pubkey;
+        let public_key = profile.public_key();
-        let Ok(metadata) = Metadata::from_json(event.content) else {
-            // Invalid metadata, no need to process further.
-            return;
-        };
 
-        if let Some(person) = self.persons.get(&public_key) {
+        match self.persons.get(&public_key) {
+            Some(person) => {
                 person.update(cx, |this, cx| {
-                *this = Profile::new(public_key, metadata);
+                    *this = profile;
                     cx.notify();
                 });
-        } else {
+            }
-            self.persons
+            None => {
-                .insert(public_key, cx.new(|_| Profile::new(public_key, metadata)));
+                self.persons.insert(public_key, cx.new(|_| profile));
+            }
         }
     }
 

crates/registry/src/message.rs

@@ -5,6 +5,7 @@ use nostr_sdk::prelude::*;
 #[derive(Debug, Clone, Hash, PartialEq, Eq)]
 pub enum Message {
     User(RenderedMessage),
+    Warning(String, Timestamp),
     System(Timestamp),
 }
 
@@ -13,6 +14,10 @@ impl Message {
         Self::User(user.into())
     }
 
+    pub fn warning(content: String) -> Self {
+        Self::Warning(content, Timestamp::now())
+    }
+
     pub fn system() -> Self {
         Self::System(Timestamp::default())
     }
@@ -25,6 +30,11 @@ impl Ord for Message {
             (Message::System(a), Message::System(b)) => a.cmp(b),
             (Message::User(a), Message::System(b)) => a.created_at.cmp(b),
             (Message::System(a), Message::User(b)) => a.cmp(&b.created_at),
+            (Message::Warning(_, a), Message::Warning(_, b)) => a.cmp(b),
+            (Message::Warning(_, a), Message::User(b)) => a.cmp(&b.created_at),
+            (Message::User(a), Message::Warning(_, b)) => a.created_at.cmp(b),
+            (Message::Warning(_, a), Message::System(b)) => a.cmp(b),
+            (Message::System(a), Message::Warning(_, b)) => a.cmp(b),
         }
     }
 }

crates/registry/src/room.rs

@@ -1,4 +1,5 @@
 use std::cmp::Ordering;
+use std::collections::{HashMap, HashSet};
 use std::hash::{Hash, Hasher};
 use std::time::Duration;
 
@@ -16,45 +17,51 @@ use crate::Registry;
 #[derive(Debug, Clone)]
 pub struct SendReport {
     pub receiver: PublicKey,
-    pub output: Option<Output<EventId>>,
+    pub tags: Option<Vec<Tag>>,
-    pub local_error: Option<SharedString>,
+    pub status: Option<Output<EventId>>,
-    pub nip17_relays_not_found: bool,
+    pub error: Option<SharedString>,
+    pub relays_not_found: bool,
 }
 
 impl SendReport {
-    pub fn output(receiver: PublicKey, output: Output<EventId>) -> Self {
+    pub fn new(receiver: PublicKey) -> Self {
         Self {
             receiver,
-            output: Some(output),
+            status: None,
-            local_error: None,
+            error: None,
-            nip17_relays_not_found: false,
+            tags: None,
+            relays_not_found: false,
         }
     }
 
-    pub fn error(receiver: PublicKey, error: impl Into<SharedString>) -> Self {
+    pub fn not_found(mut self) -> Self {
-        Self {
+        self.relays_not_found = true;
-            receiver,
+        self
-            output: None,
-            local_error: Some(error.into()),
-            nip17_relays_not_found: false,
-        }
     }
 
-    pub fn nip17_relays_not_found(receiver: PublicKey) -> Self {
+    pub fn error(mut self, error: impl Into<SharedString>) -> Self {
-        Self {
+        self.error = Some(error.into());
-            receiver,
+        self.relays_not_found = false;
-            output: None,
+        self
-            local_error: None,
-            nip17_relays_not_found: true,
     }
+
+    pub fn status(mut self, output: Output<EventId>) -> Self {
+        self.status = Some(output);
+        self.relays_not_found = false;
+        self
+    }
+
+    pub fn tags(mut self, tags: &Vec<Tag>) -> Self {
+        self.tags = Some(tags.to_owned());
+        self
     }
 
     pub fn is_relay_error(&self) -> bool {
-        self.local_error.is_some() || self.nip17_relays_not_found
+        self.error.is_some() || self.relays_not_found
     }
 
     pub fn is_sent_success(&self) -> bool {
-        if let Some(output) = self.output.as_ref() {
+        if let Some(output) = self.status.as_ref() {
             !output.success.is_empty()
         } else {
             false
@@ -324,48 +331,69 @@ impl Room {
         }
     }
 
+    /// Connects to all members' messaging relays
+    pub fn connect_relays(
+        &self,
+        cx: &App,
+    ) -> Task<Result<HashMap<PublicKey, Vec<RelayUrl>>, Error>> {
+        let members = self.members.clone();
+
+        cx.background_spawn(async move {
+            let client = nostr_client();
+            let timeout = Duration::from_secs(3);
+            let mut processed = HashSet::new();
+            let mut relays: HashMap<PublicKey, Vec<RelayUrl>> = HashMap::new();
+
+            if let Some((_, members)) = members.split_last() {
+                for member in members.iter() {
+                    relays.insert(member.to_owned(), vec![]);
+
+                    let filter = Filter::new()
+                        .kind(Kind::InboxRelays)
+                        .author(member.to_owned())
+                        .limit(1);
+
+                    if let Ok(mut stream) = client.stream_events(filter, timeout).await {
+                        if let Some(event) = stream.next().await {
+                            if processed.insert(event.id) {
+                                let urls = nip17::extract_owned_relay_list(event).collect_vec();
+                                relays.entry(member.to_owned()).or_default().extend(urls);
+                            }
+                        }
+                    }
+                }
+            };
+
+            Ok(relays)
+        })
+    }
+
     /// Loads all messages for this room from the database
-    ///
-    /// # Arguments
-    ///
-    /// * `cx` - The App context
-    ///
-    /// # Returns
-    ///
-    /// A Task that resolves to Result<Vec<Event>, Error> containing all messages for this room
     pub fn load_messages(&self, cx: &App) -> Task<Result<Vec<Event>, Error>> {
         let members = self.members.clone();
 
         cx.background_spawn(async move {
             let client = nostr_client();
+            let public_key = members[members.len() - 1];
 
-            let filter = Filter::new()
+            let sent = Filter::new()
                 .kind(Kind::PrivateDirectMessage)
-                .authors(members.clone())
+                .author(public_key)
                 .pubkeys(members.clone());
 
-            let events: Vec<Event> = client
+            let recv = Filter::new()
-                .database()
+                .kind(Kind::PrivateDirectMessage)
-                .query(filter)
+                .authors(members)
-                .await?
+                .pubkey(public_key);
-                .into_iter()
+
-                .filter(|ev| ev.compare_pubkeys(&members))
+            let sent_events = client.database().query(sent).await?;
-                .collect();
+            let recv_events = client.database().query(recv).await?;
+            let events: Vec<Event> = sent_events.merge(recv_events).into_iter().collect();
 
             Ok(events)
         })
     }
 
-    /// Emits a new message signal to the current room
-    pub fn emit_message(&self, gift_wrap_id: EventId, event: Event, cx: &mut Context<Self>) {
-        cx.emit(RoomSignal::NewMessage((gift_wrap_id, Box::new(event))));
-    }
-
-    /// Emits a signal to refresh the current room's messages.
-    pub fn emit_refresh(&mut self, cx: &mut Context<Self>) {
-        cx.emit(RoomSignal::Refresh);
-    }
-
     /// Creates a temporary message for optimistic updates
     ///
     /// The event must not been published to relays.
@@ -398,17 +426,7 @@ impl Room {
         event
     }
 
-    /// Sends a message to all members in the background task
+    /// Create a task to sends a message to all members in the background
-    ///
-    /// # Arguments
-    ///
-    /// * `content` - The content of the message to send
-    /// * `cx` - The App context
-    ///
-    /// # Returns
-    ///
-    /// A Task that resolves to Result<Vec<String>, Error> where the
-    /// strings contain error messages for any failed sends
     pub fn send_in_background(
         &self,
         content: &str,
@@ -422,20 +440,21 @@ impl Room {
         let mut public_keys = self.members.clone();
 
         cx.background_spawn(async move {
+            let css = css();
             let client = nostr_client();
             let signer = client.signer().await?;
             let public_key = signer.get_public_key().await?;
 
-            let mut tags = public_keys
+            let mut tags: Vec<Tag> = public_keys
                 .iter()
-                .filter_map(|pubkey| {
+                .filter_map(|&this| {
-                    if pubkey != &public_key {
+                    if this != public_key {
-                        Some(Tag::public_key(*pubkey))
+                        Some(Tag::public_key(this))
                     } else {
                         None
                     }
                 })
-                .collect_vec();
+                .collect();
 
             // Add event reference if it's present (replying to another event)
             if replies.len() == 1 {
@@ -468,44 +487,50 @@ impl Room {
             // Stored all send errors
             let mut reports = vec![];
 
-            for receiver in public_keys.into_iter() {
+            for pubkey in public_keys.into_iter() {
                 match client
-                    .send_private_msg(receiver, &content, tags.clone())
+                    .send_private_msg(pubkey, &content, tags.clone())
                     .await
                 {
                     Ok(output) => {
-                        if output
+                        let id = output.id().to_owned();
-                            .failed
+                        let auth_required = output.failed.iter().any(|m| m.1.starts_with("auth-"));
-                            .iter()
+                        let report = SendReport::new(pubkey).status(output).tags(&tags);
-                            .any(|(_, msg)| msg.starts_with("auth-required:"))
-                        {
-                            let id = output.id();
 
+                        if auth_required {
                             // Wait for authenticated and resent event successfully
                             for attempt in 0..=SEND_RETRY {
                                 // Check if event was successfully resent
-                                if let Some(output) =
+                                if let Some(output) = css
-                                    css().resent_ids.read().await.iter().find(|o| o.id() == id)
+                                    .resent_ids
+                                    .read()
+                                    .await
+                                    .iter()
+                                    .find(|e| e.id() == &id)
+                                    .cloned()
                                 {
-                                    reports.push(SendReport::output(receiver, output.to_owned()));
+                                    let output = SendReport::new(pubkey).status(output).tags(&tags);
+                                    reports.push(output);
                                     break;
                                 }
 
+                                // Check if retry limit exceeded
                                 if attempt == SEND_RETRY {
+                                    reports.push(report);
                                     break;
                                 }
 
-                                smol::Timer::after(Duration::from_secs(1)).await;
+                                smol::Timer::after(Duration::from_millis(1200)).await;
                             }
                         } else {
-                            reports.push(SendReport::output(receiver, output));
+                            reports.push(report);
                         }
                     }
                     Err(e) => {
                         if let nostr_sdk::client::Error::PrivateMsgRelaysNotFound = e {
-                            reports.push(SendReport::nip17_relays_not_found(receiver));
+                            reports.push(SendReport::new(pubkey).not_found().tags(&tags));
                         } else {
-                            reports.push(SendReport::error(receiver, e.to_string()));
+                            reports.push(SendReport::new(pubkey).error(e.to_string()).tags(&tags));
                         }
                     }
                 }
@@ -518,13 +543,14 @@ impl Room {
                     .await
                 {
                     Ok(output) => {
-                        reports.push(SendReport::output(public_key, output));
+                        reports.push(SendReport::new(public_key).status(output).tags(&tags));
                     }
                     Err(e) => {
                         if let nostr_sdk::client::Error::PrivateMsgRelaysNotFound = e {
-                            reports.push(SendReport::nip17_relays_not_found(public_key));
+                            reports.push(SendReport::new(public_key).not_found());
                         } else {
-                            reports.push(SendReport::error(public_key, e.to_string()));
+                            reports
+                                .push(SendReport::new(public_key).error(e.to_string()).tags(&tags));
                         }
                     }
                 }
@@ -533,4 +559,67 @@ impl Room {
             Ok(reports)
         })
     }
+
+    /// Create a task to resend a failed message
+    pub fn resend(
+        &self,
+        reports: Vec<SendReport>,
+        message: String,
+        backup: bool,
+        cx: &App,
+    ) -> Task<Result<Vec<SendReport>, Error>> {
+        cx.background_spawn(async move {
+            let client = nostr_client();
+            let mut resend_reports = vec![];
+            let mut resend_tag = vec![];
+
+            for report in reports.into_iter() {
+                if let Some(output) = report.status {
+                    let id = output.id();
+                    let urls: Vec<&RelayUrl> = output.failed.keys().collect();
+
+                    if let Some(event) = client.database().event_by_id(id).await? {
+                        for url in urls.into_iter() {
+                            let relay = client.pool().relay(url).await?;
+                            let id = relay.send_event(&event).await?;
+                            let resent: Output<EventId> = Output {
+                                val: id,
+                                success: HashSet::from([url.to_owned()]),
+                                failed: HashMap::new(),
+                            };
+
+                            resend_reports.push(SendReport::new(report.receiver).status(resent));
+                        }
+
+                        if let Some(tags) = report.tags {
+                            resend_tag.extend(tags);
+                        }
+                    }
+                }
+            }
+
+            // Only send a backup message to current user if sent successfully to others
+            if backup && !resend_reports.is_empty() {
+                let signer = client.signer().await?;
+                let public_key = signer.get_public_key().await?;
+                let output = client
+                    .send_private_msg(public_key, message, resend_tag)
+                    .await?;
+
+                resend_reports.push(SendReport::new(public_key).status(output));
+            }
+
+            Ok(resend_reports)
+        })
+    }
+
+    /// Emits a new message signal to the current room
+    pub fn emit_message(&self, gift_wrap_id: EventId, event: Event, cx: &mut Context<Self>) {
+        cx.emit(RoomSignal::NewMessage((gift_wrap_id, Box::new(event))));
+    }
+
+    /// Emits a signal to refresh the current room's messages.
+    pub fn emit_refresh(&mut self, cx: &mut Context<Self>) {
+        cx.emit(RoomSignal::Refresh);
+    }
 }

crates/title_bar/src/platforms/mac.rs

@@ -3,4 +3,4 @@
 ///
 /// Magic number: There is one extra pixel of padding on the left side due to
 /// the 1px border around the window on macOS apps.
-pub const TRAFFIC_LIGHT_PADDING: f32 = 71.;
+pub const TRAFFIC_LIGHT_PADDING: f32 = 80.;

crates/ui/src/button.rs

@@ -10,11 +10,6 @@ use crate::indicator::Indicator;
 use crate::tooltip::Tooltip;
 use crate::{h_flex, Disableable, Icon, Selectable, Sizable, Size, StyledExt};
 
-pub enum ButtonRounded {
-    Normal,
-    Full,
-}
-
 #[derive(Clone, Copy, PartialEq, Eq)]
 pub struct ButtonCustomVariant {
     color: Hsla,
@@ -130,7 +125,7 @@ pub struct Button {
     children: Vec<AnyElement>,
 
     variant: ButtonVariant,
-    rounded: ButtonRounded,
+    rounded: bool,
     size: Size,
 
     disabled: bool,
@@ -163,7 +158,7 @@ impl Button {
             disabled: false,
             selected: false,
             variant: ButtonVariant::default(),
-            rounded: ButtonRounded::Normal,
+            rounded: false,
             size: Size::Medium,
             tooltip: None,
             on_click: None,
@@ -177,9 +172,9 @@ impl Button {
         }
     }
 
-    /// Set the border radius of the Button.
+    /// Make the button rounded.
-    pub fn rounded(mut self, rounded: impl Into<ButtonRounded>) -> Self {
+    pub fn rounded(mut self) -> Self {
-        self.rounded = rounded.into();
+        self.rounded = true;
         self
     }
 
@@ -315,8 +310,8 @@ impl RenderOnce for Button {
             .cursor_default()
             .overflow_hidden()
             .map(|this| match self.rounded {
-                ButtonRounded::Normal => this.rounded(cx.theme().radius),
+                false => this.rounded(cx.theme().radius),
-                ButtonRounded::Full => this.rounded_full(),
+                true => this.rounded_full(),
             })
             .map(|this| {
                 if self.label.is_none() && self.children.is_empty() {

crates/ui/src/dock_area/tab_panel.rs

@@ -412,16 +412,15 @@ impl TabPanel {
         let is_zoomed = self.is_zoomed && state.zoomable;
         let view = cx.entity().clone();
         let build_popup_menu = move |this, cx: &App| view.read(cx).popup_menu(this, cx);
+        let toolbar = self.toolbar_buttons(window, cx);
+        let has_toolbar = !toolbar.is_empty();
 
         h_flex()
+            .p_0p5()
             .gap_1()
             .occlude()
-            .items_center()
+            .rounded_full()
-            .children(
+            .children(toolbar.into_iter().map(|btn| btn.small().ghost().rounded()))
-                self.toolbar_buttons(window, cx)
-                    .into_iter()
-                    .map(|btn| btn.small().ghost()),
-            )
             .when(self.is_zoomed, |this| {
                 this.child(
                     Button::new("zoom")
@@ -434,11 +433,16 @@ impl TabPanel {
                         })),
                 )
             })
+            .when(has_toolbar, |this| {
+                this.bg(cx.theme().surface_background)
+                    .child(div().flex_shrink_0().h_4().w_px().bg(cx.theme().border))
+            })
             .child(
                 Button::new("menu")
                     .icon(IconName::Ellipsis)
                     .small()
                     .ghost()
+                    .rounded()
                     .popup_menu({
                         let zoomable = state.zoomable;
                         let closable = state.closable;
@@ -647,7 +651,7 @@ impl TabPanel {
             .child(
                 div()
                     .size_full()
-                    .rounded_lg()
+                    .rounded_xl()
                     .shadow_sm()
                     .when(cx.theme().mode.is_dark(), |this| this.shadow_lg())
                     .bg(cx.theme().panel_background)
@@ -667,7 +671,7 @@ impl TabPanel {
                             .p_1()
                             .child(
                                 div()
-                                    .rounded_lg()
+                                    .rounded_xl()
                                     .border_1()
                                     .border_color(cx.theme().element_disabled)
                                     .bg(cx.theme().drop_target_background)

crates/ui/src/icon.rs

@@ -52,6 +52,7 @@ pub enum IconName {
     Signal,
     Search,
     Settings,
+    Server,
     SortAscending,
     SortDescending,
     Sun,
@@ -112,6 +113,7 @@ impl IconName {
             Self::Signal => "icons/signal.svg",
             Self::Search => "icons/search.svg",
             Self::Settings => "icons/settings.svg",
+            Self::Server => "icons/server.svg",
             Self::SortAscending => "icons/sort-ascending.svg",
             Self::SortDescending => "icons/sort-descending.svg",
             Self::Sun => "icons/sun.svg",

crates/ui/src/resizable/panel.rs

@@ -405,13 +405,14 @@ impl Render for ResizablePanel {
             return div();
         }
 
-        let view = cx.entity().clone();
         let total_size = self
             .group
             .as_ref()
             .and_then(|group| group.upgrade())
             .map(|group| group.read(cx).total_size());
 
+        let view = cx.entity();
+
         div()
             .flex()
             .flex_grow()

locales/app.yml

@@ -49,6 +49,10 @@ common:
     en: "Relay URL is not valid."
   recommended:
     en: "Recommended:"
+  resend:
+    en: "Resend"
+  seen_on:
+    en: "Seen on"
 
 auto_update:
   updating:
@@ -58,9 +62,11 @@ auto_update:
 
 user:
   dark_mode:
-    en: "Dark Mode"
+    en: "Dark mode"
   settings:
     en: "Settings"
+  reload_metadata:
+    en: "Reload metadata"
   sign_out:
     en: "Sign out"
 
@@ -395,6 +401,14 @@ sidebar:
     en: "Incoming new conversations"
   trusted_contacts_tooltip:
     en: "Only show rooms from trusted contacts"
+  no_requests:
+    en: "No message requests"
+  no_requests_label:
+    en: "New message requests from people you don't know will appear here."
+  no_conversations:
+    en: "No conversations"
+  no_conversations_label:
+    en: "Start a conversation with someone to get started."
 
 loading:
   label: