unrest 0.1.0

PoC of async http framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

use serde_json::{self, Value};
use serde::de::DeserializeOwned;
use serde::Serialize;
use {FromData, Error, Responder, Response};
use hyper::header::ContentType;

#[derive(Debug)]
pub struct Json<T = Value>(pub T);

impl<T> Json<T> {
    pub fn into_inner(self) -> T {
        self.0
    }
}

impl<T: DeserializeOwned> FromData for Json<T> {
    fn from_data(buf: &[u8]) -> Result<Self, Error> {
        let inner = serde_json::from_slice(buf).map_err(|e| {
            Error::FromDataError(e.to_string())
        })?;

        Ok(Json(inner))
    }
}

impl<T: Serialize> Responder for Json<T> {
    fn respond(self) -> Response {
        match serde_json::to_vec(&self.0).map_err(|e| Error::OtherServersFault(e.to_string())) {
            Ok(json) => {
                Response::new().with_header(ContentType::json()).with_body(
                    json,
                )
            }
            Err(e) => e.respond(),
        }


    }
}