mise 2026.9.3

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

use eyre::Result;

use crate::dirs;
use crate::file;
use crate::hash::{file_hash_blake3, hash_to_str};

/// Persistent state for deps freshness checking.
///
/// Stores blake3 content hashes of source files and effective commands keyed by
/// provider ID, plus the set of output paths that existed at the last successful
/// run and the output-rule identity used to select them.
/// Persisted to `$MISE_STATE_DIR/deps/<hash>.toml`, keyed by project root.
#[derive(Debug, Default, serde::Serialize, serde::Deserialize)]
pub(crate) struct DepsState {
    /// provider_id → (relative_path → blake3_hex)
    #[serde(default)]
    pub providers: BTreeMap<String, BTreeMap<String, String>>,
    /// provider_id → list of output paths (relative to project root) that
    /// existed after the last successful run. Used to detect when an output
    /// that was previously present has been deleted, including one match from
    /// a required output glob.
    #[serde(default)]
    pub seen_outputs: BTreeMap<String, Vec<String>>,
    /// provider_id → blake3 hash of the effective command
    #[serde(default)]
    pub command_hashes: BTreeMap<String, String>,
    /// provider_id → hash of the unexpanded configured output rules used
    /// when `seen_outputs` was recorded.
    #[serde(default)]
    pub output_rule_hashes: BTreeMap<String, String>,
}

impl DepsState {
    /// Load state for a project, returning default if not found.
    pub(crate) fn load(project_root: &Path) -> Self {
        let path = state_path(project_root);
        if !path.exists() {
            return Self::default();
        }
        match file::read_to_string(&path) {
            Ok(contents) => match toml::from_str(&contents) {
                Ok(state) => state,
                Err(e) => {
                    warn!("failed to parse {}: {e}", path.display());
                    Self::default()
                }
            },
            Err(e) => {
                warn!("failed to read {}: {e}", path.display());
                Self::default()
            }
        }
    }

    /// Save state for a project.
    pub(crate) fn save(&self, project_root: &Path) -> Result<()> {
        let path = state_path(project_root);
        file::create_dir_all(path.parent().unwrap())?;
        let contents = toml::to_string_pretty(self)?;
        file::write(&path, contents)?;
        Ok(())
    }

    /// Get stored hashes for a provider, or None if not previously recorded.
    pub(crate) fn get_hashes(&self, provider_id: &str) -> Option<&BTreeMap<String, String>> {
        self.providers.get(provider_id)
    }

    /// Update stored hashes for a provider.
    pub(crate) fn set_hashes(&mut self, provider_id: &str, hashes: BTreeMap<String, String>) {
        self.providers.insert(provider_id.to_string(), hashes);
    }

    /// Get outputs that existed at the last successful run, or None if not
    /// previously recorded.
    pub(crate) fn get_seen_outputs(&self, provider_id: &str) -> Option<&Vec<String>> {
        self.seen_outputs.get(provider_id)
    }

    /// Record outputs that exist after a successful run.
    pub(crate) fn set_seen_outputs(&mut self, provider_id: &str, outputs: Vec<String>) {
        self.seen_outputs.insert(provider_id.to_string(), outputs);
    }

    /// Get the effective command hash recorded after the last successful run.
    pub(crate) fn get_command_hash(&self, provider_id: &str) -> Option<&str> {
        self.command_hashes.get(provider_id).map(String::as_str)
    }

    /// Record the effective command hash after a successful run.
    pub(crate) fn set_command_hash(&mut self, provider_id: &str, hash: String) {
        self.command_hashes.insert(provider_id.to_string(), hash);
    }

    /// Get the output-rule identity used to record a provider's seen outputs.
    pub(crate) fn get_output_rules(&self, provider_id: &str) -> Option<&String> {
        self.output_rule_hashes.get(provider_id)
    }

    /// Record the output-rule identity associated with a provider's outputs.
    pub(crate) fn set_output_rules(&mut self, provider_id: &str, rules: String) {
        self.output_rule_hashes
            .insert(provider_id.to_string(), rules);
    }
}

/// Stringify a path relative to the project root using the same convention as
/// the stored state (forward-slash relative path, falling back to the absolute
/// path when the path is not under `project_root`).
pub(crate) fn relative_str(path: &Path, project_root: &Path) -> String {
    path.strip_prefix(project_root)
        .unwrap_or(path)
        .to_string_lossy()
        .to_string()
}

/// Compute blake3 hashes for a list of source files.
///
/// Returns a map of relative_path → blake3_hex. Directories are skipped
/// (only regular files are hashed). Non-existent files are omitted.
pub(crate) fn hash_sources(
    sources: &[PathBuf],
    project_root: &Path,
) -> Result<BTreeMap<String, String>> {
    let mut hashes = BTreeMap::new();

    for source in sources {
        if !source.exists() {
            continue;
        }

        if source.is_dir() {
            // For directories, hash all files within (up to 3 levels deep)
            hash_dir_files(&mut hashes, source, project_root, 3)?;
        } else {
            let hash = file_hash_blake3(source, None)?;
            hashes.insert(relative_str(source, project_root), hash);
        }
    }

    Ok(hashes)
}

/// Recursively hash files in a directory up to max_depth levels.
fn hash_dir_files(
    hashes: &mut BTreeMap<String, String>,
    dir: &Path,
    project_root: &Path,
    max_depth: usize,
) -> Result<()> {
    if max_depth == 0 {
        return Ok(());
    }
    if let Ok(entries) = std::fs::read_dir(dir) {
        for entry in entries.flatten() {
            let path = entry.path();
            if path.is_dir() {
                hash_dir_files(hashes, &path, project_root, max_depth - 1)?;
            } else {
                let hash = file_hash_blake3(&path, None)?;
                hashes.insert(relative_str(&path, project_root), hash);
            }
        }
    }
    Ok(())
}

/// Path to the state file for a given project root.
///
/// Uses a hash of the project root path so state is scoped per-project without
/// writing inside the project directory (mirrors `tracked-configs`).
fn state_path(project_root: &Path) -> PathBuf {
    dirs::STATE
        .join("deps")
        .join(format!("{}.toml", hash_to_str(&project_root)))
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn legacy_state_without_command_hashes_is_supported() {
        let state: DepsState = toml::from_str(
            r#"
                [providers.example]
                input = "hash"

                [seen_outputs]
                example = ["output"]
            "#,
        )
        .unwrap();

        assert_eq!(state.get_hashes("example").unwrap()["input"], "hash");
        assert_eq!(state.get_seen_outputs("example").unwrap(), &["output"]);
        assert_eq!(state.get_command_hash("example"), None);
    }

    #[test]
    fn command_hashes_round_trip() {
        let mut state = DepsState::default();
        state.set_command_hash("example", "digest".to_string());

        let serialized = toml::to_string(&state).unwrap();
        assert!(!serialized.contains("run command"));
        let restored: DepsState = toml::from_str(&serialized).unwrap();
        assert_eq!(restored.get_command_hash("example"), Some("digest"));
    }

    #[test]
    fn old_state_without_output_rule_hashes_remains_compatible() {
        let state: DepsState = toml::from_str(
            r#"
[seen_outputs]
npm = ["node_modules"]
"#,
        )
        .unwrap();

        assert_eq!(state.get_seen_outputs("npm").unwrap(), &["node_modules"]);
        assert!(state.get_output_rules("npm").is_none());
    }
}