use std::path::{Path, PathBuf};
use crate::errors::{CoreError, CoreResult};
pub fn collect_proposal_artifacts(change_id: &str, ito_root: &Path) -> CoreResult<String> {
let change_dir = ito_common::paths::change_dir(ito_root, change_id);
if !change_dir.is_dir() {
return Err(CoreError::not_found(format!(
"Change '{change_id}' not found"
)));
}
let mut sections = Vec::new();
for relative_path in artifact_paths(&change_dir)? {
let absolute_path = change_dir.join(&relative_path);
let content = ito_common::io::read_to_string(&absolute_path).map_err(|e| {
CoreError::io(
format!("reading proposal artifact {}", absolute_path.display()),
std::io::Error::other(e),
)
})?;
sections.push(render_section(&relative_path, &content));
}
Ok(sections.join("\n\n"))
}
fn artifact_paths(change_dir: &Path) -> CoreResult<Vec<PathBuf>> {
let mut paths = Vec::new();
for file_name in ["proposal.md", "tasks.md"] {
let path = change_dir.join(file_name);
if path.is_file() {
paths.push(PathBuf::from(file_name));
}
}
let specs_dir = change_dir.join("specs");
if specs_dir.is_dir() {
let mut spec_dirs = Vec::new();
let entries = std::fs::read_dir(&specs_dir)
.map_err(|e| CoreError::io(format!("reading {}", specs_dir.display()), e))?;
for entry in entries {
let entry =
entry.map_err(|e| CoreError::io(format!("reading {}", specs_dir.display()), e))?;
if entry.path().is_dir() {
spec_dirs.push(entry);
}
}
spec_dirs.sort_by_key(|entry| entry.file_name());
for entry in spec_dirs {
let relative_path = PathBuf::from("specs")
.join(entry.file_name())
.join("spec.md");
let absolute_path = change_dir.join(&relative_path);
if absolute_path.is_file() {
paths.push(relative_path);
}
}
}
Ok(paths)
}
fn render_section(relative_path: &Path, content: &str) -> String {
format!(
"---\n# {}\n\n{}",
relative_path.to_string_lossy(),
content.trim_end()
)
}
#[cfg(test)]
mod tests {
use super::*;
use tempfile::TempDir;
#[test]
fn collect_proposal_artifacts_orders_sections_and_preserves_content() {
let temp_dir = TempDir::new().unwrap();
let ito_root = temp_dir.path().join(".ito");
let change_dir = ito_root.join("changes/001-29_test-change");
std::fs::create_dir_all(change_dir.join("specs/auth")).unwrap();
std::fs::create_dir_all(change_dir.join("specs/zebra")).unwrap();
std::fs::write(change_dir.join("proposal.md"), "# Proposal\nbody\n").unwrap();
std::fs::write(change_dir.join("tasks.md"), "# Tasks\n- [ ] verify\n").unwrap();
std::fs::write(change_dir.join("specs/auth/spec.md"), "## ADDED\nauth\n").unwrap();
std::fs::write(
change_dir.join("specs/zebra/spec.md"),
"## MODIFIED\nzebra\n",
)
.unwrap();
let bundled = collect_proposal_artifacts("001-29_test-change", &ito_root).unwrap();
let expected = [
"---\n# proposal.md\n\n# Proposal\nbody",
"---\n# tasks.md\n\n# Tasks\n- [ ] verify",
"---\n# specs/auth/spec.md\n\n## ADDED\nauth",
"---\n# specs/zebra/spec.md\n\n## MODIFIED\nzebra",
]
.join("\n\n");
assert_eq!(bundled, expected);
}
#[test]
fn collect_proposal_artifacts_skips_missing_optional_files() {
let temp_dir = TempDir::new().unwrap();
let ito_root = temp_dir.path().join(".ito");
let change_dir = ito_root.join("changes/001-29_test-change");
std::fs::create_dir_all(&change_dir).unwrap();
std::fs::write(change_dir.join("proposal.md"), "only proposal\n").unwrap();
let bundled = collect_proposal_artifacts("001-29_test-change", &ito_root).unwrap();
assert_eq!(bundled, "---\n# proposal.md\n\nonly proposal");
}
#[test]
fn collect_proposal_artifacts_errors_for_unknown_change() {
let temp_dir = TempDir::new().unwrap();
let ito_root = temp_dir.path().join(".ito");
std::fs::create_dir_all(ito_root.join("changes")).unwrap();
let error = collect_proposal_artifacts("001-29_missing", &ito_root).unwrap_err();
assert_eq!(error.to_string(), "Change '001-29_missing' not found");
}
}