1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
use axum::{extract::State, response::IntoResponse};
use tonic::IntoRequest;
use warden_core::{
configuration::routing::{RoutingConfiguration, query_routing_server::QueryRouting},
google,
};
use crate::{
server::{error::AppError, http_svc::TAG_ROUTING, version::Version},
state::AppHandle,
};
#[utoipa::path(
get,
responses((
status = OK,
body = RoutingConfiguration
)),
operation_id = "get_active_routing", // 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 = "GET"))]
pub async fn active_routing(
version: Version,
State(state): State<AppHandle>,
) -> Result<impl IntoResponse, AppError> {
let config = state
.get_active_routing_configuration(google::protobuf::Empty::default().into_request())
.await?
.into_inner();
Ok(axum::Json(config.configuration).into_response())
}
|
