changen 0.1.10

#![feature(btree_extract_if)]
#![feature(if_let_guard)]
#![feature(let_chains)]

use core::str;
use std::{
    borrow::Cow,
    fs::{File, OpenOptions},
    io::{self, IsTerminal, Read, Write},
    path::{Path, PathBuf},
};

use anyhow::bail;
use changelog::{
    de::parse_changelog,
    ser::{serialize_changelog, serialize_release, OptionsRelease},
};
use config::{Cli, Commands, MapMessageToSection, New, Remove, Show, Validate};
use generate::generate;
use repository::{Fs, Repository};
use utils::try_get_repo;

#[macro_use]
extern crate log;

mod commit_parser;
pub mod config;
mod generate;
mod git_provider;
mod release;
mod repository;
mod utils;

#[cfg(test)]
mod test_res;

#[cfg(test)]
mod integration_test;

fn get_changelog_path(path: Option<PathBuf>) -> PathBuf {
    path.unwrap_or(PathBuf::from("CHANGELOG.md"))
}

fn read_file(path: &Path) -> anyhow::Result<String> {
    let mut buf = String::new();

    let mut from_stdin = !io::stdin().is_terminal();

    if from_stdin {
        io::stdin().read_to_string(&mut buf)?;

        if buf.is_empty() {
            info!("Read stdin because is was not a terminal, but it is empty. Fallback to file.");
            from_stdin = false;
        }
    }

    if !from_stdin {
        let mut file = File::open(path)?;
        file.read_to_string(&mut buf)?;
    }

    Ok(buf)
}

fn write_output(output: &str, path: &Path, stdout: bool) -> anyhow::Result<()> {
    // !io::stdout().is_terminal()
    // won't work on Github action because stdout is piped somehow.
    if stdout {
        print!("{output}")
    } else {
        let mut file = File::options().truncate(true).write(true).open(path)?;
        file.write_all(output.as_bytes())?;
    }

    Ok(())
}

#[inline]
pub fn run(cli: Cli) -> anyhow::Result<()> {
    let r = Fs;

    run_generic(&r, cli)
}

fn run_generic<R: Repository>(r: &R, cli: Cli) -> anyhow::Result<()> {
    debug!("is terminal: {}", io::stdin().is_terminal());
    debug!("is terminal stdout: {}", io::stdout().is_terminal());

    match cli.command {
        Commands::Generate(mut options) => {
            let path = get_changelog_path(options.file.clone());
            let input = read_file(&path)?;
            let changelog = parse_changelog(&input)?;
            options.repo = try_get_repo(options.repo);

            let output = generate(r, changelog, &options)?;

            write_output(&output, &path, options.stdout)?;
        }

        Commands::Release(mut options) => {
            let path = get_changelog_path(options.file.clone());
            let input = read_file(&path)?;
            let changelog = parse_changelog(&input)?;
            options.repo = try_get_repo(options.repo);

            let (version, output) = release::release(r, changelog, &options)?;

            write_output(&output, &path, options.stdout)?;

            eprintln!("New release {} successfully created.", version);
        }

        Commands::Validate(options) => {
            let Validate {
                file,
                format,
                map,
                ast,
                stdout,
            } = options;

            let path = get_changelog_path(file);
            let input = read_file(&path)?;
            let mut changelog = parse_changelog(&input)?;

            debug!("changelog: {:?}", changelog);

            if ast {
                dbg!(&changelog);
            }

            if format {
                let map = MapMessageToSection::try_new(map)?;
                changelog.sanitize(&map.to_fmt_options());
                let output = serialize_changelog(&changelog, &changelog::ser::Options::default());

                write_output(&output, &path, stdout)?;
            }

            eprintln!("Changelog parsed with success!");
        }

        Commands::Show(options) => {
            let Show { file, n, version } = options;

            let path = get_changelog_path(file);
            let input = read_file(&path)?;
            let changelog = parse_changelog(&input)?;

            debug!("changelog: {:?}", changelog);

            let releases = if let Some(regex) = &version {
                let mut res = Vec::new();

                for release in changelog.releases() {
                    if regex.is_match(release.version()) {
                        res.push(Cow::Borrowed(release))
                    }
                }
                res
            } else {
                changelog
                    .nth_release(n)
                    .map(|e| e.release())
                    .into_iter()
                    .collect()
            };

            if releases.is_empty() {
                bail!("No release found");
            }

            for (pos, release) in releases.iter().enumerate() {
                debug!("show release: {:?}", release);
                let mut output = String::new();
                serialize_release(
                    &mut output,
                    release,
                    &OptionsRelease {
                        serialize_title: false,
                    },
                );

                print!("{}", output);
                if pos != releases.len() - 1 {
                    println!();
                }
            }
        }

        Commands::New(options) => {
            let New { path, force } = options;

            let path = get_changelog_path(path);

            if path.exists() && !force {
                bail!("Path already exist. Delete it or use the --force option");
            }

            let changelog = include_str!("../res/CHANGELOG_DEFAULT.md");

            let mut file = OpenOptions::new()
                .create(true)
                .truncate(true)
                .write(true)
                .open(path)?;

            file.write_all(changelog.as_bytes())?;

            println!("Changelog successfully created!");
        }
        Commands::Remove(options) => {
            let Remove {
                file,
                stdout,
                remove_id,
            } = options;

            let path = get_changelog_path(file);
            let input = read_file(&path)?;
            let mut changelog = parse_changelog(&input)?;

            debug!("changelog: {:?}", changelog);

            if let Some(regex) = &remove_id.version {
                changelog
                    .releases
                    .retain(|_, v| !regex.is_match(v.version()));
            } else {
                match changelog.nth_release(remove_id.n.unwrap())?.owned() {
                    changelog::utils::NthRelease::Unreleased(_) => {
                        changelog.unreleased.take();
                    }
                    changelog::utils::NthRelease::Released(key, _) => {
                        changelog.releases.remove(&key);
                    }
                }
            }

            changelog.sanitize(&changelog::fmt::Options::default());

            let output = serialize_changelog(&changelog, &changelog::ser::Options::default());

            write_output(&output, &path, stdout)?;
        }
    }

    Ok(())
}