Function run_onboard_service

kms/src/main.rs:42–78

(kms_config: KmsConfig, figment: Figment)

}

async fn run_onboard_service(kms_config: KmsConfig, figment: Figment) -> Result<()> {
    use onboard_service::{OnboardHandler, OnboardState};

    #[rocket::get("/")]
    async fn index() -> RawHtml<&'static str> {
        RawHtml(include_str!("www/onboard.html"))
    }
    #[rocket::get("/finish")]
    fn finish(shutdown: Shutdown) -> &'static str {
        shutdown.notify();
        "OK"
    }

    if !kms_config.onboard.auto_bootstrap_domain.is_empty() {
        onboard_service::bootstrap_keys(&kms_config).await?;
        return Ok(());
    }

    let state = OnboardState::new(kms_config);
    let figment = figment
        .clone()
        .merge(Serialized::defaults(figment.find_value("core.onboard")?));

    // Remove section tls

    let _ = rocket::custom(figment)
        .mount("/", rocket::routes![index, finish])
        .mount(
            "/prpc",
            ra_rpc::prpc_routes!(OnboardState, OnboardHandler, trim: "Onboard."),
        )
        .manage(state)
        .launch()
        .await
        .map_err(|err| anyhow!(err.to_string()))?;
    Ok(())
}

#[rocket::get("/metrics")]
fn metrics(state: &State<KmsState>) -> RawText<String> {