Function async_main

supervisor/src/main.rs:118–161

(args: Args)

#[tokio::main]
async fn async_main(args: Args) -> Result<()> {
    let mut figment = load_config_figment(args.config.as_deref());
    if let Some(uds) = args.uds {
        mk_parents(&uds)?;
        if args.remove_existing_uds {
            fs_err::remove_file(&uds).ok();
        }
        figment = figment.join(("address", format!("unix:{uds}")));
    } else if let Some(address) = args.address {
        figment = figment.join(("address", address));
    }
    if let Some(port) = args.port {
        figment = figment.join(("port", port));
    }
    let rocket = web_api::rocket(figment);
    let rocket = rocket.attach(AdHoc::on_response("Add app version header", |_req, res| {
        Box::pin(async move {
            res.set_raw_header("X-App-Version", app_version());
        })
    }));
    let ignite = rocket
        .ignite()
        .await
        .map_err(|err| anyhow!("{err:?}"))
        .context("Failed to ignite rocket")?;
    let endpoint = DefaultListener::bind_endpoint(&ignite)
        .map_err(|err| anyhow!("{err:?}"))
        .context("Failed to get endpoint")?;
    let listener = DefaultListener::bind(&ignite)
        .await
        .map_err(|err| anyhow!("{err:?}"))
        .context(format!("Failed to bind on {endpoint}"))?;
    if let Some(pid_file) = &args.pid_file {
        mk_parents(pid_file)?;
        let pid = std::process::id();
        fs_err::write(pid_file, pid.to_string()).context("Failed to write pid file")?;
    }
    ignite
        .launch_on(listener)
        .await
        .map_err(|err| anyhow!("{err:?}"))
        .context("Failed to launch rocket")?;
    Ok(())
}

fn mk_parents(path: impl AsRef<Path>) -> Result<()> {
    let path = path.as_ref();