serv/conduit
1
0
Fork 0
mirror of https://gitlab.com/famedly/conduit.git synced 2025-01-28 19:55:58 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: let requests continue event if client disconnects

Browse source
This commit is contained in:
Timo Kösters 2023-03-17 22:44:50 +01:00
parent 664ee7d89a
commit da3871f39a
No known key found for this signature in database
GPG key ID: 0B25E636FBA7E4CB
1 changed files with 10 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/main.rs
View file

@ -147,6 +147,7 @@ async fn run_server() -> io::Result<()> {
let middlewares = ServiceBuilder::new() let middlewares = ServiceBuilder::new()
.sensitive_headers([header::AUTHORIZATION]) .sensitive_headers([header::AUTHORIZATION])
.layer(axum::middleware::from_fn(spawn_task))
.layer( .layer(
TraceLayer::new_for_http().make_span_with(|request: &http::Request<_>| { TraceLayer::new_for_http().make_span_with(|request: &http::Request<_>| {
let path = if let Some(path) = request.extensions().get::<MatchedPath>() { let path = if let Some(path) = request.extensions().get::<MatchedPath>() {
@ -221,6 +222,15 @@ async fn run_server() -> io::Result<()> {
Ok(()) Ok(())
} }
async fn spawn_task<B: Send + 'static>(
req: axum::http::Request<B>,
next: axum::middleware::Next<B>,
) -> std::result::Result<axum::response::Response, StatusCode> {
tokio::spawn(next.run(req))
.await
.map_err(|_| StatusCode::INTERNAL_SERVER_ERROR)
}
async fn unrecognized_method<B>( async fn unrecognized_method<B>(
req: axum::http::Request<B>, req: axum::http::Request<B>,
next: axum::middleware::Next<B>, next: axum::middleware::Next<B>,