locutus 0.0.3

Locutus P2P network main node implementation
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

use warp::{hyper::StatusCode, reject::Reject, reply, Rejection, Reply};

use super::*;

pub(super) async fn handle_error(err: Rejection) -> Result<impl Reply, std::convert::Infallible> {
    if let Some(e) = err.find::<errors::InvalidParam>() {
        return Ok(reply::with_status(e.0.to_owned(), StatusCode::BAD_REQUEST));
    }
    if err.find::<errors::NodeError>().is_some() {
        return Ok(reply::with_status(
            "Node unavailable".to_owned(),
            StatusCode::BAD_GATEWAY,
        ));
    }
    Ok(reply::with_status(
        "INTERNAL SERVER ERROR".to_owned(),
        StatusCode::INTERNAL_SERVER_ERROR,
    ))
}

#[derive(Debug)]
pub(super) struct InvalidParam(pub String);

impl Reject for InvalidParam {}

#[derive(Debug)]
pub(super) struct NodeError;

impl Reject for NodeError {}

#[derive(Debug)]
pub(super) struct HttpError(pub warp::http::StatusCode);

impl Reject for HttpError {}