chore: refactored dav_file to use async file traits

Author: Nicolas Pernoud

backend/Cargo.toml

@@ -16,13 +16,13 @@ argon2 = { features = ["alloc", "password-hash"], default-features = false, vers
 async_zip = { features = ["deflate", "tokio"], default-features = false, version = "0.0.18" }
 async-stream = "0.3.6"
 async-walkdir = "2.1.0"
-aws-lc-rs = { version = "1.13.3", default-features = false, features = ["bindgen"] }
-axum = { version = "0.8.4", features = ["http2", "json", "query", "tokio"], default-features = false }
-axum-extra = { version = "0.10.1", features = ["cookie-private", "typed-header"], default-features = false }
+aws-lc-rs = { version = "1.14.1", default-features = false, features = ["bindgen"] }
+axum = { version = "0.8.6", features = ["http2", "json", "query", "tokio"], default-features = false }
+axum-extra = { version = "0.10.3", features = ["cookie-private", "typed-header"], default-features = false }
 axum-server = { version = "0.7.2", default-features = false, features = ["tls-rustls"] }
 base64ct = { version = "1.8.0", features = ["alloc"] }
 chacha20poly1305 = { version = "0.10.1", features = ["stream"], default-features = false }
-chrono = { default-features = false, version = "0.4.41" }
+chrono = { default-features = false, version = "0.4.42" }
 filetime = "0.2.26"
 futures = { default-features = false, version = "0.3.31" }
 futures-util = { default-features = false, version = "0.3.31" }
@@ -32,24 +32,24 @@ http-body-util = "0.1.3"
 hyper = { version = "1.7.0", default-features = false }
 hyper-hickory = { version = "0.8.0", default-features = false, features = ["system-config", "tokio"] }
 hyper-rustls = { version = "0.27.7", features = ["aws-lc-rs", "http1", "http2", "tls12", "webpki-tokio"], default-features = false }
-hyper-util = { version = "0.1.16", features = ["client-legacy", "http1", "tokio"], default-features = false }
-jsonwebtoken-aws-lc = { version = "9.3.0", default-features = false }
+hyper-util = { version = "0.1.17", features = ["client-legacy", "http1", "tokio"], default-features = false }
+jsonwebtoken = { version = "10", features = ["aws_lc_rs"], default-features = false }
 maxminddb = "0.26.0"
 mime_guess = { default-features = false, version = "2.0.5" }
 oauth2 = { version = "5.0.0", default-features = false }
 percent-encoding = { default-features = false, version = "2.3.2" }
 quick-xml = "0.38.3"
 rand = { default-features = false, version = "0.9.2", features = ["os_rng"] }
-rcgen = { version = "0.14.3", default-features = false, optional = true, features = ["aws_lc_rs", "crypto", "pem"] }
-rustls = { default-features = false, version = "0.23.31", features = ["aws_lc_rs"] }
-rustls-acme = { version = "0.14.0", features = ["aws-lc-rs", "axum", "webpki-roots"], default-features = false }
+rcgen = { version = "0.14.5", default-features = false, optional = true, features = ["aws_lc_rs", "crypto", "pem"] }
+rustls = { default-features = false, version = "0.23.32", features = ["aws_lc_rs"] }
+rustls-acme = { version = "0.14.1", features = ["aws-lc-rs", "axum", "webpki-roots"], default-features = false }
 rustls-pki-types = { version = "1.12.0" }
-serde = { version = "1.0.219", default-features = false }
-serde_json = { default-features = false, version = "1.0.143" }
+serde = { version = "1.0.228", default-features = false }
+serde_json = { default-features = false, version = "1.0.145" }
 serde_yaml_ng = "0.10.0"
 sha2 = { default-features = false, version = "0.10.9" }
-sysinfo = { default-features = false, version = "0.37.0", features = ["disk", "system"] }
-time = { default-features = false, version = "0.3.41" }
+sysinfo = { default-features = false, version = "0.37.2", features = ["disk", "system"] }
+time = { default-features = false, version = "0.3.44" }
 tokio = { version = "1.47.1", features = ["full"], default-features = false }
 tokio-stream = { version = "0.1.17", default-features = false }
 tokio-util = { version = "0.7.16", default-features = false }
@@ -58,10 +58,10 @@ tower-http = { version = "0.6.6", features = ["fs"], default-features = false }
 tower-service = "0.3.3"
 tracing = { default-features = false, version = "0.1.41", features = ["attributes"] }
 tracing-appender = "0.2.3"
-tracing-subscriber = { version = "0.3.19", features = ["ansi", "env-filter", "local-time"], default-features = false }
+tracing-subscriber = { version = "0.3.20", features = ["ansi", "env-filter", "local-time"], default-features = false }
 trim-in-place = "0.1.7"
 urlencoding = "2.1.3"
-uuid = { version = "1.18.0", features = ["fast-rng", "v4"], default-features = false }
+uuid = { version = "1.18.1", features = ["fast-rng", "v4"], default-features = false }
 
 [features]
 default = ["self_signed"]
@@ -70,6 +70,7 @@ self_signed = ["dep:rcgen"]
 [dev-dependencies]
 async-tungstenite = { version = "0.31.0", features = ["tokio-runtime"] }
 reqwest = { version = "0.12.23", default-features = false, features = ["cookies", "json", "native-tls", "stream"] }
+tempfile = "3.23.0"
 tungstenite = "0.27.0"
 
 [profile.release_optimized]

backend/src/apps/mod.rs

@@ -194,43 +194,43 @@ where
     .await?;
 
     // If the response contains a location, alter the redirect location if the redirection is relative to the proxied host
-    if let Some(location) = response.headers().get("location") {
-        if let Ok(location) = location.to_str() {
-            // parse location as an url
-            let location_uri: Uri = match location.trim_start_matches('.').parse() {
-                Ok(uri) => uri,
-                Err(_) => {
-                    // Try to add a forward slash
-                    match format!("/{location}").parse() {
-                        Ok(uri) => uri,
-                        Err(e) => {
-                            error!(
-                                "proxy redirect location header parsing for {:?} gave error: {:?}",
-                                location, e
-                            );
-                            return Err(<ProxyError as Into<axum::response::Response>>::into(
-                                ProxyError::BadRedirectResponseError,
-                            ));
-                        }
+    if let Some(location) = response.headers().get("location")
+        && let Ok(location) = location.to_str()
+    {
+        // parse location as an url
+        let location_uri: Uri = match location.trim_start_matches('.').parse() {
+            Ok(uri) => uri,
+            Err(_) => {
+                // Try to add a forward slash
+                match format!("/{location}").parse() {
+                    Ok(uri) => uri,
+                    Err(e) => {
+                        error!(
+                            "proxy redirect location header parsing for {:?} gave error: {:?}",
+                            location, e
+                        );
+                        return Err(<ProxyError as Into<axum::response::Response>>::into(
+                            ProxyError::BadRedirectResponseError,
+                        ));
                     }
                 }
-            };
-            // test if the host of this url contains the target service host
-            if location_uri
-                .host()
-                .is_some_and(|h| h.contains(app.forward_authority.host()))
+            }
+        };
+        // test if the host of this url contains the target service host
+        if location_uri
+            .host()
+            .is_some_and(|h| h.contains(app.forward_authority.host()))
+        {
+            // if so, replace the target service host with the front service host
+            let mut parts = location_uri.into_parts();
+            parts.scheme = Some(app.app_scheme);
+            if let Ok(authority) = hostname.parse::<Authority>() {
+                parts.authority = Some(authority);
+            }
+            if let Ok(uri) = Uri::from_parts(parts)
+                && let Ok(uri) = HeaderValue::from_str(&uri.to_string())
             {
-                // if so, replace the target service host with the front service host
-                let mut parts = location_uri.into_parts();
-                parts.scheme = Some(app.app_scheme);
-                if let Ok(authority) = hostname.parse::<Authority>() {
-                    parts.authority = Some(authority);
-                }
-                if let Ok(uri) = Uri::from_parts(parts)
-                    && let Ok(uri) = HeaderValue::from_str(&uri.to_string())
-                {
-                    response.headers_mut().insert(LOCATION, uri);
-                }
+                response.headers_mut().insert(LOCATION, uri);
             }
         }
     }

backend/src/configuration.rs

@@ -366,9 +366,11 @@ where
     async fn from_request_parts(parts: &mut Parts, state: &S) -> Result<Self, Self::Rejection> {
         let configmap = ConfigMap::from_ref(state);
 
-        let host = axum_extra::extract::Host::from_request_parts(parts, state)
-            .await
-            .map_err(|_| StatusCode::NOT_FOUND)?;
+        let host = <axum_extra::extract::Host as FromRequestParts<S>>::from_request_parts(
+            parts, state,
+        )
+        .await
+        .map_err(|_| StatusCode::NOT_FOUND)?;
 
         let hostname = host.0.split_once(':').unwrap_or((&host.0, "")).0;