@@ -149,10 +149,7 @@ async fn api_key_middleware(
149149 req : Request ,
150150 next : Next ,
151151) -> Result < axum:: response:: Response , ( StatusCode , Json < ErrorResponse > ) > {
152- let provided = req
153- . headers ( )
154- . get ( "X-Api-Key" )
155- . and_then ( |v| v. to_str ( ) . ok ( ) ) ;
152+ let provided = req. headers ( ) . get ( "X-Api-Key" ) . and_then ( |v| v. to_str ( ) . ok ( ) ) ;
156153
157154 match provided {
158155 Some ( key) if key. as_bytes ( ) . ct_eq ( state. api_key ( ) . as_bytes ( ) ) . into ( ) => {
@@ -174,7 +171,10 @@ pub fn create_router(state: Arc<ServerState>) -> Router {
174171 let protected = Router :: new ( )
175172 . route ( "/route" , get ( route_handler) )
176173 . route ( "/info" , get ( info_handler) )
177- . layer ( middleware:: from_fn_with_state ( state. clone ( ) , api_key_middleware) ) ;
174+ . layer ( middleware:: from_fn_with_state (
175+ state. clone ( ) ,
176+ api_key_middleware,
177+ ) ) ;
178178
179179 Router :: new ( )
180180 . route ( "/health" , get ( health_handler) )
@@ -277,7 +277,9 @@ mod tests {
277277 . unwrap ( ) ;
278278 let resp = app. oneshot ( req) . await . unwrap ( ) ;
279279 assert_eq ! ( resp. status( ) , HyperStatus :: UNAUTHORIZED ) ;
280- let body = axum:: body:: to_bytes ( resp. into_body ( ) , usize:: MAX ) . await . unwrap ( ) ;
280+ let body = axum:: body:: to_bytes ( resp. into_body ( ) , usize:: MAX )
281+ . await
282+ . unwrap ( ) ;
281283 let json: serde_json:: Value = serde_json:: from_slice ( & body) . unwrap ( ) ;
282284 assert_eq ! ( json, serde_json:: json!( { "error" : "unauthorized" } ) ) ;
283285 }
0 commit comments