ugly hack: temporarily force JSON decoding (#4)

Cargo.toml

@@ -21,6 +21,9 @@ redis = { version = "0.23.0", features = ["tokio-comp", "connection-manager"] }
 tracing-subscriber = { version = "0.3", default-features = false, features = [
     "fmt",
 ] }
+serde_path_to_error = "0.1.14"
+async-trait = "0.1.74"
+thiserror = "1.0.50"
 
 [build-dependencies]
 chrono = "0.4.26"

src/axum/mod.rs

@@ -0,0 +1,62 @@
+use std::time::SystemTime;
+
+use async_trait::async_trait;
+use axum::{
+    body::{Bytes, HttpBody},
+    extract::FromRequest,
+    http::Request,
+    response::IntoResponse,
+    BoxError,
+};
+use serde::de::DeserializeOwned;
+
+#[derive(Debug, thiserror::Error)]
+pub enum JsonError {
+    #[error("failed to deserialize json")]
+    Deserialize(#[from] serde_path_to_error::Error<serde_json::Error>),
+
+    #[error("failed to extract body")]
+    Body(#[from] axum::extract::rejection::BytesRejection),
+}
+
+impl IntoResponse for JsonError {
+    fn into_response(self) -> axum::response::Response {
+        unimplemented!()
+    }
+}
+
+#[derive(Debug, Clone, Copy, Default)]
+#[must_use]
+pub struct TemporaryForceDecodeJson<T>(pub T);
+
+#[async_trait]
+impl<T, S, B> FromRequest<S, B> for TemporaryForceDecodeJson<T>
+where
+    T: DeserializeOwned,
+    B: HttpBody + Send + 'static,
+    B::Data: Send,
+    B::Error: Into<BoxError>,
+    S: Send + Sync,
+{
+    type Rejection = JsonError;
+
+    async fn from_request(req: Request<B>, state: &S) -> Result<Self, Self::Rejection> {
+        assert!(
+            !is_after_nov_30(),
+            "This was supposed to be a very temporary hack you fools!!!! Time to use proper JSON headers."
+        );
+
+        let bytes = Bytes::from_request(req, state).await?;
+        let deserializer = &mut serde_json::Deserializer::from_slice(&bytes);
+
+        Ok(Self(serde_path_to_error::deserialize(deserializer)?))
+    }
+}
+
+fn is_after_nov_30() -> bool {
+    SystemTime::now()
+        .duration_since(std::time::SystemTime::UNIX_EPOCH)
+        .unwrap()
+        .as_secs()
+        > 1_701_331_200
+}

src/main.rs

@@ -4,6 +4,7 @@ use dotenvy::dotenv;
 use redis::aio::ConnectionManager;
 use std::env;
 
+mod axum;
 mod routes;
 mod server;
 mod utils;

src/routes/response.rs

@@ -11,8 +11,11 @@ use std::str;
 use tower_http::cors::{AllowHeaders, Any, CorsLayer};
 use uuid::Uuid;
 
-use crate::utils::{
-    handle_redis_error, RequestPayload, RequestStatus, EXPIRE_AFTER_SECONDS, REQ_STATUS_PREFIX,
+use crate::{
+    axum::TemporaryForceDecodeJson,
+    utils::{
+        handle_redis_error, RequestPayload, RequestStatus, EXPIRE_AFTER_SECONDS, REQ_STATUS_PREFIX,
+    },
 };
 
 const RES_PREFIX: &str = "res:";
@@ -81,7 +84,7 @@ async fn get_response(
 async fn insert_response(
     Path(request_id): Path<Uuid>,
     Extension(mut redis): Extension<ConnectionManager>,
-    Json(request): Json<RequestPayload>,
+    TemporaryForceDecodeJson(request): TemporaryForceDecodeJson<RequestPayload>,
 ) -> Result<StatusCode, StatusCode> {
     //ANCHOR - Store the response
     if !redis