typescript_tools 8.0.1

use std::collections::HashMap;
use std::fmt::Display;
use std::path::{Path, PathBuf};

use crate::configuration_file::ConfigurationFile;
use crate::io::FromFileError;
use crate::monorepo_manifest::{EnumeratePackageManifestsError, MonorepoManifest};

#[derive(Debug)]
#[non_exhaustive]
pub struct LintError {
    pub kind: LintErrorKind,
}

impl Display for LintError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match &self.kind {
            LintErrorKind::UnknownDependency(dependency) => write!(
                f,
                "expected dependency `{}` to be used in at least one package",
                dependency
            ),
            LintErrorKind::UnexpectedInternalDependencyVersion => write!(f, "lint errors detected"),
            LintErrorKind::InvalidUtf8(path) => {
                write!(f, "path cannot be expressed as UTF-8: {:?}", path)
            }
            _ => write!(f, "error linting dependency versions"),
        }
    }
}

impl std::error::Error for LintError {
    fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
        match &self.kind {
            LintErrorKind::EnumeratePackageManifests(err) => Some(err),
            LintErrorKind::FromFile(err) => Some(err),
            LintErrorKind::UnknownDependency(_) => None,
            LintErrorKind::UnexpectedInternalDependencyVersion => None,
            LintErrorKind::InvalidUtf8(_) => None,
        }
    }
}

#[derive(Debug)]
pub enum LintErrorKind {
    #[non_exhaustive]
    FromFile(FromFileError),
    #[non_exhaustive]
    EnumeratePackageManifests(EnumeratePackageManifestsError),
    #[non_exhaustive]
    UnknownDependency(String),
    // REFACTOR: move display logic into this type
    #[non_exhaustive]
    UnexpectedInternalDependencyVersion,
    #[non_exhaustive]
    InvalidUtf8(PathBuf),
}

impl From<FromFileError> for LintError {
    fn from(err: FromFileError) -> Self {
        Self {
            kind: LintErrorKind::FromFile(err),
        }
    }
}

impl From<EnumeratePackageManifestsError> for LintError {
    fn from(err: EnumeratePackageManifestsError) -> Self {
        Self {
            kind: LintErrorKind::EnumeratePackageManifests(err),
        }
    }
}

impl From<LintErrorKind> for LintError {
    fn from(kind: LintErrorKind) -> Self {
        Self { kind }
    }
}

fn most_common_dependency_version(
    package_manifests_by_dependency_version: &HashMap<String, Vec<String>>,
) -> Option<String> {
    package_manifests_by_dependency_version
        .iter()
        // Map each dependecy version to its number of occurrences
        .map(|(dependency_version, package_manifests)| {
            (dependency_version, package_manifests.len())
        })
        // Take the max by value
        .max_by(|a, b| a.1.cmp(&b.1))
        .map(|(k, _v)| k.to_owned())
}

pub fn lint_dependency_version<P, S>(root: P, dependencies: &[S]) -> Result<(), LintError>
where
    P: AsRef<Path>,
    S: AsRef<str> + std::fmt::Display,
{
    let root = root.as_ref();

    let lerna_manifest = MonorepoManifest::from_directory(root)?;
    let package_manifest_by_package_name = lerna_manifest.package_manifests_by_package_name()?;

    let mut is_exit_success = true;

    for dependency in dependencies {
        let package_manifests_by_dependency_version: HashMap<String, Vec<String>> =
            package_manifest_by_package_name
                .values()
                .filter_map(|package_manifest| {
                    package_manifest
                        .get_dependency_version(dependency)
                        .map(|dependency_version| (package_manifest, dependency_version))
                })
                .try_fold(
                    HashMap::new(),
                    |mut accumulator,
                     (package_manifest, dependency_version)|
                     -> Result<HashMap<_, _>, LintError> {
                        let packages_using_this_dependency_version: &mut Vec<String> =
                            accumulator.entry(dependency_version).or_default();
                        packages_using_this_dependency_version.push(
                            package_manifest
                                .path()
                                .to_str()
                                .map(ToOwned::to_owned)
                                .ok_or_else(|| {
                                    LintErrorKind::InvalidUtf8(package_manifest.path())
                                })?,
                        );
                        Ok(accumulator)
                    },
                )?;

        if package_manifests_by_dependency_version.keys().len() <= 1 {
            return Ok(());
        }

        let expected_version_number =
            most_common_dependency_version(&package_manifests_by_dependency_version)
                .ok_or_else(|| LintErrorKind::UnknownDependency(dependency.to_string()))?;

        println!("Linting versions of dependency \"{}\"", &dependency);

        package_manifests_by_dependency_version
            .into_iter()
            // filter out the packages using the expected dependency version
            .filter(|(dependency_version, _package_manifests)| {
                !dependency_version.eq(&expected_version_number)
            })
            .for_each(|(dependency_version, package_manifests)| {
                package_manifests.into_iter().for_each(|package_manifest| {
                    println!(
                        "\tIn {}, expected version {} but found version {}",
                        &package_manifest, &expected_version_number, dependency_version
                    );
                });
            });

        is_exit_success = false;
    }

    if !is_exit_success {
        return Err(LintError {
            kind: LintErrorKind::UnexpectedInternalDependencyVersion,
        });
    }
    Ok(())
}