Add Bytes serde feature

Author: sd109

Cargo.lock

@@ -69,6 +69,7 @@ validator = { version = "0.16", features = ["derive"] }
 zerocopy = { version = "0.6.1", features = ["alloc", "simd"] }
 zune-inflate = "0.2.54"
 cached = { version = "0.54.0", features = ["disk_store", "async"] }
+bytes = { version = "1.9.0", features = ["serde"] }
 
 [dev-dependencies]
 criterion = { version = "0.4", features = ["async_tokio", "html_reports"] }

Cargo.toml

@@ -14,15 +14,15 @@ use crate::validated_json::ValidatedJson;
 
 use axum::middleware;
 use axum::{
-    body::Bytes,
     extract::{Path, State},
     headers::authorization::{Authorization, Basic},
     http::header,
     response::{IntoResponse, Response},
     routing::{get, post},
     Router, TypedHeader,
 };
-use cached::{proc_macro::io_cached, stores::DiskCacheBuilder};
+use bytes::Bytes;
+// use cached::{proc_macro::io_cached, stores::DiskCacheBuilder};
 
 use std::sync::Arc;
 use tokio::sync::SemaphorePermit;
@@ -172,13 +172,13 @@ async fn schema() -> &'static str {
     level = "DEBUG",
     skip(client, request_data, resource_manager, mem_permits)
 )]
-#[io_cached(
-    map_error = r##"|e| ActiveStorageError::CacheError{ error: format!("{:?}", e) }"##,
-    disk = true,
-    create = r##"{ DiskCacheBuilder::new("test-cache").set_disk_directory("./").build().expect("valid disk cache builder") }"##,
-    key = "String",
-    convert = r##"{ format!("{:?},{:?},{:?},{:?}", client, request_data, resource_manager, mem_permits) }"##
-)]
+// #[io_cached(
+//     map_error = r##"|e| ActiveStorageError::CacheError{ error: format!("{:?}", e) }"##,
+//     disk = true,
+//     create = r##"{ DiskCacheBuilder::new("test-cache").set_disk_directory("./").build().expect("valid disk cache builder") }"##,
+//     key = "String",
+//     convert = r##"{ format!("{:?},{:?},{:?},{:?}", client, request_data, resource_manager, mem_permits) }"##
+// )]
 async fn download_object<'a>(
     client: &s3_client::S3Client,
     request_data: &models::RequestData,

src/app.rs

@@ -274,7 +274,7 @@ impl From<ActiveStorageError> for ErrorResponse {
                     _ => Self::internal_server_error(&error),
                 }
             }
-            ActiveStorageError::CacheError { error } => todo!(),
+            ActiveStorageError::CacheError { error: _ } => todo!(),
         };
 
         // Log server errors.

src/error.rs

@@ -206,10 +206,7 @@ pub fn get_range(offset: Option<usize>, size: Option<usize>) -> Option<String> {
 #[cfg(test)]
 mod tests {
     use super::*;
-    use cached::{
-        proc_macro::{cached, io_cached},
-        stores::DiskCacheBuilder,
-    };
+    use cached::{proc_macro::io_cached, stores::DiskCacheBuilder};
     use url::Url;
 
     // #[cached(