use std::fs::File; use std::io::Cursor; use std::fmt; use http::{Status, ContentType}; use response::Response; use request::Request; /// Trait implemented by types that generate responses for clients. /// /// Types that implement this trait can be used as the return type of a handler, /// as illustrated below: /// /// ```rust,ignore /// #[get("/")] /// fn index() -> T { ... } /// ``` /// /// In this example, `T` can be any type that implements `Responder`. /// /// # Return Value /// /// A `Responder` returns an `Ok(Response)` or an `Err(Status)`: /// /// * An `Ok` variant means that the `Responder` was successful in generating /// a `Response`. The `Response` will be written out to the client. /// /// * An `Err` variant means that the `Responder` could not or did not /// generate a `Response`. The contained `Status` will be used to find the /// relevant error catcher which then generates an error response. /// /// # Provided Implementations /// /// Rocket implements `Responder` for several standard library types. Their /// behavior is documented here. Note that the `Result` implementation is /// overloaded, allowing for two `Responder`s to be used at once, depending on /// the variant. /// /// * **&str** /// /// Sets the `Content-Type` to `text/plain`. The string is used as the body /// of the response, which is fixed size and not streamed. To stream a raw /// string, use `Stream::from(Cursor::new(string))`. /// /// * **String** /// /// Sets the `Content-Type`t to `text/plain`. The string is used as the body /// of the response, which is fixed size and not streamed. To stream a /// string, use `Stream::from(Cursor::new(string))`. /// /// * **File** /// /// Responds with a streamed body containing the data in the `File`. No /// `Content-Type` is set. To automatically have a `Content-Type` set based /// on the file's extension, use /// [`NamedFile`](/rocket/response/struct.NamedFile.html). /// /// * **()** /// /// Responds with an empty body. No `Content-Type` is set. /// /// * **Option<T>** /// /// If the `Option` is `Some`, the wrapped responder is used to respond to /// the client. Otherwise, an `Err` with status **404 Not Found** is /// returned and a warning is printed to the console. /// /// * **Result<T, E>** _where_ **E: Debug** /// /// If the `Result` is `Ok`, the wrapped responder is used to respond to the /// client. Otherwise, an `Err` with status **500 Internal Server Error** is /// returned and the error is printed to the console using the `Debug` /// implementation. /// /// * **Result<T, E>** _where_ **E: Debug + Responder** /// /// If the `Result` is `Ok`, the wrapped `Ok` responder is used to respond /// to the client. If the `Result` is `Err`, the wrapped `Err` responder is /// used to respond to the client. /// /// # Implementation Tips /// /// This section describes a few best practices to take into account when /// implementing `Responder`. /// /// ## Debug /// /// A type implementing `Responder` should implement the `Debug` trait when /// possible. This is because the `Responder` implementation for `Result` /// requires its `Err` type to implement `Debug`. Therefore, a type implementing /// `Debug` can more easily be composed. /// /// ## Joining and Merging /// /// When chaining/wrapping other `Responder`s, use the /// [merge](/rocket/struct.Response.html#method.merge) or /// [join](/rocket/struct.Response.html#method.join) methods on the `Response` /// or `ResponseBuilder` struct. Ensure that you document the merging or joining /// behavior appropriately. /// /// ## Inspecting Requests /// /// A `Responder` has access to the request it is responding to. Even so, you /// should avoid using the `Request` value as much as possible. This is because /// using the `Request` object makes your responder _inpure_, and so the use of /// the type as a `Responder` has less intrinsic meaning associated with it. If /// the `Responder` were pure, however, it always respond in the same manner, /// regardless of the incoming request. Thus, knowing the type is sufficient to /// fully determine its functionality. /// /// # Example /// /// Say that you have a custom type, `Person`: /// /// ```rust /// /// # #[allow(dead_code)] /// struct Person { /// name: String, /// age: u16 /// } /// ``` /// /// You'd like to use `Person` as a `Responder` so that you can return a /// `Person` directly from a handler: /// /// ```rust,ignore /// #[get("/person/")] /// fn person(id: usize) -> Option { /// Person::from_id(id) /// } /// ``` /// /// You want the `Person` responder to set two header fields: `X-Person-Name` /// and `X-Person-Age` as well as supply a custom representation of the object /// (`Content-Type: application/x-person`) in the body of the response. The /// following `Responder` implementation accomplishes this: /// /// ```rust /// # #![feature(plugin)] /// # #![plugin(rocket_codegen)] /// # extern crate rocket; /// # /// # #[derive(Debug)] /// # struct Person { name: String, age: u16 } /// # /// use std::io::Cursor; /// /// use rocket::request::Request; /// use rocket::response::{self, Response, Responder}; /// use rocket::http::ContentType; /// /// impl Responder<'static> for Person { /// fn respond_to(self, _: &Request) -> response::Result<'static> { /// Response::build() /// .sized_body(Cursor::new(format!("{}:{}", self.name, self.age))) /// .raw_header("X-Person-Name", self.name) /// .raw_header("X-Person-Age", self.age.to_string()) /// .header(ContentType::new("application", "x-person")) /// .ok() /// } /// } /// # /// # #[get("/person")] /// # fn person() -> Person { Person { name: "a".to_string(), age: 20 } } /// # fn main() { } /// ``` pub trait Responder<'r> { /// Returns `Ok` if a `Response` could be generated successfully. Otherwise, /// returns an `Err` with a failing `Status`. /// /// The `request` parameter is the `Request` that this `Responder` is /// responding to. /// /// When using Rocket's code generation, if an `Ok(Response)` is returned, /// the response will be written out to the client. If an `Err(Status)` is /// returned, the error catcher for the given status is retrieved and called /// to generate a final error response, which is then written out to the /// client. fn respond_to(self, request: &Request) -> Result, Status>; } /// Returns a response with Content-Type `text/plain` and a fixed-size body /// containing the string `self`. Always returns `Ok`. impl<'r> Responder<'r> for &'r str { fn respond_to(self, _: &Request) -> Result, Status> { Response::build() .header(ContentType::Plain) .sized_body(Cursor::new(self)) .ok() } } /// Returns a response with Content-Type `text/plain` and a fixed-size body /// containing the string `self`. Always returns `Ok`. impl Responder<'static> for String { fn respond_to(self, _: &Request) -> Result, Status> { Response::build() .header(ContentType::Plain) .sized_body(Cursor::new(self)) .ok() } } /// Returns a response with a sized body for the file. Always returns `Ok`. impl Responder<'static> for File { fn respond_to(self, _: &Request) -> Result, Status> { Response::build().streamed_body(self).ok() } } /// Returns an empty, default `Response`. Always returns `Ok`. impl Responder<'static> for () { fn respond_to(self, _: &Request) -> Result, Status> { Ok(Response::new()) } } /// If `self` is `Some`, responds with the wrapped `Responder`. Otherwise prints /// a warning message and returns an `Err` of `Status::NotFound`. impl<'r, R: Responder<'r>> Responder<'r> for Option { fn respond_to(self, req: &Request) -> Result, Status> { self.map_or_else(|| { warn_!("Response was `None`."); Err(Status::NotFound) }, |r| r.respond_to(req)) } } /// If `self` is `Ok`, responds with the wrapped `Responder`. Otherwise prints /// an error message with the `Err` value returns an `Err` of /// `Status::InternalServerError`. impl<'r, R: Responder<'r>, E: fmt::Debug> Responder<'r> for Result { default fn respond_to(self, req: &Request) -> Result, Status> { self.map(|r| r.respond_to(req)).unwrap_or_else(|e| { error_!("Response was `Err`: {:?}.", e); Err(Status::InternalServerError) }) } } /// Responds with the wrapped `Responder` in `self`, whether it is `Ok` or /// `Err`. impl<'r, R: Responder<'r>, E: Responder<'r> + fmt::Debug> Responder<'r> for Result { fn respond_to(self, req: &Request) -> Result, Status> { match self { Ok(responder) => responder.respond_to(req), Err(responder) => responder.respond_to(req), } } }