diff --git a/examples/web_api.rs b/examples/web_api.rs index 025266e4..35e98ba4 100644 --- a/examples/web_api.rs +++ b/examples/web_api.rs @@ -2,10 +2,11 @@ extern crate futures; extern crate hyper; extern crate pretty_env_logger; +extern crate serde_json; use futures::{future, Future, Stream}; -use hyper::{Body, Chunk, Client, Method, Request, Response, Server, StatusCode}; +use hyper::{Body, Chunk, Client, Method, Request, Response, Server, StatusCode, header}; use hyper::client::HttpConnector; use hyper::service::service_fn; @@ -27,32 +28,65 @@ fn response_examples(req: Request, client: &Client) }, (&Method::GET, "/test.html") => { // Run a web query against the web api below + + // build the request let req = Request::builder() .method(Method::POST) .uri(URL) .body(LOWERCASE.into()) .unwrap(); + // use the request with client let web_res_future = client.request(req); Box::new(web_res_future.map(|web_res| { + // return the response that came from the web api and the original text together + // to show the difference let body = Body::wrap_stream(web_res.into_body().map(|b| { - Chunk::from(format!("before: '{:?}'
after: '{:?}'", + Chunk::from(format!("before: {}
after: {}", std::str::from_utf8(LOWERCASE).unwrap(), std::str::from_utf8(&b).unwrap())) })); + Response::new(body) })) }, (&Method::POST, "/web_api") => { - // A web api to run against. Simple upcasing of the body. + // A web api to run against. Uppercases the body and returns it back. let body = Body::wrap_stream(req.into_body().map(|chunk| { + // uppercase the letters let upper = chunk.iter().map(|byte| byte.to_ascii_uppercase()) .collect::>(); Chunk::from(upper) })); Box::new(future::ok(Response::new(body))) }, + (&Method::GET, "/json") => { + let data = vec!["foo", "bar"]; + let res = match serde_json::to_string(&data) { + Ok(json) => { + // return a json response + Response::builder() + .header(header::CONTENT_TYPE, "application/json") + .body(Body::from(json)) + .unwrap() + } + // This is unnecessary here because we know + // this can't fail. But if we were serializing json that came from another + // source we could handle an error like this. + Err(e) => { + eprintln!("serializing json: {}", e); + + Response::builder() + .status(StatusCode::INTERNAL_SERVER_ERROR) + .body(Body::from("Internal Server Error")) + .unwrap() + } + }; + + Box::new(future::ok(res)) + } _ => { + // Return 404 not found response. let body = Body::from(NOTFOUND); Box::new(future::ok(Response::builder() .status(StatusCode::NOT_FOUND)