fqeat(api): catch internal panic

Author: BobAnkh

Cargo.lock

@@ -69,7 +69,7 @@ time = { version = "0.3.44", features = ["serde-human-readable"] }
 tokio = { workspace = true }
 tokio-tar = "0.3.1"
 tokio-util = { version = "0.7.16", features = ["rt"] }
-tower-http = { version = "0.6.6", features = ["cors"] }
+tower-http = { version = "0.6.6", features = ["cors", "catch-panic"] }
 tracing = { workspace = true }
 tracing-appender = "0.2.3"
 tracing-subscriber = { workspace = true }

netmito/Cargo.toml

@@ -24,6 +24,7 @@ use axum::{
 use http_body_util::BodyExt;
 use serde_json::json;
 use tokio_util::sync::CancellationToken;
+use tower_http::catch_panic::CatchPanicLayer;
 use tower_http::cors::CorsLayer;
 
 use crate::{
@@ -63,6 +64,7 @@ pub fn router(st: InfraPool, cancel_token: CancellationToken) -> Router {
             .nest("/tasks", tasks::tasks_router(st.clone()))
             .with_state(st)
             .layer(CorsLayer::permissive())
+            .layer(CatchPanicLayer::new())
     }
     #[cfg(feature = "debugging")]
     {
@@ -93,6 +95,7 @@ pub fn router(st: InfraPool, cancel_token: CancellationToken) -> Router {
             .nest("/tasks", tasks::tasks_router(st.clone()))
             .with_state(st)
             .layer(CorsLayer::permissive())
+            .layer(CatchPanicLayer::new())
             .layer(middleware::from_fn(print_request_addr))
             .layer(middleware::from_fn(print_request_response))
     }