use builder::{

config::BuilderConfig,

service::serve_builder,

tasks::{block::sim::Simulator, metrics::MetricsTask, submit::SubmitTask},

};

use init4_bin_base::{

deps::tracing::{info, info_span},

utils::from_env::FromEnv,

};

use signet_types::constants::SignetSystemConstants;

use tokio::select;

// Note: Must be set to `multi_thread` to support async tasks.

// See: https://docs.rs/tokio/latest/tokio/attr.main.html

#[tokio::main(flavor = "multi_thread")]

async fn main() -> eyre::Result<()> {

let _guard = init4_bin_base::init4();

let init_span_guard = info_span!("builder initialization");

// Pull the configuration from the environment

let config = BuilderConfig::from_env()?.clone();

let constants = SignetSystemConstants::pecorino();

// Spawn the EnvTask

let env_task = config.env_task().await;

let (block_env, env_jh) = env_task.spawn();

// Spawn the cache system

let cache_system = config.spawn_cache_system(block_env.clone());

// Prep providers and contracts

let (host_provider, quincey) =

tokio::try_join!(config.connect_host_provider(), config.connect_quincey())?;

let ru_provider = config.connect_ru_provider();

let zenith = config.connect_zenith(host_provider.clone());

// Set up the metrics task

let metrics = MetricsTask { host_provider };

let (tx_channel, metrics_jh) = metrics.spawn();

// Make a Tx submission task

let submit =

SubmitTask { zenith, quincey, config: config.clone(), outbound_tx_channel: tx_channel };

// Set up tx submission

let (submit_channel, submit_jh) = submit.spawn();

// Set up the simulator

let sim = Simulator::new(&config, ru_provider.clone(), block_env);

let build_jh = sim.spawn_simulator_task(constants, cache_system.sim_cache, submit_channel);

// Start the healthcheck server

let server = serve_builder(([0, 0, 0, 0], config.builder_port));

// We have finished initializing the builder, so we can drop the init span

// guard.

drop(init_span_guard);

select! {

_ = env_jh => {

info!("env task finished");

},

_ = cache_system.cache_task => {

info!("cache task finished");

},

_ = cache_system.tx_poller => {

info!("tx_poller finished");

},

_ = cache_system.bundle_poller => {

info!("bundle_poller finished");

},

_ = submit_jh => {

info!("submit finished");

},

_ = metrics_jh => {

info!("metrics finished");

},

_ = build_jh => {

info!("build finished");

}

_ = server => {

info!("server finished");

}

}

info!("shutting down");

Ok(())

}