use failure::*;
use serde_json::{json, Value};
-use crate::api_schema::router::RpcEnvironment;
+use crate::api_schema::router::{HttpError, RpcEnvironment};
use hyper::{Body, Response, StatusCode};
use hyper::header;
fn json_format_error(err: Error) -> Response<Body> {
- let mut response = Response::new(Body::from(err.to_string()));
+ let mut response = if let Some(apierr) = err.downcast_ref::<HttpError>() {
+ let mut resp = Response::new(Body::from(apierr.message.clone()));
+ *resp.status_mut() = apierr.code;
+ resp
+ } else {
+ let mut resp = Response::new(Body::from(err.to_string()));
+ *resp.status_mut() = StatusCode::BAD_REQUEST;
+ resp
+ };
+
response.headers_mut().insert(
header::CONTENT_TYPE,
header::HeaderValue::from_static(JSON_CONTENT_TYPE));
- *response.status_mut() = StatusCode::BAD_REQUEST;
response.extensions_mut().insert(ErrorMessageExtension(err.to_string()));
if method != hyper::Method::GET {
if let Some(token) = token {
- println!("CSRF prev token: {:?}", token);
+ println!("CSRF prevention token: {:?}", token);
verify_csrf_prevention_token(csrf_secret(), &username, &token, -300, ticket_lifetime)?;
} else {
- bail!("");
+ bail!("missing CSRF prevention token");
}
}