3 files changed, 26 insertions, 11 deletions
diff --git a/kittybox-rs/src/media/mod.rs b/kittybox-rs/src/media/mod.rs
index d18cf34..0d26f92 100644
--- a/kittybox-rs/src/media/mod.rs
+++ b/kittybox-rs/src/media/mod.rs
@@ -1,9 +1,9 @@
-use bytes::buf::Buf;
-use futures_util::StreamExt;
 use axum::{
-    extract::{Host, Extension, Multipart},
-    response::{Response, IntoResponse, Json}
+    extract::{Extension, Host, Multipart},
+    response::{IntoResponse, Json, Response},
 };
+use bytes::buf::Buf;
+use futures_util::StreamExt;
 
 pub mod storage;
 use storage::{MediaStore, MediaStoreError};
@@ -36,7 +36,7 @@ use storage::{MediaStore, MediaStoreError};
 pub async fn upload<S: MediaStore>(
     Host(host): Host,
     upload: Multipart,
-    Extension(db): Extension<S>
+    Extension(db): Extension<S>,
 ) -> Response {
     todo!()
 }
diff --git a/kittybox-rs/src/media/storage/file.rs b/kittybox-rs/src/media/storage/file.rs
index 8c0ddf0..ea1f010 100644
--- a/kittybox-rs/src/media/storage/file.rs
+++ b/kittybox-rs/src/media/storage/file.rs
@@ -22,16 +22,22 @@ impl From<tokio::io::Error> for MediaStoreError {
 #[async_trait]
 impl MediaStore for FileStore {
     async fn write_streaming(
-        &self, domain: url::Host, filename: &str,
-        content: axum::extract::multipart::Field<'_>
+        &self,
+        domain: url::Host,
+        filename: &str,
+        content: axum::extract::multipart::Field<'_>,
     ) -> Result<()> {
         todo!()
     }
 
-    async fn read_streaming(&self, domain: url::Host, filename: &str) -> Result<tokio_util::io::ReaderStream<Box<dyn tokio::io::AsyncRead>>> {
+    async fn read_streaming(
+        &self,
+        domain: url::Host,
+        filename: &str,
+    ) -> Result<tokio_util::io::ReaderStream<Box<dyn tokio::io::AsyncRead>>> {
         todo!()
     }
-    
+
     async fn write(&self, domain: url::Host, filename: &str, content: &[u8]) -> Result<()> {
         let path = self.base.join(format!("{}/{}", domain, filename));
 
diff --git a/kittybox-rs/src/media/storage/mod.rs b/kittybox-rs/src/media/storage/mod.rs
index e9b01f9..ba880ab 100644
--- a/kittybox-rs/src/media/storage/mod.rs
+++ b/kittybox-rs/src/media/storage/mod.rs
@@ -45,9 +45,18 @@ pub type Result<T> = std::result::Result<T, MediaStoreError>;
 
 #[async_trait]
 pub trait MediaStore: 'static + Send + Sync + Clone {
-    async fn write_streaming(&self, domain: url::Host, filename: &str, content: axum::extract::multipart::Field<'_>) -> Result<()>;
+    async fn write_streaming(
+        &self,
+        domain: url::Host,
+        filename: &str,
+        content: axum::extract::multipart::Field<'_>,
+    ) -> Result<()>;
     async fn write(&self, domain: url::Host, filename: &str, content: &[u8]) -> Result<()>;
-    async fn read_streaming(&self, domain: url::Host, filename: &str) -> Result<tokio_util::io::ReaderStream<Box<dyn tokio::io::AsyncRead>>>;
+    async fn read_streaming(
+        &self,
+        domain: url::Host,
+        filename: &str,
+    ) -> Result<tokio_util::io::ReaderStream<Box<dyn tokio::io::AsyncRead>>>;
     async fn read(&self, domain: url::Host, filename: &str) -> Result<Vec<u8>>;
     async fn delete(&self, domain: url::Host, filename: &str) -> Result<()>;
 }