@@ -164,11 +164,7 @@
match args.command {
IssueCommand::List { repo, state, limit } => list(repo.as_deref(), &state, limit).await,
IssueCommand::View { number, repo } => view(repo.as_deref(), number).await,
IssueCommand::Create {
repo,
title,
body,
} => create(repo.as_deref(), &title, &body).await,
IssueCommand::Create { repo, title, body } => create(repo.as_deref(), &title, &body).await,
IssueCommand::Close { number, repo } => close_issue(repo.as_deref(), number).await,
IssueCommand::Reopen { number, repo } => reopen_issue(repo.as_deref(), number).await,
IssueCommand::Edit {
@@ -177,11 +173,34 @@
title,
body,
} => edit_issue(repo.as_deref(), number, title.as_deref(), body.as_deref()).await,
IssueCommand::Comment { number, body, repo } => {
add_comment(repo.as_deref(), number, &body).await
IssueCommand::Comment { number, body, repo } => add_comment(repo.as_deref(), number, &body).await,
}
IssueCommand::Comments { number, repo } => list_comments(repo.as_deref(), number).await,
IssueCommand::Milestones { repo } => list_milestones(repo.as_deref()).await,
IssueCommand::CreateMilestone {
title,
description,
due_date,
repo,
} => {
create_milestone(
repo.as_deref(),
&title,
IssueCommand::CreateMilestone { title, description, due_date, repo } => create_milestone(repo.as_deref(), &title, description.as_deref(), due_date.as_deref()).await,
IssueCommand::Assign { number, user_id, repo } => assign(repo.as_deref(), number, &user_id).await,
IssueCommand::Unassign { number, user_id, repo } => unassign(repo.as_deref(), number, &user_id).await,
description.as_deref(),
due_date.as_deref(),
)
.await
}
IssueCommand::Assign {
number,
user_id,
repo,
} => assign(repo.as_deref(), number, &user_id).await,
IssueCommand::Unassign {
number,
user_id,
repo,
} => unassign(repo.as_deref(), number, &user_id).await,
}
}
@@ -389,11 +408,18 @@
Ok(())
}
async fn add_comment(
repo: Option<&str>,
number: u32,
body: &str,
) -> Result<(), Box<dyn std::error::Error>> {
async fn add_comment(repo: Option<&str>, number: u32, body: &str) -> Result<(), Box<dyn std::error::Error>> {
let client = Client::from_config()?;
let (org, name) = config::resolve_repo(repo)?;
let _resp: serde_json::Value = client
.post(&format!("/{org}/{name}/issues/{number}/comments"), &serde_json::json!({"body": body}))
.post(
&format!("/{org}/{name}/issues/{number}/comments"),
&serde_json::json!({"body": body}),
)
.await?;
output::success(&format!("Added comment to issue #{number}"));
Ok(())
@@ -419,8 +445,15 @@
}
for comment in &comments {
let author = comment
.pointer("/author/email")
.and_then(|v| v.as_str())
let author = comment.pointer("/author/email").and_then(|v| v.as_str()).unwrap_or("unknown");
let time = comment.get("inserted_at").and_then(|v| v.as_str()).map(output::format_time).unwrap_or_default();
.unwrap_or("unknown");
let time = comment
.get("inserted_at")
.and_then(|v| v.as_str())
.map(output::format_time)
.unwrap_or_default();
let body = comment.get("body").and_then(|v| v.as_str()).unwrap_or("");
println!("\n {} — {}", author, time);
println!(" {body}");
@@ -432,46 +465,97 @@
let client = Client::from_config()?;
let (org, name) = config::resolve_repo(repo)?;
let resp: serde_json::Value = client.get(&format!("/{org}/{name}/milestones")).await?;
let milestones: Vec<serde_json::Value> = resp
let milestones: Vec<serde_json::Value> = resp.get("milestones").and_then(|v| serde_json::from_value(v.clone()).ok()).unwrap_or_default();
.get("milestones")
.and_then(|v| serde_json::from_value(v.clone()).ok())
.unwrap_or_default();
output::header(&format!("Milestones ({org}/{name})"));
let rows: Vec<Vec<String>> = milestones.iter().map(|m| {
vec![
m.get("title").and_then(|v| v.as_str()).unwrap_or("?").to_string(),
m.get("state").and_then(|v| v.as_str()).map(output::colorize_status).unwrap_or_default(),
format!("{}/{}", m.get("closed_issues").and_then(|v| v.as_u64()).unwrap_or(0), m.get("open_issues").and_then(|v| v.as_u64()).unwrap_or(0) + m.get("closed_issues").and_then(|v| v.as_u64()).unwrap_or(0)),
format!("{}%", m.get("progress_percent").and_then(|v| v.as_f64()).unwrap_or(0.0) as u32),
m.get("due_date").and_then(|v| v.as_str()).unwrap_or("none").to_string(),
]
}).collect();
let rows: Vec<Vec<String>> = milestones
.iter()
.map(|m| {
vec![
m.get("title")
.and_then(|v| v.as_str())
.unwrap_or("?")
.to_string(),
m.get("state")
.and_then(|v| v.as_str())
.map(output::colorize_status)
.unwrap_or_default(),
format!(
"{}/{}",
m.get("closed_issues").and_then(|v| v.as_u64()).unwrap_or(0),
m.get("open_issues").and_then(|v| v.as_u64()).unwrap_or(0)
+ m.get("closed_issues").and_then(|v| v.as_u64()).unwrap_or(0)
),
format!(
"{}%",
m.get("progress_percent")
.and_then(|v| v.as_f64())
.unwrap_or(0.0) as u32
),
m.get("due_date")
.and_then(|v| v.as_str())
.unwrap_or("none")
.to_string(),
]
})
.collect();
output::print_table(&["TITLE", "STATE", "PROGRESS", "%", "DUE"], &rows);
Ok(())
}
async fn create_milestone(
repo: Option<&str>,
title: &str,
description: Option<&str>,
due_date: Option<&str>,
) -> Result<(), Box<dyn std::error::Error>> {
async fn create_milestone(repo: Option<&str>, title: &str, description: Option<&str>, due_date: Option<&str>) -> Result<(), Box<dyn std::error::Error>> {
let client = Client::from_config()?;
let (org, name) = config::resolve_repo(repo)?;
let mut payload = serde_json::json!({"title": title});
if let Some(d) = description {
payload["description"] = serde_json::json!(d);
}
if let Some(dd) = due_date {
if let Some(d) = description { payload["description"] = serde_json::json!(d); }
if let Some(dd) = due_date { payload["due_date"] = serde_json::json!(dd); }
let _resp: serde_json::Value = client.post(&format!("/{org}/{name}/milestones"), &payload).await?;
payload["due_date"] = serde_json::json!(dd);
}
let _resp: serde_json::Value = client
.post(&format!("/{org}/{name}/milestones"), &payload)
.await?;
output::success(&format!("Created milestone '{title}'"));
Ok(())
}
async fn assign(
async fn assign(repo: Option<&str>, number: u32, user_id: &str) -> Result<(), Box<dyn std::error::Error>> {
repo: Option<&str>,
number: u32,
user_id: &str,
) -> Result<(), Box<dyn std::error::Error>> {
let client = Client::from_config()?;
let (org, name) = config::resolve_repo(repo)?;
let _resp: serde_json::Value = client
.post(
&format!("/{org}/{name}/issues/{number}/assignees"),
&serde_json::json!({"user_id": user_id}),
)
.post(&format!("/{org}/{name}/issues/{number}/assignees"), &serde_json::json!({"user_id": user_id}))
.await?;
output::success(&format!("Assigned user to issue #{number}"));
Ok(())
}
async fn unassign(repo: Option<&str>, number: u32, user_id: &str) -> Result<(), Box<dyn std::error::Error>> {
async fn unassign(
repo: Option<&str>,
number: u32,
user_id: &str,
) -> Result<(), Box<dyn std::error::Error>> {
let client = Client::from_config()?;
let (org, name) = config::resolve_repo(repo)?;
client
.delete_empty(&format!(
client.delete_empty(&format!("/{org}/{name}/issues/{number}/assignees/{user_id}")).await?;
"/{org}/{name}/issues/{number}/assignees/{user_id}"
))
.await?;
output::success(&format!("Unassigned user from issue #{number}"));
Ok(())
}