media: move to separate subtree

This will ease future extraction of the media endpoint to a separate
crate. This is highly desirable since it will allow Kittybox's media
endpoint to be used separately in instances where a standalone media
endpoint is desirable (e.g. custom solutions using my code to polyfill
for desired functionality that is undesirable to implement by oneself)

1 files changed, 0 insertions, 50 deletions

diff --git a/src/micropub/mod.rs b/src/micropub/mod.rs
index ac038f8..7aad51a 100644
--- a/src/micropub/mod.rs
+++ b/src/micropub/mod.rs
@@ -110,56 +110,6 @@ impl warp::reject::Reject for MicropubError {}
 mod post;
 pub(crate) use post::normalize_mf2;
 
-#[allow(unused_variables)]
-pub mod media {
-    use futures_util::StreamExt;
-    use bytes::buf::Buf;
-    use warp::{Filter, Rejection, Reply, multipart::{FormData, Part}};
-
-    pub fn query() -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone {
-        warp::get()
-            .and(crate::util::require_host())
-            .map(|host| "media endpoint query...")
-    }
-
-    pub fn options() -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone {
-        warp::options()
-            .map(|| warp::reply::json::<Option<()>>(&None))
-            .with(warp::reply::with::header("Allow", "GET, POST"))
-    }
-
-    pub fn upload() -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone {
-        warp::post()
-            .and(crate::util::require_host())
-            .and(warp::multipart::form().max_length(1024*1024*150/*mb*/))
-            .and_then(|host, mut form: FormData| async move {
-                // TODO get rid of the double unwrap() here
-                let file: Part = form.next().await.unwrap().unwrap();
-                log::debug!("Uploaded: {:?}, type: {:?}", file.filename(), file.content_type());
-
-                let mut data = file.stream();
-                while let Some(buf) = data.next().await {
-                    // TODO save it into a file
-                    log::debug!("buffer length: {:?}", buf.map(|b| b.remaining()));
-                }
-                Ok::<_, warp::Rejection>(warp::reply::with_header(
-                    warp::reply::with_status(
-                        "",
-                        warp::http::StatusCode::CREATED
-                    ),
-                    "Location",
-                    "./awoo.png"
-                ))
-            })
-    }
-
-    pub fn media() -> impl Filter<Extract = (impl Reply,), Error = Rejection> + Clone {
-        upload()
-            .or(query())
-            .or(options())
-    }
-}
-
 mod util {
     use serde_json::json;