Compare commits

..

No commits in common. "c11026c5be5d7447110ea8dcdc533d40b5c5f39c" and "983ceb2076a74657695bb51e88dbf849eaef055c" have entirely different histories.

5 changed files with 52 additions and 75 deletions

View file

@ -111,18 +111,22 @@ fn element_from_issue(issue: &forgejo_api::structs::Issue) -> anyhow::Result<cra
let ty_labels: Vec<_> = labels let ty_labels: Vec<_> = labels
.iter() .iter()
.filter_map(|l| l.name.as_deref()) .filter_map(|l| l.name.as_deref())
.filter_map(|l| l.strip_prefix("Type/")) .filter(|l| l.starts_with("Type/"))
.collect(); .collect();
let ty = match &ty_labels[..] { if ty_labels.len() == 0 {
[ty] => ty.to_string(), anyhow::bail!("Issue #{issue_number} has no type label!");
[] => { }
anyhow::bail!("Issue #{issue_number} has no type label!"); if ty_labels.len() > 1 {
} anyhow::bail!("Issue #{issue_number} has more than one type label!");
[..] => { }
anyhow::bail!("Issue #{issue_number} has more than one type label!");
} let ty = ty_labels
}; .first()
.unwrap()
.strip_prefix("Type/")
.unwrap()
.to_owned();
let has_completed_label = labels let has_completed_label = labels
.iter() .iter()

View file

@ -28,7 +28,7 @@ pub async fn make_bot_comment(
.await?; .await?;
Ok(BotCommentInfo { Ok(BotCommentInfo {
id: res.id.context("Missing id for the bot comment")?, id: res.id.unwrap(),
body: initial_message.to_owned(), body: initial_message.to_owned(),
}) })
} }
@ -55,16 +55,12 @@ pub async fn find_bot_comment(
let maybe_bot_comment = comments let maybe_bot_comment = comments
.iter() .iter()
.rev() .rev()
.find(|comment| comment.user.as_ref().and_then(|u| u.id) == Some(-2)); .find(|comment| comment.user.as_ref().unwrap().id == Some(-2));
Ok(maybe_bot_comment Ok(maybe_bot_comment.map(|c| BotCommentInfo {
.map(|c| -> anyhow::Result<_> { body: c.body.clone().unwrap_or("".to_owned()),
Ok(BotCommentInfo { id: c.id.unwrap(),
body: c.body.clone().unwrap_or("".to_owned()), }))
id: c.id.context("Missing id for the bot comment")?,
})
})
.transpose()?)
} }
/// Find existing bot comment or create a new one. /// Find existing bot comment or create a new one.
@ -159,8 +155,7 @@ pub async fn remove_stale_label(ctx: &crate::Context, issue_number: u64) -> anyh
.iter() .iter()
.filter(|l| l.name.as_deref() == Some("Stale")) .filter(|l| l.name.as_deref() == Some("Stale"))
.next() .next()
.map(|l| l.id.ok_or(anyhow::anyhow!("`Stale` label has no ID"))) .map(|l| l.id.unwrap());
.transpose()?;
if let Some(stale_label_id) = stale_label_id { if let Some(stale_label_id) = stale_label_id {
log::info!("Removing `Stale` label from issue #{issue_number}..."); log::info!("Removing `Stale` label from issue #{issue_number}...");

View file

@ -60,21 +60,14 @@ async fn run() -> anyhow::Result<()> {
"{}/{}", "{}/{}",
meta.issue.repository.owner, meta.issue.repository.name meta.issue.repository.owner, meta.issue.repository.name
)) ))
.with_context(|| { .unwrap();
format!("failed building repository URL from GITHUB_SERVER_URL: {server_url}")
})?;
let repo_auth_url = token let repo_auth_url = token.as_ref().map(|token| {
.as_ref() let mut repo_auth_url = repo_url.clone();
.map(|token| -> Result<_, ()> { repo_auth_url.set_username("forgejo-actions").unwrap();
let mut repo_auth_url = repo_url.clone(); repo_auth_url.set_password(Some(&token)).unwrap();
repo_auth_url.set_username("forgejo-actions")?; repo_auth_url
repo_auth_url.set_password(Some(&token))?; });
Ok(repo_auth_url)
})
.transpose()
.map_err(|_e| anyhow::anyhow!("Repo URL does not have correct format"))
.context("Failed adding auth info to repo URL")?;
let auth = if let Some(token) = token.as_ref() { let auth = if let Some(token) = token.as_ref() {
forgejo_api::Auth::Token(token) forgejo_api::Auth::Token(token)
@ -145,7 +138,7 @@ async fn run() -> anyhow::Result<()> {
} }
'issues: for issue in tree.iter_issues() { 'issues: for issue in tree.iter_issues() {
let subtree = tree.subtree_for_issue(issue).expect("issue from tree not found in tree"); let subtree = tree.subtree_for_issue(issue).unwrap();
let hash = subtree.stable_hash(); let hash = subtree.stable_hash();
let (bot_comment, _is_new) = issue::find_or_make_bot_comment(&ctx, issue) let (bot_comment, _is_new) = issue::find_or_make_bot_comment(&ctx, issue)

View file

@ -16,19 +16,9 @@ impl SuccessExt for Command {
} }
pub struct RenderedTree { pub struct RenderedTree {
pub repo_dir: std::path::PathBuf, repo_dir: std::path::PathBuf,
pub dot_file_name: std::ffi::OsString, dot_file: std::path::PathBuf,
pub svg_file_name: std::ffi::OsString, svg_file: std::path::PathBuf,
}
impl RenderedTree {
pub fn dot_file(&self) -> std::path::PathBuf {
self.repo_dir.join(&self.dot_file_name)
}
pub fn svg_file(&self) -> std::path::PathBuf {
self.repo_dir.join(&self.svg_file_name)
}
} }
pub async fn render( pub async fn render(
@ -37,33 +27,33 @@ pub async fn render(
) -> anyhow::Result<RenderedTree> { ) -> anyhow::Result<RenderedTree> {
let repo_dir = std::path::PathBuf::from("render-git"); let repo_dir = std::path::PathBuf::from("render-git");
let info = RenderedTree { if repo_dir.is_dir() {
repo_dir, log::info!("Found old {repo_dir:?} repository, removing...");
dot_file_name: "techtree.dot".into(), std::fs::remove_dir_all(&repo_dir).context("Failed to remove stale render repository")?;
svg_file_name: "techtree.svg".into(),
};
if info.repo_dir.is_dir() {
log::info!("Found old {:?} repository, removing...", info.repo_dir);
std::fs::remove_dir_all(&info.repo_dir)
.context("Failed to remove stale render repository")?;
} }
std::fs::create_dir(&info.repo_dir).context("Failed creating directory for rendered graph")?; std::fs::create_dir(&repo_dir).context("Failed creating directory for rendered graph")?;
let dot_file = repo_dir.join("techtree.dot");
let svg_file = repo_dir.join("techtree.svg");
let dot_source = tree.to_dot(); let dot_source = tree.to_dot();
std::fs::write(&info.dot_file(), dot_source.as_bytes()) std::fs::write(&dot_file, dot_source.as_bytes())
.context("Failed to write `dot` source file")?; .context("Failed to write `dot` source file")?;
Command::new("dot") Command::new("dot")
.args(["-T", "svg"]) .args(["-T", "svg"])
.arg("-o") .arg("-o")
.arg(&info.svg_file()) .arg(&svg_file)
.arg(&info.dot_file()) .arg(&dot_file)
.success() .success()
.context("Failed to generate svg graph from dot source")?; .context("Failed to generate svg graph from dot source")?;
Ok(info) Ok(RenderedTree {
repo_dir,
dot_file,
svg_file,
})
} }
pub async fn publish(ctx: &crate::Context, rendered: &RenderedTree) -> anyhow::Result<()> { pub async fn publish(ctx: &crate::Context, rendered: &RenderedTree) -> anyhow::Result<()> {
@ -94,8 +84,8 @@ pub async fn publish(ctx: &crate::Context, rendered: &RenderedTree) -> anyhow::R
.arg("-C") .arg("-C")
.arg(&rendered.repo_dir) .arg(&rendered.repo_dir)
.arg("add") .arg("add")
.arg(&rendered.dot_file_name) .arg(rendered.dot_file.strip_prefix(&rendered.repo_dir).unwrap())
.arg(&rendered.svg_file_name) .arg(rendered.svg_file.strip_prefix(&rendered.repo_dir).unwrap())
.success() .success()
.context("Failed to add generated graph files to git index")?; .context("Failed to add generated graph files to git index")?;

View file

@ -165,12 +165,8 @@ impl Tree {
} }
pub fn add_dependency_by_issue_number(&mut self, dependant: u64, dependency: u64) { pub fn add_dependency_by_issue_number(&mut self, dependant: u64, dependency: u64) {
let a = self let a = self.find_element_by_issue_number(dependant).unwrap();
.find_element_by_issue_number(dependant) let b = self.find_element_by_issue_number(dependency).unwrap();
.expect("dependant element does not exist");
let b = self
.find_element_by_issue_number(dependency)
.expect("dependency element does not exist");
self.graph.add_edge(a, b, ()); self.graph.add_edge(a, b, ());
} }
@ -426,8 +422,7 @@ impl<'a> Subtree<'a> {
.collect(); .collect();
edges.sort(); edges.sort();
let json_data = serde_json::ser::to_string(&(nodes, edges, HASH_EPOCH)) let json_data = serde_json::ser::to_string(&(nodes, edges, HASH_EPOCH)).unwrap();
.expect("serialization for a stable hash failed");
sha256::digest(json_data) sha256::digest(json_data)
} }
} }