tosic-http 0.0.3

//! Json extractor

use crate::body::message_body::MessageBody;
use crate::body::BoxBody;
use crate::error::ServerError;
use crate::extractors::ExtractionError;
use crate::futures::{err, ok, Ready};
use crate::traits::from_request::FromRequest;
use serde::de::DeserializeOwned;
use std::fmt::Debug;

#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord)]
/// Json extractor to extract data from the request
pub struct Json<V>(pub V);

impl<V: DeserializeOwned> FromRequest for Json<V> {
    type Error = ServerError;
    type Future = Ready<Result<Json<V>, Self::Error>>;
    fn from_request(
        _: &crate::request::HttpRequest,
        payload: &mut crate::request::HttpPayload,
    ) -> Self::Future {
        let body = <BoxBody as Clone>::clone(payload)
            .boxed()
            .try_into_bytes()
            .expect("Unable to read body");

        match serde_json::from_slice(&body) {
            Ok(value) => ok(Json(value)),
            Err(error) => err(ServerError::ExtractionError(ExtractionError::Json(error))),
        }
    }
}

impl<T> Json<T> {
    #[inline]
    /// Returns the inner value
    pub fn into_inner(self) -> T {
        self.0
    }
}

impl<T> std::ops::Deref for Json<T> {
    type Target = T;

    #[inline]
    fn deref(&self) -> &Self::Target {
        &self.0
    }
}

impl<T> std::ops::DerefMut for Json<T> {
    #[inline]
    fn deref_mut(&mut self) -> &mut Self::Target {
        &mut self.0
    }
}