From 97be7b38fa3bd3172895f6ab44157e5236d65cd6 Mon Sep 17 00:00:00 2001 From: Alex Auvolat Date: Sat, 1 Feb 2025 19:35:00 +0100 Subject: [PATCH] admin api: reorder things --- src/api/admin/api_server.rs | 66 ++++++++++++++++++------------------- 1 file changed, 32 insertions(+), 34 deletions(-) diff --git a/src/api/admin/api_server.rs b/src/api/admin/api_server.rs index ecc538e4..1ab81be3 100644 --- a/src/api/admin/api_server.rs +++ b/src/api/admin/api_server.rs @@ -110,8 +110,6 @@ pub enum HttpEndpoint { New(String), } -struct ArcAdminApiServer(Arc); - impl AdminApiServer { pub fn new( garage: Arc, @@ -146,39 +144,7 @@ impl AdminApiServer { .run_server(bind_addr, Some(0o220), must_exit) .await } -} -#[async_trait] -impl ApiHandler for ArcAdminApiServer { - const API_NAME: &'static str = "admin"; - const API_NAME_DISPLAY: &'static str = "Admin"; - - type Endpoint = HttpEndpoint; - type Error = Error; - - fn parse_endpoint(&self, req: &Request) -> Result { - if req.uri().path().starts_with("/v0/") { - let endpoint_v0 = router_v0::Endpoint::from_request(req)?; - let endpoint_v1 = router_v1::Endpoint::from_v0(endpoint_v0)?; - Ok(HttpEndpoint::Old(endpoint_v1)) - } else if req.uri().path().starts_with("/v1/") { - let endpoint_v1 = router_v1::Endpoint::from_request(req)?; - Ok(HttpEndpoint::Old(endpoint_v1)) - } else { - Ok(HttpEndpoint::New(req.uri().path().to_string())) - } - } - - async fn handle( - &self, - req: Request, - endpoint: HttpEndpoint, - ) -> Result, Error> { - self.0.handle_http_api(req, endpoint).await - } -} - -impl AdminApiServer { async fn handle_http_api( &self, req: Request, @@ -228,6 +194,38 @@ impl AdminApiServer { } } +struct ArcAdminApiServer(Arc); + +#[async_trait] +impl ApiHandler for ArcAdminApiServer { + const API_NAME: &'static str = "admin"; + const API_NAME_DISPLAY: &'static str = "Admin"; + + type Endpoint = HttpEndpoint; + type Error = Error; + + fn parse_endpoint(&self, req: &Request) -> Result { + if req.uri().path().starts_with("/v0/") { + let endpoint_v0 = router_v0::Endpoint::from_request(req)?; + let endpoint_v1 = router_v1::Endpoint::from_v0(endpoint_v0)?; + Ok(HttpEndpoint::Old(endpoint_v1)) + } else if req.uri().path().starts_with("/v1/") { + let endpoint_v1 = router_v1::Endpoint::from_request(req)?; + Ok(HttpEndpoint::Old(endpoint_v1)) + } else { + Ok(HttpEndpoint::New(req.uri().path().to_string())) + } + } + + async fn handle( + &self, + req: Request, + endpoint: HttpEndpoint, + ) -> Result, Error> { + self.0.handle_http_api(req, endpoint).await + } +} + impl ApiEndpoint for HttpEndpoint { fn name(&self) -> Cow<'static, str> { match self {