pub async fn initialize_node(config: NodeConfig) -> Result<()> {
    let swarm = build_swarm(config.keypair)?;

    let metrics = MetricsRegistry::new();
    let db_pool = connect_db(&config.db_url).await?;

    if config.archive_mode {
        log::info!("Starting in archive mode");
        sync_historical_state(db_pool.clone()).await?;
    }

    loop {
        tokio::select! {
            event = swarm.next() => handle_p2p_event(event),
            _ = shutdown_signal() => break,
        }
    }

    Ok(())
}
_