//! `hive-subagent-daemon` binary — spawns nested claude sessions on
//! request and serves the `start`/`continue`/`interrupt` MCP tool surface
//! directly over streamable-http on `--http <addr>` — no stdio bridge, no
//! separate bin claude has to respawn every turn.

use std::sync::Arc;

use anyhow::Result;
use clap::Parser;

#[derive(Parser)]
#[command(
    name = "hive-subagent-daemon",
    about = "claude-subagent runner + MCP daemon"
)]
struct Cli {
    /// Serve the MCP tools over streamable-http on this address (e.g.
    /// `127.0.0.1:8793`). Bind loopback only.
    #[arg(long)]
    http: std::net::SocketAddr,
}

#[tokio::main]
async fn main() -> Result<()> {
    tracing_subscriber::fmt()
        .with_env_filter(
            tracing_subscriber::EnvFilter::try_from_env("RUST_LOG")
                .unwrap_or_else(|_| tracing_subscriber::EnvFilter::new("info")),
        )
        // This is a systemd-managed daemon — stdout always goes to journald,
        // never a human terminal, and journald doesn't strip ANSI escapes:
        // they land in victorialogs as raw byte-array spam otherwise.
        .with_ansi(false)
        .init();

    let cli = Cli::parse();
    let todo_socket = hive_subagent_mcp::paths::agent_socket();

    tracing::info!(
        http = %cli.http,
        todo = %todo_socket.display(),
        "hive-subagent-daemon starting"
    );

    let state = Arc::new(hive_subagent_mcp::session::State::new(todo_socket));

    // Serve the MCP tools over streamable-http forever. No background poll
    // loop to start — unlike the bash daemon's task-file queue, `start`/
    // `continue` spawn their subagent's background turn directly from the
    // tool call itself, nothing to scan for.
    hive_subagent_mcp::mcp::serve_http(cli.http, state).await
}