fraiseql_auth/

security_init.rs

//! Security system initialization from compiled schema configuration
//!
//! Loads security configuration from schema.compiled.json and initializes
//! all security subsystems with proper environment variable overrides.

use serde_json::Value as JsonValue;
use tracing::{debug, info, warn};

use super::security_config::SecurityConfigFromSchema;
use crate::{AuthError, error::Result};

/// Maximum size for schema JSON to prevent DOS attacks
/// 10 MB should be more than sufficient for any realistic schema
const MAX_SCHEMA_JSON_SIZE: usize = 10 * 1024 * 1024; // 10 MB

/// Maximum size for security configuration section
/// Security config should be < 100 KB in realistic deployments
const MAX_SECURITY_CONFIG_SIZE: usize = 100 * 1024; // 100 KB

/// Initialize security configuration from compiled schema JSON string
///
/// Loads security settings from the schema.compiled.json and applies
/// environment variable overrides. This function should be called during
/// server startup after loading the compiled schema.
///
/// # SECURITY
/// - Validates schema JSON size to prevent DOS attacks
/// - Rejects JSON > 10 MB
/// - Rejects security config section > 100 KB
///
/// # Arguments
///
/// * `schema_json_str` - The compiled schema as a JSON string
///
/// # Returns
///
/// Returns a configured `SecurityConfigFromSchema` with environment overrides applied
///
/// # Errors
///
/// Returns error if:
/// - JSON size exceeds limits
/// - JSON parsing fails
/// - Security configuration section is invalid or missing required fields
///
/// # Example
///
/// ```no_run
/// // Requires: compiled schema JSON string loaded from disk or a schema loader.
/// # fn example() -> fraiseql_auth::error::Result<()> {
/// use fraiseql_auth::security_init::init_security_config;
/// let json_str = r#"{"security":{"auditLogging":{"enabled":true}}}"#;
/// let security_config = init_security_config(json_str)?;
/// # Ok(())
/// # }
/// ```
pub fn init_security_config(schema_json_str: &str) -> Result<SecurityConfigFromSchema> {
    debug!("Parsing schema JSON for security configuration");

    // SECURITY: Check JSON size to prevent DOS from oversized payloads
    if schema_json_str.len() > MAX_SCHEMA_JSON_SIZE {
        warn!(
            "Schema JSON exceeds maximum size: {} > {} bytes",
            schema_json_str.len(),
            MAX_SCHEMA_JSON_SIZE
        );
        return Err(AuthError::ConfigError {
            message: format!("Schema JSON exceeds maximum size of {} bytes", MAX_SCHEMA_JSON_SIZE),
        });
    }

    // Parse JSON string to JsonValue
    let schema_json: JsonValue = serde_json::from_str(schema_json_str).map_err(|e| {
        warn!("Failed to parse schema JSON: {e}");
        AuthError::ConfigError {
            message: format!("Invalid schema JSON: {e}"),
        }
    })?;

    init_security_config_from_value(&schema_json)
}

/// Initialize security configuration from compiled schema JSON value
///
/// Internal function that works with parsed JsonValue. Use `init_security_config` for strings.
///
/// # SECURITY
/// - Validates security configuration size to prevent DOS attacks
/// - Rejects security config > 100 KB
///
/// # Arguments
///
/// * `schema_json` - The compiled schema as a JsonValue
///
/// # Returns
///
/// Returns a configured `SecurityConfigFromSchema` with environment overrides applied
///
/// # Errors
///
/// Returns error if security configuration section is invalid or missing required fields
pub(crate) fn init_security_config_from_value(
    schema_json: &JsonValue,
) -> Result<SecurityConfigFromSchema> {
    debug!("Initializing security configuration from schema");

    // Extract security section from schema
    let security_value = schema_json.get("security").ok_or_else(|| {
        warn!("No security configuration found in schema, using defaults");
        AuthError::ConfigError {
            message: "Missing security configuration in schema".to_string(),
        }
    })?;

    // SECURITY: Check security config size to prevent DOS
    let security_json_str = security_value.to_string();
    if security_json_str.len() > MAX_SECURITY_CONFIG_SIZE {
        warn!(
            "Security configuration exceeds maximum size: {} > {} bytes",
            security_json_str.len(),
            MAX_SECURITY_CONFIG_SIZE
        );
        return Err(AuthError::ConfigError {
            message: format!(
                "Security configuration exceeds maximum size of {} bytes",
                MAX_SECURITY_CONFIG_SIZE
            ),
        });
    }

    // Parse security configuration from schema
    let mut config = SecurityConfigFromSchema::from_json(security_value).map_err(|e| {
        warn!("Failed to parse security configuration: {e}");
        AuthError::ConfigError {
            message: format!("Invalid security configuration: {e}"),
        }
    })?;

    info!("Security configuration loaded from schema");

    // Apply environment variable overrides
    config.apply_env_overrides();
    debug!("Security environment variable overrides applied");

    Ok(config)
}

/// Initialize security configuration with default values if schema doesn't have security config
///
/// This is useful for backward compatibility when the schema doesn't include
/// a security section. It loads defaults and applies environment overrides.
///
/// # Returns
///
/// A default `SecurityConfigFromSchema` with environment overrides applied
pub fn init_default_security_config() -> SecurityConfigFromSchema {
    info!("Initializing default security configuration");
    let mut config = SecurityConfigFromSchema::default();
    config.apply_env_overrides();
    debug!("Default security configuration applied with environment overrides");
    config
}

/// Log the active security configuration (sanitized for safe logging)
///
/// Outputs current security settings to logs, excluding sensitive values
/// like encryption keys.
///
/// # Arguments
///
/// * `config` - The security configuration to log
pub fn log_security_config(config: &SecurityConfigFromSchema) {
    info!(
        audit_logging_enabled = config.audit_logging.enabled,
        audit_log_level = %config.audit_logging.log_level,
        audit_async_logging = config.audit_logging.async_logging,
        audit_buffer_size = config.audit_logging.buffer_size,
        "Audit logging configuration"
    );

    info!(
        error_sanitization_enabled = config.error_sanitization.enabled,
        error_generic_messages = config.error_sanitization.generic_messages,
        error_internal_logging = config.error_sanitization.internal_logging,
        error_leak_sensitive = config.error_sanitization.leak_sensitive_details,
        "Error sanitization configuration"
    );

    info!(
        rate_limiting_enabled = config.rate_limiting.enabled,
        auth_start_max = config.rate_limiting.auth_start_max_requests,
        auth_callback_max = config.rate_limiting.auth_callback_max_requests,
        auth_refresh_max = config.rate_limiting.auth_refresh_max_requests,
        failed_login_max = config.rate_limiting.failed_login_max_requests,
        "Rate limiting configuration"
    );

    info!(
        state_encryption_enabled = config.state_encryption.enabled,
        state_encryption_algorithm = %config.state_encryption.algorithm,
        state_encryption_nonce_size = config.state_encryption.nonce_size,
        state_encryption_key_size = config.state_encryption.key_size,
        "State encryption configuration"
    );
}

/// Verify security configuration consistency.
///
/// Performs validation checks to ensure the loaded security configuration
/// doesn't have dangerous or conflicting settings.
///
/// # Arguments
///
/// * `config` - The security configuration to validate
///
/// # Returns
///
/// Returns `Ok(())` if configuration is valid.
///
/// # Errors
///
/// Returns [`AuthError::ConfigError`] if `leak_sensitive_details` is `true`,
/// `auth_start_max_requests` is zero when rate limiting is enabled, or
/// `auth_start_window_secs` is zero when rate limiting is enabled.
pub fn validate_security_config(config: &SecurityConfigFromSchema) -> Result<()> {
    // Check if sensitive data leaking is disabled (security requirement)
    if config.error_sanitization.leak_sensitive_details {
        warn!("SECURITY WARNING: leak_sensitive_details is enabled! This is a security risk.");
        return Err(AuthError::ConfigError {
            message: "leak_sensitive_details must be false in production".to_string(),
        });
    }

    // Check rate limits are reasonable
    if config.rate_limiting.enabled {
        if config.rate_limiting.auth_start_max_requests == 0 {
            return Err(AuthError::ConfigError {
                message: "auth_start_max_requests must be greater than 0".to_string(),
            });
        }
        if config.rate_limiting.auth_start_window_secs == 0 {
            return Err(AuthError::ConfigError {
                message: "auth_start_window_secs must be greater than 0".to_string(),
            });
        }
    }

    // Check state encryption key size if enabled
    if config.state_encryption.enabled && config.state_encryption.key_size != 32 {
        warn!(
            "State encryption key size is {} bytes, expected 32 bytes for ChaCha20-Poly1305",
            config.state_encryption.key_size
        );
    }

    info!("Security configuration validation passed");
    Ok(())
}