Skip to content
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
98 changes: 56 additions & 42 deletions src/commands/agent.rs
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,7 @@ use crate::{
project::get_project,
service::get_or_prompt_service,
},
errors::RailwayError,
interact_or,
util::progress::create_spinner,
};
Expand Down Expand Up @@ -144,12 +145,24 @@ pub async fn command(args: Args) -> Result<()> {
let history = match args.thread_id.as_deref() {
Some(tid) => {
let messages_url = get_thread_messages_url(&configs, tid);
get_thread_messages(&chat_client, &messages_url, Some(10))
.await
.unwrap_or_else(|e| {
match get_thread_messages(&chat_client, &messages_url, Some(10)).await {
Ok(messages) => messages,
Err(e) => {
if let Some(railway_err) = e.downcast_ref::<RailwayError>()
&& matches!(
railway_err,
RailwayError::Unauthorized
| RailwayError::UnauthorizedToken(_)
| RailwayError::UnauthorizedLogin
| RailwayError::InvalidRailwayToken(_)
)
{
return Err(e);
}
eprintln!("{}", format!("Could not load thread history: {e}").dimmed());
Vec::new()
})
}
}
}
None => Vec::new(),
};
Expand All @@ -169,6 +182,17 @@ pub async fn command(args: Args) -> Result<()> {
}
}

fn render_text_block(text: &str, is_assistant: bool, skin: &termimad::MadSkin) {
if text.trim().is_empty() {
return;
}
if is_assistant {
skin.print_text(text);
} else {
println!("{}", text);
}
}

fn render_history(messages: &[ChatMessage], thread_id: Option<&str>) {
let banner = match thread_id {
Some(id) => format!("── resuming thread {id} ──"),
Expand All @@ -187,47 +211,37 @@ fn render_history(messages: &[ChatMessage], thread_id: Option<&str>) {
};
println!("{}", role_label);

let text_parts: Vec<&str> = message
.parts
.iter()
.filter_map(|part| match part {
ChatMessagePart::Text { content } => Some(content.as_str()),
_ => None,
})
.collect();

let text = if text_parts.is_empty() {
message.content.clone()
if message.parts.is_empty() {
render_text_block(&message.content, is_assistant, &skin);
} else {
text_parts.join("")
};
if !text.trim().is_empty() {
if is_assistant {
skin.print_text(&text);
} else {
println!("{}", text);
}
}

for part in &message.parts {
match part {
ChatMessagePart::Tool {
tool_name,
is_error,
..
} => {
let label = if *is_error {
format!("[tool failed: {tool_name}]")
} else {
format!("[used tool: {tool_name}]")
};
println!("{}", label.dimmed().italic());
}
ChatMessagePart::Attachment { name, .. } => {
println!("{}", format!("[attachment: {name}]").dimmed().italic());
let mut text_buf = String::new();
for part in &message.parts {
match part {
ChatMessagePart::Text { content } => {
text_buf.push_str(content);
}
ChatMessagePart::Tool {
tool_name,
is_error,
..
} => {
render_text_block(&text_buf, is_assistant, &skin);
text_buf.clear();
let label = if *is_error {
format!("[tool failed: {tool_name}]")
} else {
format!("[used tool: {tool_name}]")
};
println!("{}", label.dimmed().italic());
}
ChatMessagePart::Attachment { name, .. } => {
render_text_block(&text_buf, is_assistant, &skin);
text_buf.clear();
println!("{}", format!("[attachment: {name}]").dimmed().italic());
}
}
ChatMessagePart::Text { .. } => {}
}
render_text_block(&text_buf, is_assistant, &skin);
}

println!();
Expand Down
Loading