reya/coop
1
0
Fork 0
Code Issues Pull Requests Releases Activity

chore: fix crash on update relays

Browse Source
This commit is contained in:
reya
2025-02-13 20:44:50 +07:00
parent b4f9d5b3c4
commit ce9193c187
2 changed files with 34 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
crates/app/src/views/app.rs
View File

@@ -188,7 +188,7 @@ impl AppView {
this.keyboard(false)
.closable(false)
.width(px(420.))
.title("Your Messaging Relays is not configured")
.title("Your Messaging Relays are not configured")
.child(relays.clone())
.footer(
div()

64
crates/app/src/views/relays.rs
View File

@@ -66,41 +66,43 @@ impl Relays {
self.set_loading(true, cx);
cx.spawn(|this, mut cx| async move {
let (tx, rx) = oneshot::channel();
let client = get_client();
let (tx, rx) = oneshot::channel();
cx.background_spawn(async move {
let client = get_client();
let signer = client.signer().await.unwrap();
let public_key = signer.get_public_key().await.unwrap();
cx.background_spawn(async move {
let signer = client.signer().await.expect("Signer is required");
let public_key = signer
.get_public_key()
.await
.expect("Cannot get public key");
let tags: Vec<Tag> = relays
.into_iter()
.map(|relay| Tag::custom(TagKind::Relay, vec![relay.to_string()]))
.collect();
let tags: Vec<Tag> = relays
.into_iter()
.map(|relay| Tag::custom(TagKind::Relay, vec![relay.to_string()]))
.collect();
let event = EventBuilder::new(Kind::InboxRelays, "")
.tags(tags)
.build(public_key)
.sign(&signer)
.await
.unwrap();
if let Ok(output) = client.send_event(&event).await {
_ = tx.send(output.val);
};
})
.detach();
if rx.await.is_ok() {
cx.update_window(window_handle, |_, window, cx| {
window.close_modal(cx);
this.update(cx, |this, cx| {
this.set_loading(false, cx);
})
.unwrap();
})
let event = EventBuilder::new(Kind::InboxRelays, "")
.tags(tags)
.build(public_key)
.sign(&signer)
.await
.unwrap();
if let Ok(output) = client.send_event(&event).await {
_ = tx.send(output.val);
};
})
.detach();
cx.spawn(|this, mut cx| async move {
if rx.await.is_ok() {
_ = cx.update_window(window_handle, |_, window, cx| {
_ = this.update(cx, |this, cx| {
this.set_loading(false, cx);
});
window.close_modal(cx);
});
}
})
.detach();