Function reset

crates/client-api/src/routes/database.rs:833–877

(
    State(ctx): State<S>,
    Path(ResetDatabaseParams { name_or_identity }): Path<ResetDatabaseParams>,
    Query(ResetDatabaseQueryParams {
        num_replicas,
        host_type,
    }): Query<R

}

pub async fn reset<S: NodeDelegate + ControlStateDelegate + Authorization>(
    State(ctx): State<S>,
    Path(ResetDatabaseParams { name_or_identity }): Path<ResetDatabaseParams>,
    Query(ResetDatabaseQueryParams {
        num_replicas,
        host_type,
    }): Query<ResetDatabaseQueryParams>,
    Extension(auth): Extension<SpacetimeAuth>,
    program_bytes: Option<Bytes>,
) -> axum::response::Result<axum::Json<PublishResult>> {
    let database_identity = name_or_identity.resolve(&ctx).await?;
    let database = worker_ctx_find_database(&ctx, &database_identity)
        .await?
        .ok_or(NO_SUCH_DATABASE)?;

    ctx.authorize_action(auth.claims.identity, database.database_identity, Action::ResetDatabase)
        .await?;

    if ctx.is_database_locked(&database_identity).await.map_err(log_and_500)? {
        return Err((
            StatusCode::FORBIDDEN,
            "Database is locked and cannot be reset with --delete-data. Run `spacetime unlock` first.",
        )
            .into());
    }

    let num_replicas = num_replicas.map(validate_replication_factor).transpose()?.flatten();
    ctx.reset_database(
        &auth.claims.identity,
        DatabaseResetDef {
            database_identity,
            program_bytes,
            num_replicas,
            host_type: Some(host_type),
        },
    )
    .await
    .map_err(log_and_500)?;

    Ok(axum::Json(PublishResult::Success {
        domain: name_or_identity.name().cloned(),
        database_identity,
        op: PublishOp::Updated,
    }))
}

#[derive(Deserialize)]
pub struct PublishDatabaseParams {