shield-axum 0.3.1

Axum integration for Shield.
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

use axum::{
    Json,
    http::StatusCode,
    response::{IntoResponse, Response},
};
use serde::Serialize;
use shield::{ActionError, MethodError, ProviderError, ShieldError, StorageError};

#[derive(Serialize)]
#[cfg_attr(feature = "utoipa", derive(utoipa::ToSchema))]
#[cfg_attr(feature = "utoipa", schema(as = Error, examples(
    json!({
        "status_code": 500,
        "status_reason": "Internal Server Error",
        "message": "Unknown"
    })
)))]
#[serde(rename_all = "camelCase")]
pub struct ErrorBody {
    status_code: u16,
    status_reason: Option<String>,
    message: String,
}

impl ErrorBody {
    fn new(status_code: StatusCode, error: ShieldError) -> Self {
        Self {
            status_code: status_code.as_u16(),
            status_reason: status_code.canonical_reason().map(ToOwned::to_owned),
            message: error.to_string(),
        }
    }
}

#[derive(Debug)]
pub struct RouteError(ShieldError);

impl RouteError {
    pub fn inner(&self) -> &ShieldError {
        &self.0
    }
}

impl IntoResponse for RouteError {
    fn into_response(self) -> Response {
        let status_code = match &self.0 {
            ShieldError::Method(method_error) => match method_error {
                MethodError::NotFound(_) => StatusCode::NOT_FOUND,
            },
            ShieldError::Action(action_error) => match action_error {
                ActionError::NotFound(_) => StatusCode::NOT_FOUND,
            },
            ShieldError::Provider(provider_error) => match provider_error {
                ProviderError::Missing => StatusCode::BAD_REQUEST,
                ProviderError::NotFound(_) => StatusCode::NOT_FOUND,
            },
            ShieldError::Configuration(_) => StatusCode::INTERNAL_SERVER_ERROR,
            ShieldError::Session(_) => StatusCode::INTERNAL_SERVER_ERROR,
            ShieldError::Storage(storage_error) => match storage_error {
                StorageError::Configuration(_) => StatusCode::INTERNAL_SERVER_ERROR,
                StorageError::Validation(_) => StatusCode::BAD_REQUEST,
                StorageError::NotFound(_, _) => StatusCode::NOT_FOUND,
                StorageError::Engine(_) => StatusCode::INTERNAL_SERVER_ERROR,
            },
            ShieldError::Request(_) => StatusCode::INTERNAL_SERVER_ERROR,
            ShieldError::Validation(_) => StatusCode::BAD_REQUEST,
            ShieldError::Unauthorized => StatusCode::UNAUTHORIZED,
        };

        (status_code, Json(ErrorBody::new(status_code, self.0))).into_response()
    }
}

impl From<ShieldError> for RouteError {
    fn from(value: ShieldError) -> Self {
        Self(value)
    }
}