diff options
author | rtkay123 <dev@kanjala.com> | 2025-08-14 18:13:31 +0200 |
---|---|---|
committer | rtkay123 <dev@kanjala.com> | 2025-08-14 18:13:31 +0200 |
commit | 5eed2d7a4a919b3583017aa9a65089673bce87db (patch) | |
tree | 75c525709907cd32f29544c3d6abf01b720957c1 /crates/configuration/src/server/http_svc/routes/routing/replace_routing.rs | |
parent | 1b8c6886f6d22f9c61e978b42d066dce91e334dc (diff) | |
download | warden-5eed2d7a4a919b3583017aa9a65089673bce87db.tar.bz2 warden-5eed2d7a4a919b3583017aa9a65089673bce87db.zip |
feat(config): routing mutation
Diffstat (limited to 'crates/configuration/src/server/http_svc/routes/routing/replace_routing.rs')
-rw-r--r-- | crates/configuration/src/server/http_svc/routes/routing/replace_routing.rs | 42 |
1 files changed, 42 insertions, 0 deletions
diff --git a/crates/configuration/src/server/http_svc/routes/routing/replace_routing.rs b/crates/configuration/src/server/http_svc/routes/routing/replace_routing.rs new file mode 100644 index 0000000..ccf184f --- /dev/null +++ b/crates/configuration/src/server/http_svc/routes/routing/replace_routing.rs @@ -0,0 +1,42 @@ +use axum::extract::{Path, State}; +use warden_core::configuration::routing::{ + RoutingConfiguration, UpdateRoutingRequest, mutate_routing_server::MutateRouting, +}; + +use crate::{ + server::{error::AppError, http_svc::TAG_ROUTING, version::Version}, + state::AppHandle, +}; + +/// Replace routing configuration +#[utoipa::path( + put, + responses(( + status = OK, + body = RoutingConfiguration + )), + path = "/{version}/routing/{id}", + params( + ("version" = Version, Path, description = "API version, e.g., v1, v2, v3"), + ("id" = String, Path, description = "Identifier for item to replace"), + ), + operation_id = "replace_routing_configuration", // https://github.com/juhaku/utoipa/issues/1170 + tag = TAG_ROUTING, + ) +] +#[axum::debug_handler] +#[tracing::instrument(skip(state))] +pub async fn replace( + State(state): State<AppHandle>, + Path(id): Path<String>, + axum::Json(body): axum::Json<RoutingConfiguration>, +) -> Result<axum::Json<RoutingConfiguration>, AppError> { + let response = state + .update_routing_configuration(tonic::Request::new(UpdateRoutingRequest { + id, + configuration: Some(body), + })) + .await? + .into_inner(); + Ok(axum::Json(response)) +} |