nomos-node/nodes/node/binary/src/main.rs

use clap::Parser as _;
use color_eyre::eyre::{Result, eyre};
use lb_utils::yaml::{OnUnknownKeys, deserialize_value_at_path};
use logos_blockchain_node::{
    UserConfig,
    cli::{CliArgs, Command, build_run_config},
    config::deployment::DeploymentSettings,
    get_services_to_start, run_node_from_config,
};

#[tokio::main]
async fn main() -> Result<()> {
    #[cfg(feature = "dhat-heap")]
    let _dhat_drop_guard = logos_blockchain_node::global_allocators::dhat_heap::setup();

    let cli_args = CliArgs::parse();

    if let Some(command) = cli_args.command {
        match command {
            Command::InitConfig(init_args) => {
                return logos_blockchain_node::cli::config::init::run(*init_args);
            }
            Command::UpdateConfig(update_args) => {
                return logos_blockchain_node::cli::config::update::run(*update_args);
            }
            Command::MigrateConfig(migrate_args) => {
                return logos_blockchain_node::cli::config::migrate::run(*migrate_args);
            }
            Command::Migrate0_1_2(migrate_args) => {
                return logos_blockchain_node::cli::config::migrate_0_1_2::run(*migrate_args);
            }
            Command::GenerateKey(generate_args) => {
                return logos_blockchain_node::cli::keys::run_generate_key(*generate_args);
            }
            Command::AddKey(add_args) => {
                return logos_blockchain_node::cli::keys::run_add_key(*add_args);
            }
            Command::RemoveKey(remove_args) => {
                return logos_blockchain_node::cli::keys::run_remove_key(*remove_args);
            }
            Command::Inscribe(inscribe_args) => {
                lb_tui_zone::run_commands::run_inscribe::run_inscribe(inscribe_args).await;
                return Ok(());
            }
            Command::Participate(participate_args) => {
                return logos_blockchain_node::cli::participate::run(&participate_args);
            }
            Command::GetPeerId(get_peer_id_args) => {
                return logos_blockchain_node::cli::get_peer_id::run(&get_peer_id_args);
            }
        }
    }

    let is_dry_run = cli_args.dry_run();

    // If we are dry-running the binary, fail in case unknown keys in one of the
    // configs are found or exit successfully if deserializations succeed.
    if is_dry_run {
        // Check user config.
        drop(deserialize_value_at_path::<UserConfig>(
            cli_args.user_config_path(),
            OnUnknownKeys::Fail,
        )?);
        // If custom, check deployment config.
        if let Some(custom_deployment_path) = cli_args.deployment_config_path() {
            drop(deserialize_value_at_path::<DeploymentSettings>(
                custom_deployment_path,
                OnUnknownKeys::Fail,
            )?);
        }
        #[expect(
            clippy::non_ascii_literal,
            reason = "Use of green checkmark for better UX."
        )]
        {
            println!("Configs are valid! ✅");
        };
        // Early return since we are dry-running.
        return Ok(());
    }

    let run_config = {
        let user_config = deserialize_value_at_path::<UserConfig>(
            cli_args.user_config_path(),
            OnUnknownKeys::Fail,
        )
        .inspect_err(|e| {
            eprintln!("\nExiting... {e}.\n");
        })?;
        build_run_config(user_config, cli_args)?
    };

    let app = run_node_from_config(run_config, None)
        .map_err(|e| eyre!("{e}"))
        .inspect_err(|e| {
            eprintln!("\nExiting... {e}.\n");
        })?;
    let services_to_start = get_services_to_start(&app).await.inspect_err(|e| {
        eprintln!("\nExiting... {e}.\n");
    })?;

    app.handle()
        .start_service_sequence(services_to_start)
        .await
        .map_err(|e| eyre!("start_service_sequence failed: {e}"))
        .inspect_err(|e| {
            eprintln!("\nExiting... {e}.\n");
        })?;

    app.wait_finished().await;
    Ok(())
}