Boilerplate until the let_chains feature is fixed

rust-lang/rust#92145

Author: Cryptex-github

cdn_server/src/download.rs

@@ -21,42 +21,54 @@ use crate::node::get_node_ip;
 pub async fn download(
     Path((node, filename)): Path<(String, String)>,
 ) -> Result<Response<BoxBody>, CdnError> {
-    let mut content_type: String;
-
-    let mut decoded: Vec<u8>;
-
-    let mut status: StatusCode;
+    if *CACHE {
+        if let Some(file_) = get_from_cache(&filename) {
+            let content_type = tree_magic::from_u8(&file_);
+            let decoded = file_;
+
+            let resp = Response::builder()
+            .status(StatusCode::FOUND)
+            .header(
+                CONTENT_TYPE,
+                HeaderValue::from_str(content_type.as_str())
+                    .unwrap_or(HeaderValue::from_static("application/octet-stream")),
+            )
+            .body(body::boxed(body::Full::from(decoded)))
+            .unwrap_or_else(|e| {
+                // this should only be reachable if a invalid HTTP code is passed in
+                unreachable!(
+                    "got an error while attempting to construct HTTP response for ServerError: {}",
+                    e
+                )
+            });
+
+            return Ok(resp);
+        }
+    }
 
-    if *CACHE && let Some(file_) = get_from_cache(&filename) {
-        content_type = tree_magic::from_u8(&file_);
-        decoded = file_;
-        status = StatusCode::FOUND;
-    } else {
-        let node_ip = get_node_ip(node).await?;
+    let node_ip = get_node_ip(node).await?;
 
-        let file = get_file(node_ip, filename).await?;
+    let file = get_file(node_ip, filename.clone()).await?;
 
-        let mut decoder = ZstdDecoder::new(Vec::new());
-        decoder
-            .write_all(&file)
-            .await
-            .map_err(|e| CdnError::FailedToDeCompress(e))?;
-        decoder
-            .shutdown()
-            .await
-            .map_err(|e| CdnError::FailedToDeCompress(e))?;
+    let mut decoder = ZstdDecoder::new(Vec::new());
+    decoder
+        .write_all(&file)
+        .await
+        .map_err(|e| CdnError::FailedToDeCompress(e))?;
+    decoder
+        .shutdown()
+        .await
+        .map_err(|e| CdnError::FailedToDeCompress(e))?;
 
-        decoded = decoder.into_inner();
-        content_type = tree_magic::from_u8(&decoded);
-        status = StatusCode::OK;
+    let decoded = decoder.into_inner();
+    let content_type = tree_magic::from_u8(&decoded);
 
-        if *CACHE {
-            insert_into_cache(filename, decoded.clone(), decoded.len() as i64).await;
-        }
+    if *CACHE {
+        insert_into_cache(filename, decoded.clone(), decoded.len() as i64).await;
     }
 
     let resp = Response::builder()
-        .status(status)
+        .status(StatusCode::OK)
         .header(
             CONTENT_TYPE,
             HeaderValue::from_str(content_type.as_str())

cdn_server/src/lib.rs

@@ -1,6 +1,5 @@
 #![feature(async_closure)]
 #![feature(once_cell)]
-#![feature(let_chains)]
 
 #[macro_use]
 extern crate lazy_static;