ohkami 0.24.9

A performant, declarative, and runtime-flexible web framework for Rust
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
79
80
81
82
83

use crate::fang::{FangAction, SendSyncOnThreaded};
use crate::{FromRequest, Request, Response};

/// # Request Context
///
/// Memorize and retrieve any data within a request.
///
/// <br>
///
/// ```no_run
/// use ohkami::prelude::*;
/// use std::sync::Arc;
///
/// #[tokio::main]
/// async fn main() {
///     let sample_data = Arc::new(String::from("ohkami"));
///
///     Ohkami::new((
///         Context::new(sample_data), // <--
///         "/hello"
///             .GET(hello),
///     )).howl("0.0.0.0:8080").await
/// }
///
/// async fn hello(
///     Context(name): Context<'_, Arc<String>>, // <--
/// ) -> String {
///     format!("Hello, {name}!")
/// }
/// ```
#[derive(Clone, Debug)]
pub struct Context<'req, T: SendSyncOnThreaded + 'static>(pub &'req T);

impl<T: SendSyncOnThreaded + 'static> Context<'static, T>
where
    T: Clone,
{
    /// Initialize a `FangAction` that sets the context data.
    #[allow(clippy::new_ret_no_self)]
    pub fn new(data: T) -> impl FangAction {
        return ContextAction(data);

        #[derive(Clone)]
        struct ContextAction<T: Clone + SendSyncOnThreaded + 'static>(T);

        impl<T: Clone + SendSyncOnThreaded + 'static> FangAction for ContextAction<T> {
            #[inline]
            async fn fore<'a>(&'a self, req: &'a mut Request) -> Result<(), Response> {
                req.context.set(self.0.clone());
                Ok(())
            }
        }
    }
}

impl<'req, T: SendSyncOnThreaded + 'static> FromRequest<'req> for Context<'req, T> {
    type Error = std::convert::Infallible;

    #[inline]
    fn from_request(req: &'req crate::Request) -> Option<Result<Self, Self::Error>> {
        match req.context.get::<T>() {
            Some(d) => Some(Ok(Self(d))),
            None => {
                #[cfg(debug_assertions)]
                {
                    crate::WARNING!("Context of `{}` doesn't exist", std::any::type_name::<T>())
                }
                None
            }
        }
    }
}

#[cfg(test)]
mod test {
    #[test]
    fn context_fang_bount() {
        use crate::fang::{BoxedFPC, Fang};
        fn assert_fang<T: Fang<BoxedFPC>>(_: T) {}

        assert_fang(super::Context::new(String::new()));
    }
}