mi6_cli/

lib.rs

// CLI crate needs stdout/stderr for user interaction
#![allow(clippy::print_stdout, clippy::print_stderr)]

mod args;
pub mod commands;
pub mod display;
mod error;
mod help;
pub mod process;

pub use help::{print_command_help, print_help, print_subcommand_help};

use anyhow::{Context, Result};
use mi6_core::{Storage, StorageError, TranscriptScanner};

pub use args::{Cli, Commands, IngestCommands, OtelCommands, TuiArgs};

/// Result of running a CLI command.
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum RunResult {
    /// Command completed successfully
    Success,
    /// Command requests the process to exit with the given code
    ExitWithCode(i32),
    /// Caller should launch the TUI with the provided arguments
    RunTui(TuiArgs),
}

/// Run the CLI with a storage factory.
///
/// The factory is only called when a command needs storage.
/// Returns `RunResult::RunTui` when the TUI should be launched (caller handles this).
pub fn run<S, F>(cli: Cli, storage_factory: F) -> Result<RunResult>
where
    S: Storage,
    F: FnOnce() -> Result<S, StorageError>,
{
    // Handle TUI mode: either no command or explicit `tui` subcommand
    let command = match cli.command {
        None => return Ok(RunResult::RunTui(cli.tui_args)),
        Some(Commands::Tui(args)) => return Ok(RunResult::RunTui(args)),
        Some(cmd) => cmd,
    };

    match command {
        Commands::Tui(_) => unreachable!("handled above"),

        Commands::Enable {
            frameworks,
            local,
            settings_local,
            print,
            db_only,
            hooks_only,
            otel,
            otel_port,
            no_otel,
        } => {
            let result = commands::run_enable(commands::EnableCliOptions {
                frameworks,
                local,
                settings_local,
                print,
                db_only,
                hooks_only,
                otel,
                otel_port,
                no_otel,
            })?;

            if result.should_init_db
                && let Some(db_path) = result.db_path
            {
                let _ = storage_factory().context("failed to initialize storage")?;
                eprintln!("Database initialized at: {}", db_path.display());
            }

            if !print {
                eprintln!(
                    "\nRemember to reload hooks in your AI assistant to enable the new configuration."
                );
            }

            Ok(RunResult::Success)
        }

        Commands::Disable {
            frameworks,
            local,
            settings_local,
            print,
        } => {
            commands::run_disable(commands::DisableOptions {
                frameworks,
                local,
                settings_local,
                print,
            })?;
            Ok(RunResult::Success)
        }

        Commands::Ingest(ingest_cmd) => run_ingest(ingest_cmd, storage_factory),

        Commands::Session {
            session_or_pid,
            machine,
            json,
            fields,
        } => {
            let storage = storage_factory().context("failed to open storage")?;
            commands::run_session(&storage, session_or_pid, machine, json, fields)?;
            Ok(RunResult::Success)
        }

        Commands::Status { json } => {
            commands::run_status_command(json)?;
            Ok(RunResult::Success)
        }

        Commands::Watch {
            session,
            event_type,
            mode,
            framework,
            poll_ms,
        } => {
            let storage = storage_factory().context("failed to open storage")?;
            commands::run_watch(
                &storage,
                commands::WatchOptions {
                    session,
                    event_type,
                    permission_mode: mode,
                    framework,
                    poll_ms,
                },
            )?;
            Ok(RunResult::Success)
        }

        Commands::Gc { dry_run, retention } => {
            let storage = storage_factory().context("failed to open storage")?;
            commands::run_gc(&storage, dry_run, retention)?;
            Ok(RunResult::Success)
        }

        Commands::Otel(otel_cmd) => run_otel(otel_cmd, storage_factory),

        Commands::Upgrade {
            version,
            yes,
            dry_run,
        } => {
            commands::run_upgrade(commands::UpgradeOptions {
                version,
                yes,
                dry_run,
            })?;
            Ok(RunResult::Success)
        }

        Commands::Uninstall {
            confirm,
            keep_data,
            dry_run,
        } => {
            commands::run_uninstall(commands::UninstallOptions {
                confirm,
                keep_data,
                dry_run,
            })?;
            Ok(RunResult::Success)
        }
    }
}

/// Handle ingest subcommands.
fn run_ingest<S, F>(cmd: IngestCommands, storage_factory: F) -> Result<RunResult>
where
    S: Storage,
    F: FnOnce() -> Result<S, StorageError>,
{
    match cmd {
        IngestCommands::Event {
            event_type,
            json_payload,
            framework,
        } => {
            // The event ingest is called by AI assistant hooks during tool execution.
            // It must always exit 0 to avoid blocking the workflow, even if logging fails.
            // Errors are printed to stderr for debugging but don't affect the exit code.
            let result: Result<(), anyhow::Error> = (|| {
                let storage = storage_factory().context("failed to open storage")?;
                let log_result = commands::run_log(&storage, event_type, json_payload, framework)?;

                // Scan transcript file after every hook (if path is available)
                // This is cheap due to incremental position tracking
                if let Some(ref path) = log_result.transcript_path {
                    let scanner = TranscriptScanner::new(&storage, &log_result.machine_id);
                    let _ = scanner.scan_file(std::path::Path::new(path));

                    // Backfill initial prompt if the UserPromptSubmit hook didn't fire
                    // (e.g., when Claude is started with an inline prompt like `claude 'prompt'`)
                    let _ = scanner.backfill_initial_prompt(
                        &log_result.session_id,
                        std::path::Path::new(path),
                    );
                }
                Ok(())
            })();

            if let Err(e) = result {
                eprintln!("mi6: {:#}", e);
            }
            Ok(RunResult::ExitWithCode(0))
        }

        IngestCommands::Transcript { path } => {
            let storage = storage_factory().context("failed to open storage")?;
            commands::run_scan(&storage, &path)?;
            Ok(RunResult::Success)
        }

        IngestCommands::Otel => {
            let storage = storage_factory().context("failed to open storage")?;
            commands::run_otel_ingest(&storage)?;
            Ok(RunResult::Success)
        }
    }
}

/// Handle otel subcommands.
fn run_otel<S, F>(cmd: OtelCommands, storage_factory: F) -> Result<RunResult>
where
    S: Storage,
    F: FnOnce() -> Result<S, StorageError>,
{
    match cmd {
        OtelCommands::Start { port, mode } => {
            if commands::ensure_running(port, false, mode)? {
                eprintln!("OTel server is running on port {}", port);
            }
            Ok(RunResult::Success)
        }
        OtelCommands::Stop { port } => {
            commands::stop_server(port)?;
            Ok(RunResult::Success)
        }
        OtelCommands::Restart { port, mode } => {
            if commands::ensure_running(port, true, mode)? {
                eprintln!("OTel server restarted on port {}", port);
            }
            Ok(RunResult::Success)
        }
        OtelCommands::Status { port } => {
            commands::get_status(port)?;
            Ok(RunResult::Success)
        }
        OtelCommands::Run { port, mode } => {
            let storage = storage_factory().context("failed to open storage")?;
            commands::run_server(&storage, port, mode)?;
            Ok(RunResult::Success)
        }
    }
}