nestrs 0.3.3

NestJS-like API framework for Rust on top of Axum and Tower.
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

use crate::core::ExecutionContext;
use axum::extract::Request;
use axum::http::request::Parts;
use axum::http::StatusCode;
use axum::middleware::Next;
use axum::response::{IntoResponse, Response};
use std::ops::Deref;

pub(crate) async fn install_execution_context_middleware(req: Request, next: Next) -> Response {
    let (mut parts, body) = req.into_parts();
    let ctx = ExecutionContext::from_http_parts(&parts);
    parts.extensions.insert(ctx);
    next.run(Request::from_parts(parts, body)).await
}

/// Axum extractor for [`ExecutionContext`] (Nest-style `ArgumentsHost` snapshot).
///
/// Enable with [`crate::NestApplication::use_execution_context`].
#[derive(Clone, Debug)]
pub struct HttpExecutionContext(pub ExecutionContext);

impl Deref for HttpExecutionContext {
    type Target = ExecutionContext;

    fn deref(&self) -> &Self::Target {
        &self.0
    }
}

/// Returned when [`HttpExecutionContext`] is used but the app did not enable
/// [`crate::NestApplication::use_execution_context`].
#[derive(Debug)]
pub struct ExecutionContextMissing;

impl IntoResponse for ExecutionContextMissing {
    fn into_response(self) -> Response {
        (
            StatusCode::INTERNAL_SERVER_ERROR,
            "nestrs: HttpExecutionContext extractor requires NestApplication::use_execution_context()",
        )
            .into_response()
    }
}

#[async_trait::async_trait]
impl<S> axum::extract::FromRequestParts<S> for HttpExecutionContext
where
    S: Send + Sync,
{
    type Rejection = ExecutionContextMissing;

    async fn from_request_parts(parts: &mut Parts, _state: &S) -> Result<Self, Self::Rejection> {
        parts
            .extensions
            .get::<ExecutionContext>()
            .cloned()
            .map(HttpExecutionContext)
            .ok_or(ExecutionContextMissing)
    }
}