pyrls 0.1.0

use std::{collections::BTreeMap, fs, path::Path};

use anyhow::{Context, Result};

use crate::{config::Config, conventional_commits::ConventionalCommit};

#[derive(Debug, Clone, PartialEq, Eq)]
pub struct PendingChangelog {
    pub sections: BTreeMap<String, Vec<String>>,
}

impl PendingChangelog {
    pub fn from_commits(config: &Config, commits: &[ConventionalCommit]) -> Self {
        let mut sections = BTreeMap::new();

        for commit in commits {
            if commit.breaking {
                sections
                    .entry("Breaking Changes".to_string())
                    .or_insert_with(Vec::new)
                    .push(commit.description.clone());
            }

            let Some(section) = config.section_for_commit_type(&commit.commit_type) else {
                continue;
            };

            sections
                .entry(section)
                .or_insert_with(Vec::new)
                .push(commit.description.clone());
        }

        Self { sections }
    }

    pub fn is_empty(&self) -> bool {
        self.sections.is_empty()
    }
}

pub fn next_release_heading(version: &str, date: &str) -> String {
    format!("## [{version}] - {date}")
}

pub fn render_release_notes(version: &str, date: &str, changelog: &PendingChangelog) -> String {
    let mut output = String::new();
    output.push_str(&next_release_heading(version, date));
    output.push('\n');

    for (section, entries) in &changelog.sections {
        output.push('\n');
        output.push_str(&format!("### {section}\n"));
        for entry in entries {
            output.push_str(&format!("- {entry}\n"));
        }
    }

    output.trim_end().to_string()
}

pub fn prepend_release_notes(path: &Path, release_notes: &str) -> Result<()> {
    let existing = match fs::read_to_string(path) {
        Ok(content) => content,
        Err(error) if error.kind() == std::io::ErrorKind::NotFound => String::new(),
        Err(error) => {
            return Err(error).with_context(|| format!("failed to read {}", path.display()));
        }
    };

    let updated = if existing.trim().is_empty() {
        format!("# Changelog\n\n{release_notes}\n")
    } else if let Some(header_end) = existing.find('\n') {
        let (head, tail) = existing.split_at(header_end + 1);
        format!("{head}\n{release_notes}\n\n{}", tail.trim_start())
    } else {
        format!("{existing}\n\n{release_notes}\n")
    };

    fs::write(path, updated).with_context(|| format!("failed to write {}", path.display()))?;
    Ok(())
}

#[cfg(test)]
mod tests {
    use std::{collections::BTreeMap, fs};

    use crate::config::Config;

    use anyhow::Result;
    use tempfile::tempdir;

    use super::{
        PendingChangelog, next_release_heading, prepend_release_notes, render_release_notes,
    };

    #[test]
    fn builds_heading() {
        assert_eq!(
            next_release_heading("1.2.0", "2026-03-16"),
            "## [1.2.0] - 2026-03-16"
        );
    }

    #[test]
    fn groups_commit_sections_from_config() {
        let config = toml::from_str::<Config>(
            r#"
            [[version_files]]
            path = "pyproject.toml"
            key = "project.version"

            [changelog.sections]
            feat = "Added"
            fix = "Fixed"
            docs = false
            "#,
        )
        .expect("config");
        let commits = vec![
            crate::conventional_commits::ConventionalCommit::parse_message("feat: add search")
                .expect("parse"),
            crate::conventional_commits::ConventionalCommit::parse_message("docs: update readme")
                .expect("parse"),
        ];

        let changelog = PendingChangelog::from_commits(&config, &commits);
        assert_eq!(
            changelog.sections.get("Added"),
            Some(&vec!["add search".to_string()])
        );
        assert!(!changelog.sections.contains_key("docs"));
    }

    #[test]
    fn renders_release_notes() {
        let changelog = PendingChangelog {
            sections: BTreeMap::from([("Added".to_string(), vec!["ship it".to_string()])]),
        };

        let notes = render_release_notes("1.2.0", "2026-03-16", &changelog);
        assert!(notes.contains("## [1.2.0] - 2026-03-16"));
        assert!(notes.contains("### Added"));
        assert!(notes.contains("- ship it"));
    }

    #[test]
    fn prepends_release_notes_after_heading() -> Result<()> {
        let dir = tempdir()?;
        let path = dir.path().join("CHANGELOG.md");
        fs::write(&path, "# Changelog\n\n## [0.1.0] - 2026-01-01\n")?;

        prepend_release_notes(&path, "## [0.2.0] - 2026-03-16\n\n### Added\n- feature")?;

        let content = fs::read_to_string(path)?;
        assert!(content.starts_with("# Changelog\n\n## [0.2.0] - 2026-03-16"));
        assert!(content.contains("## [0.1.0] - 2026-01-01"));
        Ok(())
    }
}