agent-envoy 0.2.0

use std::net::SocketAddr;

use envoy::server;

#[tokio::main]
async fn main() {
    let db_path = std::env::var("ENVOY_DB").unwrap_or_else(|_| {
        let base = std::env::var("XDG_DATA_HOME")
            .map(std::path::PathBuf::from)
            .ok()
            .or_else(|| {
                std::env::var("HOME")
                    .ok()
                    .map(|h| std::path::PathBuf::from(h).join(".local").join("share"))
            })
            .unwrap_or_else(|| std::path::PathBuf::from("."));
        base.join("envoy")
            .join("server.db")
            .to_string_lossy()
            .into_owned()
    });

    // Ensure parent directory exists
    if let Some(parent) = std::path::Path::new(&db_path).parent() {
        std::fs::create_dir_all(parent).ok();
    }

    // Optional atheneum database path
    let atheneum_path = std::env::var("ATHENEUM_DB").ok();

    let port: u16 = std::env::var("ENVOY_PORT")
        .ok()
        .and_then(|p| p.parse().ok())
        .unwrap_or(9876);

    let addr: SocketAddr = ([127, 0, 0, 1], port).into();

    // Initialize Prometheus metrics recorder (idempotent via LazyLock)
    envoy::metrics::init();

    let result = if atheneum_path.is_some() {
        server::run_with_atheneum(&db_path, addr, atheneum_path).await
    } else {
        server::run(&db_path, addr).await
    };

    if let Err(e) = result {
        eprintln!("envoy server error: {e}");
        std::process::exit(1);
    }
}