Function main

cli/src/main.rs:60–101

()

#[tokio::main]
pub async fn main() -> anyhow::Result<()> {
    let cli = Cli::parse();

    match &cli.command {
        Some(Commands::Upload { name, path }) => {
            let content = std::fs::read(path)?;
            let coordinator = create_coordinator().await?;

            coordinator.upload_scenario(name.clone(), content).await??;
        }
        Some(Commands::Start {
            name,
            workers_number,
        }) => {
            let mut coordinator = create_coordinator().await?;
            commands::start(&mut coordinator, name, workers_number).await?;
        }
        Some(Commands::Workers { command }) => match &command {
            Some(WorkersCommands::List) => {
                let coordinator = create_coordinator().await?;
                let workers = coordinator.list_workers().await?;
                println!(
                    "Available workers list:\n{}",
                    workers
                        .iter()
                        .map(|w| format!("\t{w}\n"))
                        .collect::<Vec<String>>()
                        .join("")
                );
            }
            None => {}
        },
        Some(Commands::Run { path }) => {
            commands::run(path)
                .await
                .expect("An error while running a scenario");
        }
        None => {}
    }

    Ok(())
}