forked from janek/mostr
1
0
Fork 0

feat: use dots for navigation

This commit is contained in:
xeruf 2024-07-18 15:19:12 +03:00
parent 76e1f87377
commit cfe815fe2e
1 changed files with 41 additions and 40 deletions

View File

@ -98,10 +98,10 @@ fn make_event(text: &str, tags: &[Tag]) -> Event {
.unwrap() .unwrap()
} }
type TaskMap = HashMap<EventId, Task>;
async fn repl() { async fn repl() {
let mut tasks: HashMap<EventId, Task> = HashMap::new(); let mut tasks: TaskMap = HashMap::new();
let add_task = let add_task = |tasks: &mut TaskMap, event: Event| tasks.insert(event.id, Task::new(event));
|tasks: &mut HashMap<EventId, Task>, event: Event| tasks.insert(event.id, Task::new(event));
for argument in args().skip(1) { for argument in args().skip(1) {
add_task( add_task(
&mut tasks, &mut tasks,
@ -109,8 +109,8 @@ async fn repl() {
); );
} }
let mut position: Option<EventId> = None;
let mut properties: Vec<String> = vec!["id".into(), "name".into(), "state".into()]; let mut properties: Vec<String> = vec!["id".into(), "name".into(), "state".into()];
let mut position: Option<EventId> = None;
loop { loop {
let mut prompt = String::with_capacity(64); let mut prompt = String::with_capacity(64);
let mut pos = position; let mut pos = position;
@ -127,11 +127,36 @@ async fn repl() {
if input.trim() == "exit" { if input.trim() == "exit" {
break; break;
} }
if input.starts_with(".") { let dots = input.chars().take_while(|c| c == &'.').count();
match input[1..2].parse::<usize>() { match dots {
0 => {
let mut tags: Vec<Tag> = Vec::new();
position.inspect(|p| tags.push(Tag::event(*p)));
let event = match input.split_once(": ") {
None => make_event(&input, &tags),
Some(s) => {
tags.append(
&mut s.1.split(" ")
.map(|t| Tag::Hashtag(t.to_string()))
.collect());
make_event(s.0, &tags)
}
};
for tag in event.tags.iter() {
match tag {
Tag::Event { event_id, .. } => {
tasks
.get_mut(event_id)
.map(|t| t.children.push(event.clone()));
}
_ => {}
}
}
add_task(&mut tasks, event);
}
1 => match input[1..2].parse::<usize>() {
Ok(index) => { Ok(index) => {
properties.insert(index, input[2..].to_string()); properties.insert(index, input[2..].to_string());
continue;
} }
Err(_) => { Err(_) => {
let prop = &input[1..]; let prop = &input[1..];
@ -145,37 +170,14 @@ async fn repl() {
} }
} }
} }
},
_ => {
for _ in 1..dots {
position = position
.and_then(|id| tasks.get(&id))
.and_then(|t| t.parent_id());
} }
} else { let _ = EventId::parse(&input[dots..]).map(|p| position = Some(p));
match input.split_once(": ") {
None => {
position = EventId::parse(input).ok().or(position
.and_then(|p| tasks.get(&p))
.and_then(|t| t.parent_id()));
}
Some(s) => {
let mut tags: Vec<Tag> =
s.1.split(" ")
.map(|t| Tag::Hashtag(t.to_string()))
.collect();
if let Some(pos) = position {
tags.push(Tag::event(pos));
}
let event = make_event(s.0, &tags);
for tag in event.tags.iter() {
match tag {
Tag::Event { event_id, .. } => {
tasks
.get_mut(event_id)
.unwrap()
.children
.push(event.clone());
}
_ => {}
}
}
add_task(&mut tasks, event);
}
} }
}; };
let events: Vec<&Event> = let events: Vec<&Event> =
@ -192,13 +194,12 @@ async fn repl() {
_ => {} _ => {}
} }
} }
CLIENT let _ = CLIENT
.batch_event( .batch_event(
tasks.into_values().map(|t| t.event).collect(), tasks.into_values().map(|t| t.event).collect(),
RelaySendOptions::new().skip_send_confirmation(true), RelaySendOptions::new().skip_send_confirmation(true),
) )
.await .await;
.unwrap();
} }
struct Task { struct Task {