clorinde 1.4.0

use std::process::{Command, Stdio};

use self::error::Error;

/// Checks if a command-line tool is installed and available in PATH
fn is_installed(tool: &str) -> bool {
    let status = std::process::Command::new(tool)
        .arg("--version")
        .stdout(std::process::Stdio::null())
        .stderr(std::process::Stdio::null())
        .status();

    status.is_ok_and(|s| s.success())
}

/// Starts Clorinde's database container and wait until it reports healthy.
///
/// Any existing `clorinde_postgres` container is removed first to avoid
/// name conflicts left over from a previous failed run.
pub fn setup(podman: bool, container_image: &str, container_wait: u64) -> Result<(), Error> {
    let command = if podman { "podman" } else { "docker" };
    if !is_installed(command) {
        return Err(Error {
            msg: format!("`{command}` is not installed or not found in PATH."),
            help: Some(format!(
                "`schema` requires `{command}` to be installed and added to your PATH."
            )),
        });
    }

    // Clean up any stale container from a previous run
    cleanup(podman).ok();

    spawn_container(podman, container_image)?;
    healthcheck(podman, 120, 50, container_wait)?;
    Ok(())
}

/// Stop and remove a container and its volume.
pub fn cleanup(podman: bool) -> Result<(), Error> {
    stop_container(podman)?;
    remove_container(podman)?;
    Ok(())
}

/// Starts Clorinde's database container.
fn spawn_container(podman: bool, container_image: &str) -> Result<(), Error> {
    let args = vec![
        "run",
        "-d",
        "--name",
        "clorinde_postgres",
        "-p",
        "5435:5432",
        "-e",
        "POSTGRES_PASSWORD=postgres",
        container_image,
    ];
    cmd(podman, &args, "spawn container")
}

/// Checks if Clorinde's container reports healthy
fn is_postgres_healthy(podman: bool) -> Result<bool, Error> {
    let args = ["exec", "clorinde_postgres", "pg_isready"];
    Ok(cmd(podman, &args, "check container health").is_ok())
}

/// This function controls how the healthcheck retries are handled.
fn healthcheck(
    podman: bool,
    max_retries: u64,
    ms_per_retry: u64,
    container_wait: u64,
) -> Result<(), Error> {
    let slow_threshold = 10 + max_retries / 10;
    let mut nb_retries = 0;

    while !is_postgres_healthy(podman)? {
        if nb_retries >= max_retries {
            return Err(Error::new(
                String::from("Clorinde reached the max number of connection retries"),
                podman,
            ));
        };

        std::thread::sleep(std::time::Duration::from_millis(ms_per_retry));
        nb_retries += 1;

        if nb_retries % slow_threshold == 0 {
            println!(
                "Container startup slower than expected ({nb_retries} retries out of {max_retries})"
            );
        }
    }

    // Just for extra safety...
    std::thread::sleep(std::time::Duration::from_millis(container_wait));
    Ok(())
}

/// Stops Clorinde's container.
fn stop_container(podman: bool) -> Result<(), Error> {
    let args = ["stop", "clorinde_postgres"];
    cmd(podman, &args, "stop container")
}

/// Removes Clorinde's container and its volume.
fn remove_container(podman: bool) -> Result<(), Error> {
    let args = ["rm", "-v", "clorinde_postgres"];
    cmd(podman, &args, "remove container")
}

fn cmd(podman: bool, args: &[&str], action: &'static str) -> Result<(), Error> {
    let command = if podman { "podman" } else { "docker" };
    let output = Command::new(command)
        .args(args)
        .stderr(Stdio::piped())
        .stdout(Stdio::null())
        .output()?;

    if output.status.success() {
        Ok(())
    } else {
        let err = String::from_utf8_lossy(&output.stderr);
        Err(Error::new(
            format!("`{command}` couldn't {action}: {err}"),
            podman,
        ))
    }
}

pub(crate) mod error {
    use std::fmt::Debug;

    use miette::Diagnostic;
    use thiserror::Error as ThisError;

    #[derive(Debug, ThisError, Diagnostic)]
    #[error("{msg}")]
    pub struct Error {
        pub(crate) msg: String,
        #[help]
        pub help: Option<String>,
    }

    impl Error {
        pub fn new(msg: String, podman: bool) -> Self {
            let help = if podman {
                "Make sure that port 5435 is usable and that no container named `clorinde_postgres` already exists."
            } else {
                "First, check that the docker daemon is up-and-running. Then, make sure that port 5435 is usable and that no container named `clorinde_postgres` already exists."
            };
            Error {
                msg,
                help: Some(String::from(help)),
            }
        }
    }

    impl From<std::io::Error> for Error {
        fn from(e: std::io::Error) -> Self {
            Self {
                msg: format!("{e:#}"),
                help: None,
            }
        }
    }
}