nighthawk 0.1.1

pub mod config;
pub mod engine;
pub mod fuzzy;
pub mod history;
pub mod server;
pub mod specs;

use crate::proto::Shell;
use engine::PredictionEngine;
use history::ShellHistory;
use std::sync::Arc;
use tracing_subscriber::EnvFilter;

/// Entry point for the nighthawk daemon process.
pub async fn run() -> Result<(), Box<dyn std::error::Error>> {
    // Load config
    let config = config::load_config(None);

    // Initialize tracing
    tracing_subscriber::fmt()
        .with_env_filter(
            EnvFilter::try_from_default_env()
                .unwrap_or_else(|_| EnvFilter::new(&config.daemon.log_level)),
        )
        .init();

    tracing::info!("Starting nighthawk daemon");

    // Build prediction tiers
    let mut tiers: Vec<Box<dyn engine::tier::PredictionTier>> = Vec::new();

    // Tier 0: History
    if config.tiers.enable_history {
        // TODO: support multi-shell history — lazily load per-shell keyed by req.shell
        let shell = Shell::detect_default();
        if let Ok(val) = std::env::var("NIGHTHAWK_SHELL") {
            if val.parse::<Shell>().is_err() {
                tracing::warn!(
                    "NIGHTHAWK_SHELL={val} is not recognized, falling back to {}",
                    shell.as_str()
                );
            }
        }
        tracing::info!("Default shell for history: {}", shell.as_str());
        let mut file_history = history::file::FileHistory::new(shell);
        if let Err(e) = file_history.load() {
            tracing::warn!("Failed to load history for {}: {e}", shell.as_str());
        }
        let history: Arc<tokio::sync::RwLock<dyn history::ShellHistory>> =
            Arc::new(tokio::sync::RwLock::new(file_history));
        tiers.push(Box::new(engine::history::HistoryTier::new(history)));
        tracing::debug!("History tier enabled");
    }

    // Tier 1: Specs
    if config.tiers.enable_specs {
        let specs_dir = std::env::var("NIGHTHAWK_SPECS_DIR")
            .map(std::path::PathBuf::from)
            .unwrap_or_else(|_| {
                dirs::config_dir()
                    .unwrap_or_else(|| std::path::PathBuf::from("."))
                    .join("nighthawk")
                    .join("specs")
            });

        tracing::info!("Loading specs from {}", specs_dir.display());

        let fig_provider = specs::fig::FigSpecProvider::new(specs_dir.clone());
        let help_cache_dir = specs_dir.join("help_cache");
        if let Err(e) = std::fs::create_dir_all(&help_cache_dir) {
            tracing::warn!("Failed to create help cache dir: {e}");
        }
        let help_provider = specs::helpparse::HelpParseProvider::new(
            help_cache_dir,
            tokio::runtime::Handle::current(),
        );

        let registry = Arc::new(specs::SpecRegistry::new(vec![
            Box::new(fig_provider),
            Box::new(help_provider),
        ]));

        tiers.push(Box::new(engine::specs::SpecTier::new(registry)));
        tracing::debug!("Spec tier enabled");
    }

    // Tier 2: Local LLM
    #[cfg(feature = "local-llm")]
    if config.tiers.enable_local_llm {
        let llm_config = config.local_llm.unwrap_or_default();
        tracing::info!(
            endpoint = %llm_config.endpoint,
            model = %llm_config.model,
            budget_ms = llm_config.budget_ms,
            "Local LLM tier enabled"
        );
        tiers.push(Box::new(engine::llm::LlmTier::new(llm_config)));
    }

    #[cfg(not(feature = "local-llm"))]
    if config.tiers.enable_local_llm {
        tracing::warn!(
            "enable_local_llm is set but nighthawk was compiled without the 'local-llm' feature. \
             Reinstall with: cargo install nighthawk --features local-llm"
        );
    }

    // Build engine
    let engine = Arc::new(PredictionEngine::new(tiers));

    // Determine socket path
    let socket_path = config
        .daemon
        .socket_path
        .map(|p| p.to_string_lossy().to_string())
        .unwrap_or_else(|| {
            crate::proto::default_socket_path()
                .to_string_lossy()
                .to_string()
        });

    // Run server
    server::run(engine, &socket_path).await?;

    Ok(())
}