envorigin 1.10.0

pub mod actions;
pub mod audit;
pub mod circleci;
pub mod cli;
pub mod compose;
pub mod diff;
pub mod docker;
pub mod dotenv;
pub mod gitlab;
pub mod graph;
pub mod interpolation;
pub mod lsp;
pub mod model;
pub mod output;
pub mod rules;

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

use compose::{analyze_service, load_compose_with_content};
use docker::DockerVerification;
use dotenv::parse_dotenv_file;
use interpolation::InterpolationContext;
use model::{AnalysisError, Diagnostic, ProjectReport, Severity, SourceKind, SourceRef};

#[derive(Debug, Clone)]
pub struct AnalyzeOptions {
    pub compose_file: PathBuf,
    pub env_files: Vec<PathBuf>,
    pub project_directory: Option<PathBuf>,
    pub host_env_file: Option<PathBuf>,
    pub docker_check: bool,
}

impl Default for AnalyzeOptions {
    fn default() -> Self {
        Self {
            compose_file: PathBuf::from("compose.yaml"),
            env_files: Vec::new(),
            project_directory: None,
            host_env_file: None,
            docker_check: true,
        }
    }
}

pub fn analyze(options: &AnalyzeOptions) -> Result<ProjectReport, AnalysisError> {
    analyze_with_content(options, None)
}

/// Analyze with an in-memory buffer override (LSP unsaved edits). Paths
/// still resolve against the real file location.
pub fn analyze_with_content(
    options: &AnalyzeOptions,
    content: Option<&str>,
) -> Result<ProjectReport, AnalysisError> {
    let compose_file = absolute(&options.compose_file)?;
    let compose = load_compose_with_content(&compose_file, content)?;
    let project_directory = match &options.project_directory {
        Some(path) => absolute(path)?,
        None => compose_file
            .parent()
            .unwrap_or_else(|| Path::new("."))
            .to_path_buf(),
    };

    let mut diagnostics = Vec::new();
    let mut context = InterpolationContext::<SourceRef>::new();

    let host_values: BTreeMap<String, String> = env::vars().collect();
    for (key, value) in host_values {
        context.define(
            key,
            Some(value),
            SourceRef::new(
                SourceKind::HostEnvironment,
                None,
                None,
                "process environment",
            ),
            10_000,
        );
    }

    if let Some(host_file) = &options.host_env_file {
        let path = absolute(host_file)?;
        let parsed = parse_dotenv_file(&path)?;
        diagnostics.extend(parsed.diagnostics);
        for entry in parsed.entries {
            let value = entry
                .value
                .as_deref()
                .map(|raw| context.interpolate_if(raw, entry.interpolate).value);
            context.define(
                entry.key,
                value,
                SourceRef::new(
                    SourceKind::HostEnvironment,
                    Some(path.clone()),
                    Some(entry.line),
                    "host environment overlay",
                ),
                20_000,
            );
        }
    }

    // COMPOSE_ENV_FILES lists interpolation files (separated by the OS path
    // separator) and replaces the default .env lookup. Explicit --env-file
    // arguments take precedence, mirroring Docker Compose's resolution.
    let env_files_from_compose = context
        .get("COMPOSE_ENV_FILES")
        .map(|value| {
            value
                .split([':', ';'])
                .map(str::trim)
                .filter(|part| !part.is_empty())
                .map(|part| project_directory.join(part))
                .collect::<Vec<_>>()
        })
        .filter(|paths| !paths.is_empty());

    let interpolation_files = if !options.env_files.is_empty() {
        options
            .env_files
            .iter()
            .map(|path| absolute(path))
            .collect::<Result<Vec<_>, _>>()?
    } else if let Some(paths) = env_files_from_compose {
        let mut files = Vec::new();
        for path in paths {
            if path.exists() {
                files.push(path);
            } else {
                diagnostics.push(Diagnostic::new(
                    Severity::Warning,
                    "compose-env-files-missing",
                    format!("COMPOSE_ENV_FILES entry does not exist: {}", path.display()),
                ));
            }
        }
        files
    } else {
        let default = project_directory.join(".env");
        if default.exists() {
            vec![default]
        } else {
            Vec::new()
        }
    };

    for (index, path) in interpolation_files.iter().enumerate() {
        let parsed = parse_dotenv_file(path)?;
        diagnostics.extend(parsed.diagnostics);
        let kind = if options.env_files.is_empty() {
            SourceKind::DefaultEnvFile
        } else {
            SourceKind::CliEnvFile
        };
        for entry in parsed.entries {
            let interpolated = entry
                .value
                .as_deref()
                .map(|raw| context.interpolate_if(raw, entry.interpolate));
            if let Some(result) = &interpolated {
                diagnostics.extend(result.diagnostics.clone());
            }
            context.define(
                entry.key,
                interpolated.map(|result| result.value),
                SourceRef::new(
                    kind.clone(),
                    Some(path.clone()),
                    Some(entry.line),
                    if options.env_files.is_empty() {
                        "default Compose interpolation file"
                    } else {
                        "explicit Compose interpolation file"
                    },
                ),
                100 + index as i32,
            );
        }
    }

    if context.contains("COMPOSE_FILE") {
        diagnostics.push(Diagnostic::new(
            Severity::Warning,
            "compose-file-redirect",
            "COMPOSE_FILE is set; use --file explicitly so the analyzed file is unambiguous",
        ));
    }

    let docker = if options.docker_check {
        DockerVerification::run(
            &compose_file,
            &options.env_files,
            &project_directory,
            options.host_env_file.as_deref(),
        )
    } else {
        DockerVerification::skipped()
    };

    diagnostics.extend(docker.diagnostics.clone());

    let mut services = Vec::new();
    for (name, service) in &compose.services {
        let canonical = docker.services.get(name);
        services.push(analyze_service(
            name,
            service,
            &compose_file,
            &context,
            canonical,
        )?);
    }

    Ok(ProjectReport {
        compose_file,
        project_directory,
        interpolation_files,
        docker_status: docker.status,
        services,
        diagnostics,
    })
}

fn absolute(path: &Path) -> Result<PathBuf, AnalysisError> {
    if path.is_absolute() {
        return Ok(path.to_path_buf());
    }
    Ok(env::current_dir()?.join(path))
}