aboutsummaryrefslogtreecommitdiffstats
path: root/rust/fatcat-api/src/server
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@robocracy.org>2018-05-15 00:33:33 -0700
committerBryan Newbold <bnewbold@robocracy.org>2018-05-15 00:33:36 -0700
commit33a4cce0b97832f5f0301b318a0a50073ce6b615 (patch)
tree1b6ba7ec5944d2be2d746510e743a7934f453cd0 /rust/fatcat-api/src/server
parent4a1d8f20ab91fda0f4794131144915d0c5214268 (diff)
downloadfatcat-33a4cce0b97832f5f0301b318a0a50073ce6b615.tar.gz
fatcat-33a4cce0b97832f5f0301b318a0a50073ce6b615.zip
revert to v2.3.1 codegen
This reverts back to something compatible with Iron and simple (blocking) parallelism, instead of the new async hyper 0.11 stuff.
Diffstat (limited to 'rust/fatcat-api/src/server')
-rw-r--r--rust/fatcat-api/src/server/auth.rs93
-rw-r--r--rust/fatcat-api/src/server/mod.rs2485
2 files changed, 0 insertions, 2578 deletions
diff --git a/rust/fatcat-api/src/server/auth.rs b/rust/fatcat-api/src/server/auth.rs
deleted file mode 100644
index 48dfd7d6..00000000
--- a/rust/fatcat-api/src/server/auth.rs
+++ /dev/null
@@ -1,93 +0,0 @@
-use Api;
-use hyper;
-use hyper::{Error, Request, Response, StatusCode};
-use server::url::form_urlencoded;
-use std::io;
-use swagger::auth::{AuthData, Authorization, Scopes};
-
-pub struct NewService<T>
-where
- T: hyper::server::NewService<
- Request = (Request, Option<AuthData>),
- Response = Response,
- Error = Error,
- >,
-{
- inner: T,
-}
-
-impl<T> NewService<T>
-where
- T: hyper::server::NewService<
- Request = (Request, Option<AuthData>),
- Response = Response,
- Error = Error,
- >
- + 'static,
-{
- pub fn new(inner: T) -> NewService<T> {
- NewService { inner }
- }
-}
-
-impl<T> hyper::server::NewService for NewService<T>
-where
- T: hyper::server::NewService<
- Request = (Request, Option<AuthData>),
- Response = Response,
- Error = Error,
- >
- + 'static,
-{
- type Request = Request;
- type Response = Response;
- type Error = Error;
- type Instance = Service<T::Instance>;
-
- fn new_service(&self) -> Result<Self::Instance, io::Error> {
- self.inner.new_service().map(|s| Service::new(s))
- }
-}
-
-/// Middleware to extract authentication data from request
-pub struct Service<T>
-where
- T: hyper::server::Service<
- Request = (Request, Option<AuthData>),
- Response = Response,
- Error = Error,
- >,
-{
- inner: T,
-}
-
-impl<T> Service<T>
-where
- T: hyper::server::Service<
- Request = (Request, Option<AuthData>),
- Response = Response,
- Error = Error,
- >,
-{
- pub fn new(inner: T) -> Service<T> {
- Service { inner }
- }
-}
-
-impl<T> hyper::server::Service for Service<T>
-where
- T: hyper::server::Service<
- Request = (Request, Option<AuthData>),
- Response = Response,
- Error = Error,
- >,
-{
- type Request = Request;
- type Response = Response;
- type Error = Error;
- type Future = T::Future;
-
- fn call(&self, req: Self::Request) -> Self::Future {
- return self.inner.call((req, None));
- }
-}
diff --git a/rust/fatcat-api/src/server/mod.rs b/rust/fatcat-api/src/server/mod.rs
deleted file mode 100644
index 186f8272..00000000
--- a/rust/fatcat-api/src/server/mod.rs
+++ /dev/null
@@ -1,2485 +0,0 @@
-#![allow(unused_extern_crates)]
-extern crate chrono;
-extern crate hyper_tls;
-extern crate mime;
-extern crate native_tls;
-extern crate openssl;
-extern crate serde_ignored;
-extern crate tokio_core;
-extern crate uuid;
-
-extern crate percent_encoding;
-extern crate url;
-
-use self::url::form_urlencoded;
-use futures::{future, stream, Future, Stream};
-use hyper;
-use hyper::header::{ContentType, Headers};
-use hyper::{Error, Request, Response, StatusCode};
-use mimetypes;
-use std::sync::Arc;
-
-use serde_json;
-
-#[allow(unused_imports)]
-use std::collections::{BTreeMap, HashMap};
-use std::io;
-#[allow(unused_imports)]
-use swagger;
-
-#[allow(unused_imports)]
-use std::collections::BTreeSet;
-
-pub use swagger::auth::Authorization;
-use swagger::auth::Scopes;
-use swagger::{ApiError, Context, XSpanId};
-
-#[allow(unused_imports)]
-use models;
-use {Api, ContainerIdGetResponse, ContainerLookupGetResponse, ContainerPostResponse,
- CreatorIdGetResponse, CreatorLookupGetResponse, CreatorPostResponse,
- EditgroupIdAcceptPostResponse, EditgroupIdGetResponse, EditgroupPostResponse,
- EditorUsernameChangelogGetResponse, EditorUsernameGetResponse, FileIdGetResponse,
- FileLookupGetResponse, FilePostResponse, ReleaseIdGetResponse, ReleaseLookupGetResponse,
- ReleasePostResponse, WorkIdGetResponse, WorkPostResponse};
-
-pub mod auth;
-
-header! { (Warning, "Warning") => [String] }
-
-mod paths {
- extern crate regex;
-
- lazy_static! {
- pub static ref GLOBAL_REGEX_SET: regex::RegexSet = regex::RegexSet::new(&[
- r"^/v0/container$",
- r"^/v0/container/lookup$",
- r"^/v0/container/(?P<id>[^/?#]*)$",
- r"^/v0/creator$",
- r"^/v0/creator/lookup$",
- r"^/v0/creator/(?P<id>[^/?#]*)$",
- r"^/v0/editgroup$",
- r"^/v0/editgroup/(?P<id>[^/?#]*)$",
- r"^/v0/editgroup/(?P<id>[^/?#]*)/accept$",
- r"^/v0/editor/(?P<username>[^/?#]*)$",
- r"^/v0/editor/(?P<username>[^/?#]*)/changelog$",
- r"^/v0/file$",
- r"^/v0/file/lookup$",
- r"^/v0/file/(?P<id>[^/?#]*)$",
- r"^/v0/release$",
- r"^/v0/release/lookup$",
- r"^/v0/release/(?P<id>[^/?#]*)$",
- r"^/v0/work$",
- r"^/v0/work/(?P<id>[^/?#]*)$"
- ]).unwrap();
- }
- pub static ID_CONTAINER: usize = 0;
- pub static ID_CONTAINER_LOOKUP: usize = 1;
- pub static ID_CONTAINER_ID: usize = 2;
- lazy_static! {
- pub static ref REGEX_CONTAINER_ID: regex::Regex =
- regex::Regex::new(r"^/v0/container/(?P<id>[^/?#]*)$").unwrap();
- }
- pub static ID_CREATOR: usize = 3;
- pub static ID_CREATOR_LOOKUP: usize = 4;
- pub static ID_CREATOR_ID: usize = 5;
- lazy_static! {
- pub static ref REGEX_CREATOR_ID: regex::Regex =
- regex::Regex::new(r"^/v0/creator/(?P<id>[^/?#]*)$").unwrap();
- }
- pub static ID_EDITGROUP: usize = 6;
- pub static ID_EDITGROUP_ID: usize = 7;
- lazy_static! {
- pub static ref REGEX_EDITGROUP_ID: regex::Regex =
- regex::Regex::new(r"^/v0/editgroup/(?P<id>[^/?#]*)$").unwrap();
- }
- pub static ID_EDITGROUP_ID_ACCEPT: usize = 8;
- lazy_static! {
- pub static ref REGEX_EDITGROUP_ID_ACCEPT: regex::Regex =
- regex::Regex::new(r"^/v0/editgroup/(?P<id>[^/?#]*)/accept$").unwrap();
- }
- pub static ID_EDITOR_USERNAME: usize = 9;
- lazy_static! {
- pub static ref REGEX_EDITOR_USERNAME: regex::Regex =
- regex::Regex::new(r"^/v0/editor/(?P<username>[^/?#]*)$").unwrap();
- }
- pub static ID_EDITOR_USERNAME_CHANGELOG: usize = 10;
- lazy_static! {
- pub static ref REGEX_EDITOR_USERNAME_CHANGELOG: regex::Regex =
- regex::Regex::new(r"^/v0/editor/(?P<username>[^/?#]*)/changelog$").unwrap();
- }
- pub static ID_FILE: usize = 11;
- pub static ID_FILE_LOOKUP: usize = 12;
- pub static ID_FILE_ID: usize = 13;
- lazy_static! {
- pub static ref REGEX_FILE_ID: regex::Regex =
- regex::Regex::new(r"^/v0/file/(?P<id>[^/?#]*)$").unwrap();
- }
- pub static ID_RELEASE: usize = 14;
- pub static ID_RELEASE_LOOKUP: usize = 15;
- pub static ID_RELEASE_ID: usize = 16;
- lazy_static! {
- pub static ref REGEX_RELEASE_ID: regex::Regex =
- regex::Regex::new(r"^/v0/release/(?P<id>[^/?#]*)$").unwrap();
- }
- pub static ID_WORK: usize = 17;
- pub static ID_WORK_ID: usize = 18;
- lazy_static! {
- pub static ref REGEX_WORK_ID: regex::Regex =
- regex::Regex::new(r"^/v0/work/(?P<id>[^/?#]*)$").unwrap();
- }
-}
-
-pub struct NewService<T> {
- api_impl: Arc<T>,
-}
-
-impl<T> NewService<T>
-where
- T: Api + Clone + 'static,
-{
- pub fn new<U: Into<Arc<T>>>(api_impl: U) -> NewService<T> {
- NewService {
- api_impl: api_impl.into(),
- }
- }
-}
-
-impl<T> hyper::server::NewService for NewService<T>
-where
- T: Api + Clone + 'static,
-{
- type Request = (Request, Context);
- type Response = Response;
- type Error = Error;
- type Instance = Service<T>;
-
- fn new_service(&self) -> Result<Self::Instance, io::Error> {
- Ok(Service::new(self.api_impl.clone()))
- }
-}
-
-pub struct Service<T> {
- api_impl: Arc<T>,
-}
-
-impl<T> Service<T>
-where
- T: Api + Clone + 'static,
-{
- pub fn new<U: Into<Arc<T>>>(api_impl: U) -> Service<T> {
- Service {
- api_impl: api_impl.into(),
- }
- }
-}
-
-impl<T> hyper::server::Service for Service<T>
-where
- T: Api + Clone + 'static,
-{
- type Request = (Request, Context);
- type Response = Response;
- type Error = Error;
- type Future = Box<Future<Item = Response, Error = Error>>;
-
- fn call(&self, (req, mut context): Self::Request) -> Self::Future {
- let api_impl = self.api_impl.clone();
- let (method, uri, _, headers, body) = req.deconstruct();
- let path = paths::GLOBAL_REGEX_SET.matches(uri.path());
- match &method {
- // ContainerIdGet - GET /container/{id}
- &hyper::Method::Get if path.matched(paths::ID_CONTAINER_ID) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Path parameters
- let path = uri.path().to_string();
- let path_params = paths::REGEX_CONTAINER_ID
- .captures(&path)
- .unwrap_or_else(|| {
- panic!("Path {} matched RE CONTAINER_ID in set but failed match against \"{}\"", path, paths::REGEX_CONTAINER_ID.as_str())
- });
-
- let param_id = match percent_encoding::percent_decode(path_params["id"].as_bytes())
- .decode_utf8()
- {
- Ok(param_id) => match param_id.parse::<String>() {
- Ok(param_id) => param_id,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!("Couldn't parse path parameter id: {}", e)),
- ))
- }
- },
- Err(_) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't percent-decode path parameter as UTF-8: {}",
- &path_params["id"]
- )),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(api_impl.container_id_get(param_id, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- ContainerIdGetResponse::FetchASingleContainerById
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(200).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::CONTAINER_ID_GET_FETCH_A_SINGLE_CONTAINER_BY_ID.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- ContainerIdGetResponse::BadRequest
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(400).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::CONTAINER_ID_GET_BAD_REQUEST.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- ContainerIdGetResponse::GenericErrorResponse
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(0).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::CONTAINER_ID_GET_GENERIC_ERROR_RESPONSE.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response.set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- },
- }
-
- future::ok(response)
- },
- ))
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // ContainerLookupGet - GET /container/lookup
- &hyper::Method::Get if path.matched(paths::ID_CONTAINER_LOOKUP) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Query parameters (note that non-required or collection query parameters will ignore garbage values, rather than causing a 400 response)
- let query_params = form_urlencoded::parse(
- uri.query().unwrap_or_default().as_bytes(),
- ).collect::<Vec<_>>();
- let param_issn = query_params
- .iter()
- .filter(|e| e.0 == "issn")
- .map(|e| e.1.to_owned())
- .nth(0);
- let param_issn = match param_issn {
- Some(param_issn) => match param_issn.parse::<String>() {
- Ok(param_issn) => param_issn,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't parse query parameter issn - doesn't match schema: {}",
- e
- )),
- ))
- }
- },
- None => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body("Missing required query parameter issn"),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(api_impl.container_lookup_get(param_issn, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- ContainerLookupGetResponse::FindASingleContainerByExternalIdentifer
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(200).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::CONTAINER_LOOKUP_GET_FIND_A_SINGLE_CONTAINER_BY_EXTERNAL_IDENTIFER.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- ContainerLookupGetResponse::BadRequest
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(400).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::CONTAINER_LOOKUP_GET_BAD_REQUEST.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- ContainerLookupGetResponse::NoSuchContainer
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(404).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::CONTAINER_LOOKUP_GET_NO_SUCH_CONTAINER.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- ContainerLookupGetResponse::GenericErrorResponse
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(0).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::CONTAINER_LOOKUP_GET_GENERIC_ERROR_RESPONSE.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response.set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- },
- }
-
- future::ok(response)
- },
- ))
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // ContainerPost - POST /container
- &hyper::Method::Post if path.matched(paths::ID_CONTAINER) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Body parameters (note that non-required body parameters will ignore garbage
- // values, rather than causing a 400 response). Produce warning header and logs for
- // any unused fields.
- Box::new(body.concat2().then(
- move |result| -> Box<Future<Item = Response, Error = Error>> {
- match result {
- Ok(body) => {
- let mut unused_elements = Vec::new();
- let param_body: Option<
- models::ContainerEntity,
- > = if !body.is_empty() {
- let deserializer =
- &mut serde_json::Deserializer::from_slice(&*body);
-
- match serde_ignored::deserialize(deserializer, |path| {
- warn!("Ignoring unknown field in body: {}", path);
- unused_elements.push(path.to_string());
- }) {
- Ok(param_body) => param_body,
-
- Err(_) => None,
- }
- } else {
- None
- };
-
- Box::new(api_impl.container_post(param_body, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- if !unused_elements.is_empty() {
- response.headers_mut().set(Warning(format!(
- "Ignoring unknown fields in body: {:?}",
- unused_elements
- )));
- }
-
- match result {
- Ok(rsp) => match rsp {
- ContainerPostResponse::Created(body) => {
- response.set_status(
- StatusCode::try_from(201).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::CONTAINER_POST_CREATED.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- ContainerPostResponse::BadRequest(body) => {
- response.set_status(
- StatusCode::try_from(400).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::CONTAINER_POST_BAD_REQUEST.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- ContainerPostResponse::GenericErrorResponse(
- body,
- ) => {
- response.set_status(
- StatusCode::try_from(0).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::CONTAINER_POST_GENERIC_ERROR_RESPONSE.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response
- .set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- }
- }
-
- future::ok(response)
- },
- ))
- }
- Err(e) => Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!("Couldn't read body parameter body: {}", e)),
- )),
- }
- },
- )) as Box<Future<Item = Response, Error = Error>>
- }
-
- // CreatorIdGet - GET /creator/{id}
- &hyper::Method::Get if path.matched(paths::ID_CREATOR_ID) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Path parameters
- let path = uri.path().to_string();
- let path_params = paths::REGEX_CREATOR_ID.captures(&path).unwrap_or_else(|| {
- panic!(
- "Path {} matched RE CREATOR_ID in set but failed match against \"{}\"",
- path,
- paths::REGEX_CREATOR_ID.as_str()
- )
- });
-
- let param_id = match percent_encoding::percent_decode(path_params["id"].as_bytes())
- .decode_utf8()
- {
- Ok(param_id) => match param_id.parse::<String>() {
- Ok(param_id) => param_id,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!("Couldn't parse path parameter id: {}", e)),
- ))
- }
- },
- Err(_) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't percent-decode path parameter as UTF-8: {}",
- &path_params["id"]
- )),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(api_impl.creator_id_get(param_id, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- CreatorIdGetResponse::FetchASingleCreatorById(
- body,
- ) => {
- response.set_status(
- StatusCode::try_from(200).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::CREATOR_ID_GET_FETCH_A_SINGLE_CREATOR_BY_ID.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- CreatorIdGetResponse::BadRequest(body) => {
- response.set_status(
- StatusCode::try_from(400).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::CREATOR_ID_GET_BAD_REQUEST.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- CreatorIdGetResponse::GenericErrorResponse(
- body,
- ) => {
- response.set_status(
- StatusCode::try_from(0).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::CREATOR_ID_GET_GENERIC_ERROR_RESPONSE.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response
- .set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- }
- }
-
- future::ok(response)
- },
- ))
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // CreatorLookupGet - GET /creator/lookup
- &hyper::Method::Get if path.matched(paths::ID_CREATOR_LOOKUP) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Query parameters (note that non-required or collection query parameters will ignore garbage values, rather than causing a 400 response)
- let query_params = form_urlencoded::parse(
- uri.query().unwrap_or_default().as_bytes(),
- ).collect::<Vec<_>>();
- let param_orcid = query_params
- .iter()
- .filter(|e| e.0 == "orcid")
- .map(|e| e.1.to_owned())
- .nth(0);
- let param_orcid = match param_orcid {
- Some(param_orcid) => match param_orcid.parse::<String>() {
- Ok(param_orcid) => param_orcid,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't parse query parameter orcid - doesn't match schema: {}",
- e
- )),
- ))
- }
- },
- None => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body("Missing required query parameter orcid"),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(api_impl.creator_lookup_get(param_orcid, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- CreatorLookupGetResponse::FindASingleCreatorByExternalIdentifer
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(200).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::CREATOR_LOOKUP_GET_FIND_A_SINGLE_CREATOR_BY_EXTERNAL_IDENTIFER.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- CreatorLookupGetResponse::BadRequest
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(400).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::CREATOR_LOOKUP_GET_BAD_REQUEST.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- CreatorLookupGetResponse::NoSuchCreator
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(404).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::CREATOR_LOOKUP_GET_NO_SUCH_CREATOR.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- CreatorLookupGetResponse::GenericErrorResponse
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(0).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::CREATOR_LOOKUP_GET_GENERIC_ERROR_RESPONSE.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response.set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- },
- }
-
- future::ok(response)
- },
- ))
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // CreatorPost - POST /creator
- &hyper::Method::Post if path.matched(paths::ID_CREATOR) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Body parameters (note that non-required body parameters will ignore garbage
- // values, rather than causing a 400 response). Produce warning header and logs for
- // any unused fields.
- Box::new(body.concat2().then(
- move |result| -> Box<Future<Item = Response, Error = Error>> {
- match result {
- Ok(body) => {
- let mut unused_elements = Vec::new();
- let param_body: Option<
- models::CreatorEntity,
- > = if !body.is_empty() {
- let deserializer =
- &mut serde_json::Deserializer::from_slice(&*body);
-
- match serde_ignored::deserialize(deserializer, |path| {
- warn!("Ignoring unknown field in body: {}", path);
- unused_elements.push(path.to_string());
- }) {
- Ok(param_body) => param_body,
-
- Err(_) => None,
- }
- } else {
- None
- };
-
- Box::new(api_impl.creator_post(param_body, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- if !unused_elements.is_empty() {
- response.headers_mut().set(Warning(format!(
- "Ignoring unknown fields in body: {:?}",
- unused_elements
- )));
- }
-
- match result {
- Ok(rsp) => match rsp {
- CreatorPostResponse::Created(body) => {
- response.set_status(
- StatusCode::try_from(201).unwrap(),
- );
-
- response.headers_mut().set(ContentType(
- mimetypes::responses::CREATOR_POST_CREATED
- .clone(),
- ));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- CreatorPostResponse::BadRequest(body) => {
- response.set_status(
- StatusCode::try_from(400).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::CREATOR_POST_BAD_REQUEST.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- CreatorPostResponse::GenericErrorResponse(body) => {
- response.set_status(
- StatusCode::try_from(0).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::CREATOR_POST_GENERIC_ERROR_RESPONSE.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response
- .set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- }
- }
-
- future::ok(response)
- },
- ))
- }
- Err(e) => Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!("Couldn't read body parameter body: {}", e)),
- )),
- }
- },
- )) as Box<Future<Item = Response, Error = Error>>
- }
-
- // EditgroupIdAcceptPost - POST /editgroup/{id}/accept
- &hyper::Method::Post if path.matched(paths::ID_EDITGROUP_ID_ACCEPT) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Path parameters
- let path = uri.path().to_string();
- let path_params = paths::REGEX_EDITGROUP_ID_ACCEPT
- .captures(&path)
- .unwrap_or_else(|| {
- panic!("Path {} matched RE EDITGROUP_ID_ACCEPT in set but failed match against \"{}\"", path, paths::REGEX_EDITGROUP_ID_ACCEPT.as_str())
- });
-
- let param_id = match percent_encoding::percent_decode(path_params["id"].as_bytes())
- .decode_utf8()
- {
- Ok(param_id) => match param_id.parse::<i32>() {
- Ok(param_id) => param_id,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!("Couldn't parse path parameter id: {}", e)),
- ))
- }
- },
- Err(_) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't percent-decode path parameter as UTF-8: {}",
- &path_params["id"]
- )),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(
- api_impl.editgroup_id_accept_post(param_id, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- EditgroupIdAcceptPostResponse::MergedEditgroupSuccessfully_
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(200).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITGROUP_ID_ACCEPT_POST_MERGED_EDITGROUP_SUCCESSFULLY_.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- EditgroupIdAcceptPostResponse::EditgroupIsInAnUnmergableState
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(400).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITGROUP_ID_ACCEPT_POST_EDITGROUP_IS_IN_AN_UNMERGABLE_STATE.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- EditgroupIdAcceptPostResponse::NoSuchEditgroup
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(404).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITGROUP_ID_ACCEPT_POST_NO_SUCH_EDITGROUP.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- EditgroupIdAcceptPostResponse::GenericErrorResponse
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(0).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITGROUP_ID_ACCEPT_POST_GENERIC_ERROR_RESPONSE.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response.set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- },
- }
-
- future::ok(response)
- },
- ),
- )
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // EditgroupIdGet - GET /editgroup/{id}
- &hyper::Method::Get if path.matched(paths::ID_EDITGROUP_ID) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Path parameters
- let path = uri.path().to_string();
- let path_params = paths::REGEX_EDITGROUP_ID
- .captures(&path)
- .unwrap_or_else(|| {
- panic!("Path {} matched RE EDITGROUP_ID in set but failed match against \"{}\"", path, paths::REGEX_EDITGROUP_ID.as_str())
- });
-
- let param_id = match percent_encoding::percent_decode(path_params["id"].as_bytes())
- .decode_utf8()
- {
- Ok(param_id) => match param_id.parse::<i32>() {
- Ok(param_id) => param_id,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!("Couldn't parse path parameter id: {}", e)),
- ))
- }
- },
- Err(_) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't percent-decode path parameter as UTF-8: {}",
- &path_params["id"]
- )),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(api_impl.editgroup_id_get(param_id, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- EditgroupIdGetResponse::FetchEditgroupByIdentifier
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(200).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITGROUP_ID_GET_FETCH_EDITGROUP_BY_IDENTIFIER.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- EditgroupIdGetResponse::NoSuchEditgroup
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(404).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITGROUP_ID_GET_NO_SUCH_EDITGROUP.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- EditgroupIdGetResponse::GenericErrorResponse
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(0).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITGROUP_ID_GET_GENERIC_ERROR_RESPONSE.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response.set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- },
- }
-
- future::ok(response)
- },
- ))
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // EditgroupPost - POST /editgroup
- &hyper::Method::Post if path.matched(paths::ID_EDITGROUP) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- Box::new(
- ({
- {
- {
- Box::new(api_impl.editgroup_post(&context).then(move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- EditgroupPostResponse::SuccessfullyCreated(body) => {
- response
- .set_status(StatusCode::try_from(201).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITGROUP_POST_SUCCESSFULLY_CREATED.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- EditgroupPostResponse::InvalidRequestParameters(
- body,
- ) => {
- response
- .set_status(StatusCode::try_from(400).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITGROUP_POST_INVALID_REQUEST_PARAMETERS.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- EditgroupPostResponse::GenericErrorResponse(body) => {
- response
- .set_status(StatusCode::try_from(0).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITGROUP_POST_GENERIC_ERROR_RESPONSE.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response.set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- }
- }
-
- future::ok(response)
- }))
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // EditorUsernameChangelogGet - GET /editor/{username}/changelog
- &hyper::Method::Get if path.matched(paths::ID_EDITOR_USERNAME_CHANGELOG) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Path parameters
- let path = uri.path().to_string();
- let path_params = paths::REGEX_EDITOR_USERNAME_CHANGELOG
- .captures(&path)
- .unwrap_or_else(|| {
- panic!("Path {} matched RE EDITOR_USERNAME_CHANGELOG in set but failed match against \"{}\"", path, paths::REGEX_EDITOR_USERNAME_CHANGELOG.as_str())
- });
-
- let param_username = match percent_encoding::percent_decode(
- path_params["username"].as_bytes(),
- ).decode_utf8()
- {
- Ok(param_username) => match param_username.parse::<String>() {
- Ok(param_username) => param_username,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't parse path parameter username: {}",
- e
- )),
- ))
- }
- },
- Err(_) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't percent-decode path parameter as UTF-8: {}",
- &path_params["username"]
- )),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(
- api_impl
- .editor_username_changelog_get(param_username, &context)
- .then(move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- EditorUsernameChangelogGetResponse::FindChanges_
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(200).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITOR_USERNAME_CHANGELOG_GET_FIND_CHANGES_.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- EditorUsernameChangelogGetResponse::UsernameNotFound
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(404).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITOR_USERNAME_CHANGELOG_GET_USERNAME_NOT_FOUND.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- EditorUsernameChangelogGetResponse::GenericErrorResponse
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(0).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITOR_USERNAME_CHANGELOG_GET_GENERIC_ERROR_RESPONSE.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response.set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- },
- }
-
- future::ok(response)
- }),
- )
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // EditorUsernameGet - GET /editor/{username}
- &hyper::Method::Get if path.matched(paths::ID_EDITOR_USERNAME) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Path parameters
- let path = uri.path().to_string();
- let path_params = paths::REGEX_EDITOR_USERNAME.captures(&path).unwrap_or_else(
- || {
- panic!("Path {} matched RE EDITOR_USERNAME in set but failed match against \"{}\"", path, paths::REGEX_EDITOR_USERNAME.as_str())
- },
- );
-
- let param_username = match percent_encoding::percent_decode(
- path_params["username"].as_bytes(),
- ).decode_utf8()
- {
- Ok(param_username) => match param_username.parse::<String>() {
- Ok(param_username) => param_username,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't parse path parameter username: {}",
- e
- )),
- ))
- }
- },
- Err(_) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't percent-decode path parameter as UTF-8: {}",
- &path_params["username"]
- )),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(
- api_impl.editor_username_get(param_username, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- EditorUsernameGetResponse::FetchGenericInformationAboutAnEditor
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(200).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITOR_USERNAME_GET_FETCH_GENERIC_INFORMATION_ABOUT_AN_EDITOR.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- EditorUsernameGetResponse::UsernameNotFound
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(404).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITOR_USERNAME_GET_USERNAME_NOT_FOUND.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- EditorUsernameGetResponse::GenericErrorResponse
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(0).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::EDITOR_USERNAME_GET_GENERIC_ERROR_RESPONSE.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response.set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- },
- }
-
- future::ok(response)
- },
- ),
- )
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // FileIdGet - GET /file/{id}
- &hyper::Method::Get if path.matched(paths::ID_FILE_ID) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Path parameters
- let path = uri.path().to_string();
- let path_params = paths::REGEX_FILE_ID.captures(&path).unwrap_or_else(|| {
- panic!(
- "Path {} matched RE FILE_ID in set but failed match against \"{}\"",
- path,
- paths::REGEX_FILE_ID.as_str()
- )
- });
-
- let param_id = match percent_encoding::percent_decode(path_params["id"].as_bytes())
- .decode_utf8()
- {
- Ok(param_id) => match param_id.parse::<String>() {
- Ok(param_id) => param_id,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!("Couldn't parse path parameter id: {}", e)),
- ))
- }
- },
- Err(_) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't percent-decode path parameter as UTF-8: {}",
- &path_params["id"]
- )),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(api_impl.file_id_get(param_id, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- FileIdGetResponse::FetchASingleFileById(body) => {
- response.set_status(
- StatusCode::try_from(200).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::FILE_ID_GET_FETCH_A_SINGLE_FILE_BY_ID.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- FileIdGetResponse::BadRequest(body) => {
- response.set_status(
- StatusCode::try_from(400).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::FILE_ID_GET_BAD_REQUEST.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- FileIdGetResponse::GenericErrorResponse(body) => {
- response.set_status(
- StatusCode::try_from(0).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::FILE_ID_GET_GENERIC_ERROR_RESPONSE.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response
- .set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- }
- }
-
- future::ok(response)
- },
- ))
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // FileLookupGet - GET /file/lookup
- &hyper::Method::Get if path.matched(paths::ID_FILE_LOOKUP) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Query parameters (note that non-required or collection query parameters will ignore garbage values, rather than causing a 400 response)
- let query_params = form_urlencoded::parse(
- uri.query().unwrap_or_default().as_bytes(),
- ).collect::<Vec<_>>();
- let param_sha1 = query_params
- .iter()
- .filter(|e| e.0 == "sha1")
- .map(|e| e.1.to_owned())
- .nth(0);
- let param_sha1 = match param_sha1 {
- Some(param_sha1) => match param_sha1.parse::<String>() {
- Ok(param_sha1) => param_sha1,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't parse query parameter sha1 - doesn't match schema: {}",
- e
- )),
- ))
- }
- },
- None => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body("Missing required query parameter sha1"),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(api_impl.file_lookup_get(param_sha1, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- FileLookupGetResponse::FindASingleFileByExternalIdentifer
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(200).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::FILE_LOOKUP_GET_FIND_A_SINGLE_FILE_BY_EXTERNAL_IDENTIFER.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- FileLookupGetResponse::BadRequest
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(400).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::FILE_LOOKUP_GET_BAD_REQUEST.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- FileLookupGetResponse::NoSuchFile
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(404).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::FILE_LOOKUP_GET_NO_SUCH_FILE.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- FileLookupGetResponse::GenericErrorResponse
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(0).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::FILE_LOOKUP_GET_GENERIC_ERROR_RESPONSE.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response.set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- },
- }
-
- future::ok(response)
- },
- ))
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // FilePost - POST /file
- &hyper::Method::Post if path.matched(paths::ID_FILE) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Body parameters (note that non-required body parameters will ignore garbage
- // values, rather than causing a 400 response). Produce warning header and logs for
- // any unused fields.
- Box::new(body.concat2().then(
- move |result| -> Box<Future<Item = Response, Error = Error>> {
- match result {
- Ok(body) => {
- let mut unused_elements = Vec::new();
- let param_body: Option<
- models::FileEntity,
- > = if !body.is_empty() {
- let deserializer =
- &mut serde_json::Deserializer::from_slice(&*body);
-
- match serde_ignored::deserialize(deserializer, |path| {
- warn!("Ignoring unknown field in body: {}", path);
- unused_elements.push(path.to_string());
- }) {
- Ok(param_body) => param_body,
-
- Err(_) => None,
- }
- } else {
- None
- };
-
- Box::new(api_impl.file_post(param_body, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- if !unused_elements.is_empty() {
- response.headers_mut().set(Warning(format!(
- "Ignoring unknown fields in body: {:?}",
- unused_elements
- )));
- }
-
- match result {
- Ok(rsp) => match rsp {
- FilePostResponse::Created(body) => {
- response.set_status(
- StatusCode::try_from(201).unwrap(),
- );
-
- response.headers_mut().set(ContentType(
- mimetypes::responses::FILE_POST_CREATED
- .clone(),
- ));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- FilePostResponse::BadRequest(body) => {
- response.set_status(
- StatusCode::try_from(400).unwrap(),
- );
-
- response.headers_mut().set(ContentType(
- mimetypes::responses::FILE_POST_BAD_REQUEST
- .clone(),
- ));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- FilePostResponse::GenericErrorResponse(body) => {
- response.set_status(
- StatusCode::try_from(0).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::FILE_POST_GENERIC_ERROR_RESPONSE.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response
- .set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- }
- }
-
- future::ok(response)
- },
- ))
- }
- Err(e) => Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!("Couldn't read body parameter body: {}", e)),
- )),
- }
- },
- )) as Box<Future<Item = Response, Error = Error>>
- }
-
- // ReleaseIdGet - GET /release/{id}
- &hyper::Method::Get if path.matched(paths::ID_RELEASE_ID) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Path parameters
- let path = uri.path().to_string();
- let path_params = paths::REGEX_RELEASE_ID.captures(&path).unwrap_or_else(|| {
- panic!(
- "Path {} matched RE RELEASE_ID in set but failed match against \"{}\"",
- path,
- paths::REGEX_RELEASE_ID.as_str()
- )
- });
-
- let param_id = match percent_encoding::percent_decode(path_params["id"].as_bytes())
- .decode_utf8()
- {
- Ok(param_id) => match param_id.parse::<String>() {
- Ok(param_id) => param_id,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!("Couldn't parse path parameter id: {}", e)),
- ))
- }
- },
- Err(_) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't percent-decode path parameter as UTF-8: {}",
- &path_params["id"]
- )),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(api_impl.release_id_get(param_id, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- ReleaseIdGetResponse::FetchASingleReleaseById(
- body,
- ) => {
- response.set_status(
- StatusCode::try_from(200).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::RELEASE_ID_GET_FETCH_A_SINGLE_RELEASE_BY_ID.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- ReleaseIdGetResponse::BadRequest(body) => {
- response.set_status(
- StatusCode::try_from(400).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::RELEASE_ID_GET_BAD_REQUEST.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- ReleaseIdGetResponse::GenericErrorResponse(
- body,
- ) => {
- response.set_status(
- StatusCode::try_from(0).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::RELEASE_ID_GET_GENERIC_ERROR_RESPONSE.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response
- .set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- }
- }
-
- future::ok(response)
- },
- ))
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // ReleaseLookupGet - GET /release/lookup
- &hyper::Method::Get if path.matched(paths::ID_RELEASE_LOOKUP) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Query parameters (note that non-required or collection query parameters will ignore garbage values, rather than causing a 400 response)
- let query_params = form_urlencoded::parse(
- uri.query().unwrap_or_default().as_bytes(),
- ).collect::<Vec<_>>();
- let param_doi = query_params
- .iter()
- .filter(|e| e.0 == "doi")
- .map(|e| e.1.to_owned())
- .nth(0);
- let param_doi = match param_doi {
- Some(param_doi) => match param_doi.parse::<String>() {
- Ok(param_doi) => param_doi,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't parse query parameter doi - doesn't match schema: {}",
- e
- )),
- ))
- }
- },
- None => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body("Missing required query parameter doi"),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(api_impl.release_lookup_get(param_doi, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- ReleaseLookupGetResponse::FindASingleReleaseByExternalIdentifer
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(200).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::RELEASE_LOOKUP_GET_FIND_A_SINGLE_RELEASE_BY_EXTERNAL_IDENTIFER.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- ReleaseLookupGetResponse::BadRequest
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(400).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::RELEASE_LOOKUP_GET_BAD_REQUEST.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- ReleaseLookupGetResponse::NoSuchRelease
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(404).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::RELEASE_LOOKUP_GET_NO_SUCH_RELEASE.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- ReleaseLookupGetResponse::GenericErrorResponse
-
- (body)
-
-
- => {
- response.set_status(StatusCode::try_from(0).unwrap());
-
- response.headers_mut().set(ContentType(mimetypes::responses::RELEASE_LOOKUP_GET_GENERIC_ERROR_RESPONSE.clone()));
-
-
- let body = serde_json::to_string(&body).expect("impossible to fail to serialize");
-
- response.set_body(body);
- },
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response.set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- },
- }
-
- future::ok(response)
- },
- ))
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // ReleasePost - POST /release
- &hyper::Method::Post if path.matched(paths::ID_RELEASE) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Body parameters (note that non-required body parameters will ignore garbage
- // values, rather than causing a 400 response). Produce warning header and logs for
- // any unused fields.
- Box::new(body.concat2().then(
- move |result| -> Box<Future<Item = Response, Error = Error>> {
- match result {
- Ok(body) => {
- let mut unused_elements = Vec::new();
- let param_body: Option<
- models::ReleaseEntity,
- > = if !body.is_empty() {
- let deserializer =
- &mut serde_json::Deserializer::from_slice(&*body);
-
- match serde_ignored::deserialize(deserializer, |path| {
- warn!("Ignoring unknown field in body: {}", path);
- unused_elements.push(path.to_string());
- }) {
- Ok(param_body) => param_body,
-
- Err(_) => None,
- }
- } else {
- None
- };
-
- Box::new(api_impl.release_post(param_body, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- if !unused_elements.is_empty() {
- response.headers_mut().set(Warning(format!(
- "Ignoring unknown fields in body: {:?}",
- unused_elements
- )));
- }
-
- match result {
- Ok(rsp) => match rsp {
- ReleasePostResponse::Created(body) => {
- response.set_status(
- StatusCode::try_from(201).unwrap(),
- );
-
- response.headers_mut().set(ContentType(
- mimetypes::responses::RELEASE_POST_CREATED
- .clone(),
- ));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- ReleasePostResponse::BadRequest(body) => {
- response.set_status(
- StatusCode::try_from(400).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::RELEASE_POST_BAD_REQUEST.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- ReleasePostResponse::GenericErrorResponse(body) => {
- response.set_status(
- StatusCode::try_from(0).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::RELEASE_POST_GENERIC_ERROR_RESPONSE.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response
- .set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- }
- }
-
- future::ok(response)
- },
- ))
- }
- Err(e) => Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!("Couldn't read body parameter body: {}", e)),
- )),
- }
- },
- )) as Box<Future<Item = Response, Error = Error>>
- }
-
- // WorkIdGet - GET /work/{id}
- &hyper::Method::Get if path.matched(paths::ID_WORK_ID) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Path parameters
- let path = uri.path().to_string();
- let path_params = paths::REGEX_WORK_ID.captures(&path).unwrap_or_else(|| {
- panic!(
- "Path {} matched RE WORK_ID in set but failed match against \"{}\"",
- path,
- paths::REGEX_WORK_ID.as_str()
- )
- });
-
- let param_id = match percent_encoding::percent_decode(path_params["id"].as_bytes())
- .decode_utf8()
- {
- Ok(param_id) => match param_id.parse::<String>() {
- Ok(param_id) => param_id,
- Err(e) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!("Couldn't parse path parameter id: {}", e)),
- ))
- }
- },
- Err(_) => {
- return Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!(
- "Couldn't percent-decode path parameter as UTF-8: {}",
- &path_params["id"]
- )),
- ))
- }
- };
-
- Box::new(
- ({
- {
- {
- Box::new(api_impl.work_id_get(param_id, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- match result {
- Ok(rsp) => match rsp {
- WorkIdGetResponse::FetchASingleWorkById(body) => {
- response.set_status(
- StatusCode::try_from(200).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::WORK_ID_GET_FETCH_A_SINGLE_WORK_BY_ID.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- WorkIdGetResponse::BadRequest(body) => {
- response.set_status(
- StatusCode::try_from(400).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::WORK_ID_GET_BAD_REQUEST.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- WorkIdGetResponse::GenericErrorResponse(body) => {
- response.set_status(
- StatusCode::try_from(0).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::WORK_ID_GET_GENERIC_ERROR_RESPONSE.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response
- .set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- }
- }
-
- future::ok(response)
- },
- ))
- }
- }
- }),
- ) as Box<Future<Item = Response, Error = Error>>
- }
-
- // WorkPost - POST /work
- &hyper::Method::Post if path.matched(paths::ID_WORK) => {
- if context.x_span_id.is_none() {
- context.x_span_id = Some(
- headers
- .get::<XSpanId>()
- .map(XSpanId::to_string)
- .unwrap_or_else(|| self::uuid::Uuid::new_v4().to_string()),
- );
- }
-
- // Body parameters (note that non-required body parameters will ignore garbage
- // values, rather than causing a 400 response). Produce warning header and logs for
- // any unused fields.
- Box::new(body.concat2().then(
- move |result| -> Box<Future<Item = Response, Error = Error>> {
- match result {
- Ok(body) => {
- let mut unused_elements = Vec::new();
- let param_body: Option<
- models::WorkEntity,
- > = if !body.is_empty() {
- let deserializer =
- &mut serde_json::Deserializer::from_slice(&*body);
-
- match serde_ignored::deserialize(deserializer, |path| {
- warn!("Ignoring unknown field in body: {}", path);
- unused_elements.push(path.to_string());
- }) {
- Ok(param_body) => param_body,
-
- Err(_) => None,
- }
- } else {
- None
- };
-
- Box::new(api_impl.work_post(param_body, &context).then(
- move |result| {
- let mut response = Response::new();
- context.x_span_id.as_ref().map(|header| {
- response.headers_mut().set(XSpanId(header.clone()))
- });
-
- if !unused_elements.is_empty() {
- response.headers_mut().set(Warning(format!(
- "Ignoring unknown fields in body: {:?}",
- unused_elements
- )));
- }
-
- match result {
- Ok(rsp) => match rsp {
- WorkPostResponse::Created(body) => {
- response.set_status(
- StatusCode::try_from(201).unwrap(),
- );
-
- response.headers_mut().set(ContentType(
- mimetypes::responses::WORK_POST_CREATED
- .clone(),
- ));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- WorkPostResponse::BadRequest(body) => {
- response.set_status(
- StatusCode::try_from(400).unwrap(),
- );
-
- response.headers_mut().set(ContentType(
- mimetypes::responses::WORK_POST_BAD_REQUEST
- .clone(),
- ));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- WorkPostResponse::GenericErrorResponse(body) => {
- response.set_status(
- StatusCode::try_from(0).unwrap(),
- );
-
- response.headers_mut().set(ContentType(mimetypes::responses::WORK_POST_GENERIC_ERROR_RESPONSE.clone()));
-
- let body = serde_json::to_string(&body)
- .expect("impossible to fail to serialize");
-
- response.set_body(body);
- }
- },
- Err(_) => {
- // Application code returned an error. This should not happen, as the implementation should
- // return a valid response.
- response
- .set_status(StatusCode::InternalServerError);
- response.set_body("An internal error occurred");
- }
- }
-
- future::ok(response)
- },
- ))
- }
- Err(e) => Box::new(future::ok(
- Response::new()
- .with_status(StatusCode::BadRequest)
- .with_body(format!("Couldn't read body parameter body: {}", e)),
- )),
- }
- },
- )) as Box<Future<Item = Response, Error = Error>>
- }
-
- _ => Box::new(future::ok(
- Response::new().with_status(StatusCode::NotFound),
- )) as Box<Future<Item = Response, Error = Error>>,
- }
- }
-}