ryanmwangi
/
mostr
forked from janek/mostr
1
0
Fork 0
Code Pull Requests Activity

refactor: reformat

This commit is contained in:
xeruf 2024-07-18 12:09:18 +03:00
parent b6d85c018d
commit 870a43112a
1 changed files with 27 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/main.rs
View File

@ -72,15 +72,24 @@ async fn main() {
repl().await; repl().await;
println!("Finding existing events"); println!("Finding existing events");
let res = CLIENT.get_events_of(vec![filter], Option::from(timeout)).map_ok(|res| let res = CLIENT
.get_events_of(vec![filter], Option::from(timeout))
.map_ok(|res| {
for event in res { for event in res {
println!("Found {} {:?}", event.content, event.tags) println!("Found {} {:?}", event.content, event.tags)
}).await; }
})
.await;
let mut notifications = CLIENT.notifications(); let mut notifications = CLIENT.notifications();
println!("Listening for events..."); println!("Listening for events...");
while let Ok(notification) = notifications.recv().await { while let Ok(notification) = notifications.recv().await {
if let RelayPoolNotification::Event { subscription_id, event, .. } = notification { if let RelayPoolNotification::Event {
subscription_id,
event,
..
} = notification
{
let kind = event.kind; let kind = event.kind;
let content = &event.content; let content = &event.content;
println!("{kind}: {content}"); println!("{kind}: {content}");
@ -90,12 +99,16 @@ async fn main() {
} }
fn make_event(text: &str, tags: &[Tag]) -> Event { fn make_event(text: &str, tags: &[Tag]) -> Event {
EventBuilder::new(*TASK_KIND, text, tags.to_vec()).to_event(&MY_KEYS).unwrap() EventBuilder::new(*TASK_KIND, text, tags.to_vec())
.to_event(&MY_KEYS)
.unwrap()
} }
async fn send(text: &str, tags: &[Tag]) -> (Event, Result<EventId, Error>) { async fn send(text: &str, tags: &[Tag]) -> (Event, Result<EventId, Error>) {
println!("Sending {}", text); println!("Sending {}", text);
let event = EventBuilder::new(*TASK_KIND, text, tags.to_vec()).to_event(&MY_KEYS).unwrap(); let event = EventBuilder::new(*TASK_KIND, text, tags.to_vec())
.to_event(&MY_KEYS)
.unwrap();
let result = CLIENT.send_event(event.clone()).await; let result = CLIENT.send_event(event.clone()).await;
return (event, result); return (event, result);
} }
@ -185,7 +198,13 @@ async fn repl() {
_ => {} _ => {}
} }
} }
CLIENT.batch_event(tasks.into_values().map(|t| t.event).collect(), RelaySendOptions::new().skip_send_confirmation(true)).await.unwrap(); CLIENT
.batch_event(
tasks.into_values().map(|t| t.event).collect(),
RelaySendOptions::new().skip_send_confirmation(true),
)
.await
.unwrap();
} }
struct Task { struct Task {