systemprompt_cli/commands/admin/config/

validate.rs

//! `admin config validate` command: validate config files against their
//! schemas.
//!
//! Resolves a target to a single file, a [`ConfigSection`], or the full set of
//! sections, parses each as YAML, and validates a full profile document against
//! the [`systemprompt_manifest::profile::Profile`] schema. Also prints the
//! generated `Profile` JSON schema on demand.
//!
//! A full validation (no target) also parses every registered config plane's
//! declaration offline ([`super::plane_validate`]).
//!
//! Whenever the scheduler section is in scope, the merged services config is
//! additionally cross-checked against the registered job catalog, so a job name
//! no `submit_job!` registers is caught here instead of aborting scheduler
//! startup on a deploy. That catalog is the set of jobs linked into the *CLI*
//! binary; a downstream that links job-registering crates only into its API
//! binary would see false positives.
//!
//! Copyright (c) systemprompt.io — Business Source License 1.1.
//! See <https://systemprompt.io> for licensing details.

use anyhow::{Result, anyhow};
use clap::Args;

use super::types::{ConfigFileInfo, ConfigSection, ConfigValidateOutput, read_yaml_file};
use crate::CliConfig;
use crate::shared::CommandOutput;
use systemprompt_loader::ConfigLoader;
use systemprompt_manifest::profile::Profile;
use systemprompt_scheduler::SchedulerConfig;

#[derive(Debug, Clone, Args)]
pub struct ValidateArgs {
    #[arg(value_name = "PATH_OR_SECTION")]
    pub target: Option<String>,

    #[arg(long)]
    pub strict: bool,

    #[arg(
        long,
        help = "Print the generated JSON schema for the Profile config type instead of validating \
                any file"
    )]
    pub schema: bool,
}

pub fn execute(args: &ValidateArgs, _config: &CliConfig) -> Result<(CommandOutput, bool)> {
    if args.schema {
        return print_profile_schema();
    }

    if let Some(target) = &args.target {
        let path = std::path::PathBuf::from(target);
        if path.exists() && is_yaml_file(&path) && target.parse::<ConfigSection>().is_err() {
            return validate_profile_file(&path);
        }
    }

    let files_to_validate = if let Some(target) = &args.target {
        if let Ok(section) = target.parse::<ConfigSection>() {
            section.all_files()?
        } else {
            vec![std::path::PathBuf::from(target)]
        }
    } else {
        let mut all_files = Vec::new();
        for section in ConfigSection::all() {
            all_files.extend(section.all_files()?);
        }
        all_files
    };

    let mut results = Vec::new();
    let mut all_valid = true;

    for file_path in files_to_validate {
        let section = detect_section(&file_path);
        let exists = file_path.exists();

        let (valid, error) = if exists {
            match validate_file(&file_path, args.strict) {
                Ok(()) => (true, None),
                Err(e) => {
                    all_valid = false;
                    (false, Some(e.to_string()))
                },
            }
        } else {
            all_valid = false;
            (false, Some("File not found".to_owned()))
        };

        results.push(ConfigFileInfo {
            path: file_path.display().to_string(),
            section,
            exists,
            valid,
            error,
        });
    }

    all_valid &= super::plane_validate::append_full_validation(args.target.as_ref(), &mut results);

    if let Some(error) = scheduler_catalog_error(&results, args.strict) {
        all_valid = false;
        for file in &mut results {
            if file.section == "scheduler" && file.error.is_none() {
                file.valid = false;
                file.error = Some(error.clone());
            }
        }
    }

    let output = ConfigValidateOutput {
        files: results,
        all_valid,
    };

    let title = if all_valid {
        "Validation Passed"
    } else {
        "Validation Failed"
    };

    Ok((
        CommandOutput::table_of(
            vec!["path", "section", "exists", "valid", "error"],
            &output.files,
        )
        .with_title(title),
        all_valid,
    ))
}

fn print_profile_schema() -> Result<(CommandOutput, bool)> {
    let schema = schemars::schema_for!(Profile);
    let json = serde_json::to_string_pretty(&schema)
        .map_err(|e| anyhow!("failed to serialize Profile JSON schema: {e}"))?;
    Ok((CommandOutput::text(json), true))
}

fn validate_profile_file(path: &std::path::Path) -> Result<(CommandOutput, bool)> {
    let content = std::fs::read_to_string(path)
        .map_err(|e| anyhow!("failed to read profile {}: {e}", path.display()))?;

    match Profile::from_yaml(&content, path) {
        Ok(profile) => {
            let output = ConfigValidateOutput {
                files: vec![ConfigFileInfo {
                    path: path.display().to_string(),
                    section: "profile".to_owned(),
                    exists: true,
                    valid: true,
                    error: None,
                }],
                all_valid: true,
            };
            let title = format!("Profile '{}' is valid", profile.name);
            Ok((
                CommandOutput::table_of(
                    vec!["path", "section", "exists", "valid", "error"],
                    &output.files,
                )
                .with_title(title),
                true,
            ))
        },
        Err(e) => Err(anyhow!(
            "invalid profile {}: {e}\nThe error above names the offending field or value — fix it \
             and re-run.",
            path.display()
        )),
    }
}

fn scheduler_catalog_error(files: &[ConfigFileInfo], strict: bool) -> Option<String> {
    if !files
        .iter()
        .any(|file| file.section == "scheduler" && file.error.is_none())
    {
        return None;
    }

    match ConfigLoader::load() {
        Ok(services) => {
            let scheduler = services
                .scheduler
                .unwrap_or_else(SchedulerConfig::with_system_admin);
            unknown_jobs_message(&scheduler)
                .or_else(|| strict.then(|| unlisted_jobs_message(&scheduler)).flatten())
        },
        Err(e) => Some(format!("failed to load merged services config: {e}")),
    }
}

pub fn unlisted_jobs_message(config: &SchedulerConfig) -> Option<String> {
    let unlisted = systemprompt_scheduler::unlisted_job_names(config);
    if unlisted.is_empty() {
        return None;
    }
    Some(format!(
        "registered job(s) with no scheduler.jobs entry: {}. Add an entry for each (enabled: \
         false keeps one off the schedule).",
        unlisted
            .iter()
            .map(systemprompt_identifiers::JobName::as_str)
            .collect::<Vec<_>>()
            .join(", ")
    ))
}

pub fn unknown_jobs_message(config: &SchedulerConfig) -> Option<String> {
    let unknown = systemprompt_scheduler::unknown_job_names(config);
    if unknown.is_empty() {
        return None;
    }
    Some(format!(
        "job(s) not registered via submit_job!: {}. Run `systemprompt infra jobs list` to see \
         every registered job.",
        unknown.join(", ")
    ))
}

fn is_yaml_file(path: &std::path::Path) -> bool {
    matches!(
        path.extension().and_then(|e| e.to_str()),
        Some("yaml" | "yml")
    )
}

fn validate_file(path: &std::path::Path, _strict: bool) -> Result<()> {
    let _content = read_yaml_file(path)?;
    Ok(())
}

fn detect_section(path: &std::path::Path) -> String {
    let path_str = path.display().to_string();

    if path_str.contains("/ai/") {
        "ai".to_owned()
    } else if path_str.contains("/content/") {
        "content".to_owned()
    } else if path_str.contains("/web/") {
        "web".to_owned()
    } else if path_str.contains("/scheduler/") {
        "scheduler".to_owned()
    } else if path_str.contains("/agents/") {
        "agents".to_owned()
    } else if path_str.contains("/mcp/") {
        "mcp".to_owned()
    } else if path_str.contains("/skills/") {
        "skills".to_owned()
    } else if path_str.contains("profile.yaml") {
        "profile".to_owned()
    } else if path_str.contains("/config/config.yaml") {
        "services".to_owned()
    } else {
        "unknown".to_owned()
    }
}