From 1b8c6886f6d22f9c61e978b42d066dce91e334dc Mon Sep 17 00:00:00 2001 From: rtkay123 Date: Thu, 14 Aug 2025 18:05:07 +0200 Subject: feat(config): rule grpc --- .../server/http_svc/routes/routing/get_active.rs | 1 + .../server/http_svc/routes/routing/post_routing.rs | 39 ++++++++++++++++++++++ 2 files changed, 40 insertions(+) create mode 100644 crates/configuration/src/server/http_svc/routes/routing/post_routing.rs (limited to 'crates/configuration/src/server/http_svc/routes/routing') diff --git a/crates/configuration/src/server/http_svc/routes/routing/get_active.rs b/crates/configuration/src/server/http_svc/routes/routing/get_active.rs index 9dc22e3..4875a80 100644 --- a/crates/configuration/src/server/http_svc/routes/routing/get_active.rs +++ b/crates/configuration/src/server/http_svc/routes/routing/get_active.rs @@ -10,6 +10,7 @@ use crate::{ state::AppHandle, }; +/// Get active routing configuration #[utoipa::path( get, responses(( diff --git a/crates/configuration/src/server/http_svc/routes/routing/post_routing.rs b/crates/configuration/src/server/http_svc/routes/routing/post_routing.rs new file mode 100644 index 0000000..3578b65 --- /dev/null +++ b/crates/configuration/src/server/http_svc/routes/routing/post_routing.rs @@ -0,0 +1,39 @@ +use axum::{extract::State, response::IntoResponse}; +use warden_core::configuration::routing::{ + RoutingConfiguration, mutate_routing_server::MutateRouting, +}; + +use crate::{ + server::{error::AppError, http_svc::TAG_ROUTING, version::Version}, + state::AppHandle, +}; + +/// Create routing configuration +#[utoipa::path( + post, + responses(( + status = CREATED, + body = RoutingConfiguration + )), + operation_id = "post_routing_configuration", // https://github.com/juhaku/utoipa/issues/1170 + path = "/{version}/routing", + params( + ("version" = Version, Path, description = "API version, e.g., v1, v2, v3") + ), + tag = TAG_ROUTING, +) +] +#[axum::debug_handler] +#[tracing::instrument(skip(state), err(Debug), fields(method = "POST"))] +pub async fn post_routing( + version: Version, + State(state): State, + axum::Json(body): axum::Json, +) -> Result { + let response = state + .create_routing_configuration(tonic::Request::new(body)) + .await? + .into_inner(); + + Ok((axum::http::StatusCode::CREATED, axum::Json(response))) +} -- cgit v1.2.3