Function schema

crates/client-api/src/routes/database.rs:531–566

(
    State(worker_ctx): State<S>,
    Path(SchemaParams { name_or_identity }): Path<SchemaParams>,
    Query(SchemaQueryParams { version }): Query<SchemaQueryParams>,
    Extension(auth): Extension<S

}

pub async fn schema<S>(
    State(worker_ctx): State<S>,
    Path(SchemaParams { name_or_identity }): Path<SchemaParams>,
    Query(SchemaQueryParams { version }): Query<SchemaQueryParams>,
    Extension(auth): Extension<SpacetimeAuth>,
) -> axum::response::Result<impl IntoResponse>
where
    S: ControlStateDelegate + NodeDelegate,
{
    let (leader, _) = find_leader_and_database(&worker_ctx, name_or_identity).await?;
    // Wait for the module to finish loading rather than returning an immediate
    // 500 error. The database may still be initializing (replaying the log,
    // running init reducers, etc.).
    let module = leader
        .wait_for_module(std::time::Duration::from_secs(10))
        .await
        .map_err(log_and_500)?;

    let module_def = &module.info.module_def;
    let response_json = match version {
        SchemaVersion::V9 => {
            let raw = RawModuleDefV9::from(module_def.as_ref().clone());
            axum::Json(sats::serde::SerdeWrapper(raw)).into_response()
        }
        SchemaVersion::V10 => {
            let raw = RawModuleDefV10::from(module_def.as_ref().clone());
            axum::Json(sats::serde::SerdeWrapper(raw)).into_response()
        }
    };

    Ok((
        TypedHeader(SpacetimeIdentity(auth.claims.identity)),
        TypedHeader(SpacetimeIdentityToken(auth.creds)),
        response_json,
    ))
}

#[derive(Deserialize)]
pub struct DatabaseParam {