actix_tower 0.1.1

Modern extensions for Actix Web — Tower compatibility, ergonomic extractors, and production-ready middleware.
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

//! `extract!` macro for defining custom extractors.

/// Define a custom extractor that wraps an existing Actix extractor.
///
/// # Example
///
/// ```no_run
/// use actix_tower::prelude::*;
/// use serde::Deserialize;
///
/// #[derive(Deserialize)]
/// pub struct User { name: String }
///
/// extract!(UserJson = User, Json);
/// ```
#[macro_export]
macro_rules! extract {
    ($name:ident = $inner:ty, $wrapper:ident) => {
        pub struct $name(pub $inner);

        impl std::ops::Deref for $name {
            type Target = $inner;
            fn deref(&self) -> &$inner {
                &self.0
            }
        }

        impl actix_web::FromRequest for $name
        where
            $inner: serde::de::DeserializeOwned + 'static,
        {
            type Error = actix_web::Error;
            type Future =
                std::pin::Pin<Box<dyn std::future::Future<Output = Result<Self, Self::Error>>>>;

            fn from_request(
                req: &actix_web::HttpRequest,
                payload: &mut actix_web::dev::Payload,
            ) -> Self::Future {
                use actix_web::FromRequest;
                let req = req.clone();
                let mut payload = std::mem::replace(payload, actix_web::dev::Payload::None);
                Box::pin(async move {
                    let inner =
                        actix_web::web::$wrapper::<$inner>::from_request(&req, &mut payload)
                            .await?;
                    Ok($name(inner.into_inner()))
                })
            }
        }
    };
}

pub use extract;