🎨 format codes

Author: Cnily03

src/handlers.rs

@@ -109,7 +109,7 @@ pub async fn registry_v2_check(
 pub async fn auth_handler(
     State(state): State<Arc<AppState>>,
     Query(auth_req): Query<AuthRequest>,
-    headers: HeaderMap
+    headers: HeaderMap,
 ) -> impl IntoResponse {
     debug!(
         service = auth_req.service,
@@ -238,34 +238,48 @@ pub async fn auth_handler(
                 let mut scope_parts_clone = scope_parts.clone();
                 let library_scope = format!("library/{}", scope_parts_clone[1]);
                 scope_parts_clone[1] = &library_scope;
-                info!("Converted scope {} -> {}", auth_req.scope.clone().unwrap_or_default(), library_scope);
+                info!(
+                    "Converted scope {} -> {}",
+                    auth_req.scope.clone().unwrap_or_default(),
+                    library_scope
+                );
                 auth_req.scope = Some(scope_parts_clone.join(":"));
             } else {
                 // Check if user is admin of the specified game scope
                 match state.database.get_game_by_namespace(namespace).await {
                     Ok(Some(game)) => {
                         if !game.is_admin(user.id) {
-                            warn!("User '{}' is not admin of game {}: {}", username, game.id, game.bucket);
+                            warn!(
+                                "User '{}' is not admin of game {}: {}",
+                                username, game.id, game.bucket
+                            );
                             return create_error_response(
                                 StatusCode::UNAUTHORIZED,
                                 "Access denied",
                             );
                         }
                         let bucket_clone = game.bucket.clone();
                         if bucket_clone != namespace {
-                          // convert namespace from id to bucket
-                          let mut scope_image_parts = scope_image_parts.to_vec();
-                          scope_image_parts[0] = &bucket_clone;
-                          let mut scope_parts = scope_parts.to_vec();
-                          let scope_name = scope_image_parts.join("/");
-                          scope_parts[1] = &scope_name;
-                          let new_scope = scope_parts.join(":");
-                          info!("Converted scope {} -> {}", auth_req.scope.unwrap_or_default(), new_scope);
-                          auth_req.scope = Some(new_scope);
+                            // convert namespace from id to bucket
+                            let mut scope_image_parts = scope_image_parts.to_vec();
+                            scope_image_parts[0] = &bucket_clone;
+                            let mut scope_parts = scope_parts.to_vec();
+                            let scope_name = scope_image_parts.join("/");
+                            scope_parts[1] = &scope_name;
+                            let new_scope = scope_parts.join(":");
+                            info!(
+                                "Converted scope {} -> {}",
+                                auth_req.scope.unwrap_or_default(),
+                                new_scope
+                            );
+                            auth_req.scope = Some(new_scope);
                         }
                     }
                     Ok(None) => {
-                        warn!(user = username, "Game not found for namespace: {}", namespace);
+                        warn!(
+                            user = username,
+                            "Game not found for namespace: {}", namespace
+                        );
                         return create_error_response(StatusCode::UNAUTHORIZED, "Access denied");
                     }
                     Err(e) => {

src/middleware.rs

@@ -7,7 +7,7 @@ use axum::{
 };
 use jsonwebtoken::{decode, DecodingKey, Validation};
 use std::sync::Arc;
-use tracing::{debug, info, warn, error};
+use tracing::{debug, error, info, warn};
 
 use crate::{
     models::{Claims, ProxyContext},
@@ -24,7 +24,10 @@ impl AuthMiddleware {
         next: Next,
     ) -> Result<Response, StatusCode> {
         // Extract scope from path
-        let namespace = params.get("namespace").map(String::as_str).unwrap_or("library");
+        let namespace = params
+            .get("namespace")
+            .map(String::as_str)
+            .unwrap_or("library");
         let repository = params.get("repository").map(String::as_str).unwrap_or("_");
         if repository == "_" {
             return Err(StatusCode::FORBIDDEN);
@@ -39,10 +42,14 @@ impl AuthMiddleware {
                 if namespace != game.bucket {
                     info!("Translate namespace {} -> {}", namespace, game.bucket);
                     let uri = request.uri();
-                    let new_uri = uri.path_and_query().map(|pq| pq.as_str()).unwrap_or(uri.path()).replace(
-                        &format!("/v2/{}/{}/", namespace, repository),
-                        &format!("/v2/{}/{}/", game.bucket, repository)
-                    );
+                    let new_uri = uri
+                        .path_and_query()
+                        .map(|pq| pq.as_str())
+                        .unwrap_or(uri.path())
+                        .replace(
+                            &format!("/v2/{}/{}/", namespace, repository),
+                            &format!("/v2/{}/{}/", game.bucket, repository),
+                        );
 
                     // change request uri
                     debug!("Modify uri: {} -> {}", uri.path(), new_uri);
@@ -62,7 +69,6 @@ impl AuthMiddleware {
             }
         };
 
-
         let repo = format!("{}/{}", namespace, repository);
         debug!("Checking scope admin permission for scope: {}", repo);
 
@@ -151,18 +157,21 @@ impl AuthMiddleware {
             Some(_) => {}
             None => {
                 let uri = request.uri();
-                let new_uri = uri.path_and_query().map(|pq| pq.as_str()).unwrap_or(uri.path()).replace(
-                    &format!("/v2/{}/", repository),
-                    &format!("/v2/library/{}/", repository)
-                );
+                let new_uri = uri
+                    .path_and_query()
+                    .map(|pq| pq.as_str())
+                    .unwrap_or(uri.path())
+                    .replace(
+                        &format!("/v2/{}/", repository),
+                        &format!("/v2/library/{}/", repository),
+                    );
 
                 // change request uri
                 debug!("Modify uri: {} -> {}", uri.path(), new_uri);
                 *request.uri_mut() = axum::http::Uri::try_from(new_uri).unwrap();
             }
         }
 
-
         debug!("Checking library access for repository: {}", repository);
 
         // Check JWT token
@@ -247,4 +256,3 @@ impl AuthMiddleware {
         Err(StatusCode::UNAUTHORIZED)
     }
 }
-