asupersync 0.3.1

//! CLI utilities for Asupersync tools.
//!
//! This module provides a comprehensive framework for building CLI tools that are
//! both human-friendly and machine-readable. Key features:
//!
//! - **Dual-mode output**: Automatic JSON/human output based on environment
//! - **Structured errors**: RFC 9457-style errors with context and suggestions
//! - **Semantic exit codes**: Machine-parseable exit codes for automation
//! - **Progress reporting**: Streaming progress with cancellation support
//! - **Signal handling**: Graceful shutdown with cancellation tokens
//! - **Shell completions**: Generation for bash, zsh, fish, PowerShell, elvish
//!
//! # Quick Start
//!
//! ```rust,ignore
//! use asupersync::cli::{Output, OutputFormat, CliError, ExitCode};
//!
//! // Auto-detect output format (JSON in CI/pipes, human in terminal)
//! let format = OutputFormat::auto_detect();
//! let mut output = Output::new(format);
//!
//! // Write structured output
//! output.write(&my_data)?;
//!
//! // Handle errors with context
//! let error = CliError::new("config_error", "Invalid configuration")
//!     .detail("The 'timeout' field must be a positive integer")
//!     .suggestion("Set timeout to a value like 30 or 60")
//!     .context("field", "timeout")
//!     .exit_code(ExitCode::USER_ERROR);
//! ```
//!
//! # Output Format Detection
//!
//! The output format is automatically detected based on:
//! 1. `ASUPERSYNC_OUTPUT_FORMAT` environment variable
//! 2. `CI` environment variable (forces JSON)
//! 3. TTY detection (JSON for pipes, human for terminals)
//!
//! # Color Support
//!
//! Colors are automatically enabled for terminals and respect:
//! - `NO_COLOR` environment variable (disables colors)
//! - `CLICOLOR_FORCE` environment variable (forces colors)
//!
//! # Exit Codes
//!
//! Standard exit codes for automation:
//! - 0: Success
//! - 1: User error (bad input)
//! - 2: Runtime error
//! - 3: Internal error (bug)
//! - 4: Cancelled
//! - 5: Partial success
//! - 10-13: Application-specific (test failure, oracle violation, etc.)

pub mod args;
pub mod completion;
pub mod doctor;
pub mod error;
pub mod exit;
pub mod output;
pub mod progress;
pub mod signal;

// Re-export commonly used types
pub use args::{COMMON_ARGS_HELP, CommonArgs, parse_color_choice, parse_output_format};
pub use completion::{Completable, CompletionItem, Shell, generate_completions};
pub use doctor::{
    CapabilityEdge, ContractCompatibility, ContractErrorEnvelope, CoreDiagnosticsCommand,
    CoreDiagnosticsEvidence, CoreDiagnosticsFinding, CoreDiagnosticsFixture,
    CoreDiagnosticsProvenance, CoreDiagnosticsReport, CoreDiagnosticsReportBundle,
    CoreDiagnosticsReportContract, CoreDiagnosticsSummary, CorrelationPrimitiveSpec, DecisionLoop,
    DecisionStep, EvidenceIngestionReport, EvidenceProvenance, EvidenceRecord, ExchangeOutcome,
    IngestionEvent, InvariantAnalyzerReport, InvariantFinding, InvariantRuleTrace,
    LockContentionAnalyzerReport, LockContentionHotspot, LockContentionRuleTrace,
    LockOrderViolation, LoggingFieldSpec, LoggingFlowSpec, MigrationGuidance,
    OperatorModelContract, OperatorPersona, PayloadField, PayloadSchema, RejectedArtifact,
    RejectedPayloadLog, RemediationConfidenceInput, RemediationConfidenceScore,
    RemediationConfidenceWeight, RemediationPrecondition, RemediationRecipe,
    RemediationRecipeBundle, RemediationRecipeContract, RemediationRecipeFixture,
    RemediationRiskBand, RemediationRollbackPlan, RuntimeArtifact, ScanEvent, ScreenContract,
    ScreenEngineContract, ScreenExchangeEnvelope, ScreenExchangeRequest, StateTransition,
    StructuredLogEvent, StructuredLoggingContract, WorkspaceMember, WorkspaceScanReport,
    analyze_workspace_invariants, analyze_workspace_lock_contention,
    compute_remediation_confidence_score, core_diagnostics_report_bundle,
    core_diagnostics_report_contract, core_diagnostics_report_fixtures,
    emit_lock_contention_structured_events, emit_structured_log_event, ingest_runtime_artifacts,
    is_screen_contract_version_supported, operator_model_contract, parse_remediation_recipe,
    remediation_recipe_bundle, remediation_recipe_contract, remediation_recipe_fixtures,
    run_core_diagnostics_report_smoke, run_remediation_recipe_smoke, run_structured_logging_smoke,
    scan_workspace, screen_engine_contract, simulate_screen_exchange, structured_logging_contract,
    validate_core_diagnostics_report, validate_core_diagnostics_report_contract,
    validate_evidence_ingestion_report, validate_operator_model_contract,
    validate_remediation_recipe, validate_remediation_recipe_contract,
    validate_screen_engine_contract, validate_structured_log_event,
    validate_structured_logging_contract, validate_structured_logging_event_stream,
};
pub use error::{CliError, errors};
pub use exit::ExitCode;
pub use output::{ColorChoice, Output, OutputFormat, Outputtable};
pub use progress::{ProgressEvent, ProgressKind, ProgressReporter};
pub use signal::{CancellationToken, Signal, SignalHandler};

/// Prelude for convenient imports.
///
/// ```rust,ignore
/// use asupersync::cli::prelude::*;
/// ```
pub mod prelude {
    pub use super::args::{COMMON_ARGS_HELP, CommonArgs};
    pub use super::doctor::{
        CapabilityEdge, ContractCompatibility, ContractErrorEnvelope, CoreDiagnosticsCommand,
        CoreDiagnosticsEvidence, CoreDiagnosticsFinding, CoreDiagnosticsFixture,
        CoreDiagnosticsProvenance, CoreDiagnosticsReport, CoreDiagnosticsReportBundle,
        CoreDiagnosticsReportContract, CoreDiagnosticsSummary, CorrelationPrimitiveSpec,
        DecisionLoop, DecisionStep, EvidenceIngestionReport, EvidenceProvenance, EvidenceRecord,
        ExchangeOutcome, IngestionEvent, InvariantAnalyzerReport, InvariantFinding,
        InvariantRuleTrace, LockContentionAnalyzerReport, LockContentionHotspot,
        LockContentionRuleTrace, LockOrderViolation, LoggingFieldSpec, LoggingFlowSpec,
        MigrationGuidance, OperatorModelContract, OperatorPersona, PayloadField, PayloadSchema,
        RejectedArtifact, RejectedPayloadLog, RemediationConfidenceInput,
        RemediationConfidenceScore, RemediationConfidenceWeight, RemediationPrecondition,
        RemediationRecipe, RemediationRecipeBundle, RemediationRecipeContract,
        RemediationRecipeFixture, RemediationRiskBand, RemediationRollbackPlan, RuntimeArtifact,
        ScanEvent, ScreenContract, ScreenEngineContract, ScreenExchangeEnvelope,
        ScreenExchangeRequest, StateTransition, StructuredLogEvent, StructuredLoggingContract,
        WorkspaceMember, WorkspaceScanReport, analyze_workspace_invariants,
        analyze_workspace_lock_contention, compute_remediation_confidence_score,
        core_diagnostics_report_bundle, core_diagnostics_report_contract,
        core_diagnostics_report_fixtures, emit_lock_contention_structured_events,
        emit_structured_log_event, ingest_runtime_artifacts, is_screen_contract_version_supported,
        operator_model_contract, parse_remediation_recipe, remediation_recipe_bundle,
        remediation_recipe_contract, remediation_recipe_fixtures,
        run_core_diagnostics_report_smoke, run_remediation_recipe_smoke,
        run_structured_logging_smoke, scan_workspace, screen_engine_contract,
        simulate_screen_exchange, structured_logging_contract, validate_core_diagnostics_report,
        validate_core_diagnostics_report_contract, validate_evidence_ingestion_report,
        validate_operator_model_contract, validate_remediation_recipe,
        validate_remediation_recipe_contract, validate_screen_engine_contract,
        validate_structured_log_event, validate_structured_logging_contract,
        validate_structured_logging_event_stream,
    };
    pub use super::error::{CliError, errors};
    pub use super::exit::ExitCode;
    pub use super::output::{ColorChoice, Output, OutputFormat, Outputtable};
    pub use super::progress::{ProgressEvent, ProgressReporter};
    pub use super::signal::{CancellationToken, SignalHandler};
}

#[cfg(test)]
mod tests {
    use super::*;
    use serde::Serialize;
    use std::io::Cursor;

    #[derive(Serialize)]
    struct TestData {
        value: i32,
    }

    impl Outputtable for TestData {
        fn human_format(&self) -> String {
            format!("Value: {}", self.value)
        }
    }

    struct TestCmd;

    impl Completable for TestCmd {
        fn command_name(&self) -> &'static str {
            "test"
        }

        fn subcommands(&self) -> Vec<CompletionItem> {
            vec![CompletionItem::new("run")]
        }

        fn global_options(&self) -> Vec<CompletionItem> {
            vec![CompletionItem::new("--help")]
        }

        fn subcommand_options(&self, subcommand: &str) -> Vec<CompletionItem> {
            if subcommand == "run" {
                vec![CompletionItem::new("--dry-run")]
            } else {
                vec![]
            }
        }
    }

    fn init_test(name: &str) {
        crate::test_utils::init_test_logging();
        crate::test_phase!(name);
    }

    #[test]
    fn prelude_exports_work() {
        init_test("prelude_exports_work");
        // Verify prelude exports compile
        let _ = ExitCode::SUCCESS;
        let _ = OutputFormat::Human;
        let _ = ColorChoice::Auto;
        crate::test_complete!("prelude_exports_work");
    }

    #[test]
    fn error_integration() {
        init_test("error_integration");
        // Test that error module integrates with exit codes
        let error = errors::invalid_argument("test", "invalid");
        crate::assert_with_log!(
            error.exit_code == ExitCode::USER_ERROR,
            "exit_code",
            ExitCode::USER_ERROR,
            error.exit_code
        );
        crate::test_complete!("error_integration");
    }

    #[test]
    fn output_integration() {
        init_test("output_integration");

        let cursor = Cursor::new(Vec::new());
        let mut output = Output::with_writer(OutputFormat::Json, cursor);
        let data = TestData { value: 42 };
        output.write(&data).unwrap();
        crate::test_complete!("output_integration");
    }

    #[test]
    fn signal_integration() {
        init_test("signal_integration");
        let handler = SignalHandler::new();
        let token = handler.cancellation_token();

        let cancelled = token.is_cancelled();
        crate::assert_with_log!(!cancelled, "token not cancelled", false, cancelled);
        let _ = handler.record_signal();
        let cancelled = token.is_cancelled();
        crate::assert_with_log!(cancelled, "token cancelled", true, cancelled);
        crate::test_complete!("signal_integration");
    }

    #[test]
    fn completion_integration() {
        init_test("completion_integration");
        let mut buf = Vec::new();
        generate_completions(Shell::Bash, &TestCmd, &mut buf).unwrap();
        let output = String::from_utf8(buf).unwrap();
        let contains = output.contains("test");
        crate::assert_with_log!(contains, "contains test", true, contains);
        let has_subcommand_option = output.contains("--dry-run");
        crate::assert_with_log!(
            has_subcommand_option,
            "contains subcommand option",
            true,
            has_subcommand_option
        );
        crate::test_complete!("completion_integration");
    }
}