maf 0.1.0-alpha.6

MAF is an authoritative realtime framework for writing simple, secure, and scalable apps.
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

use std::future::Future;

use crate::{callable::SupportsAsync, App, User};

/// A parameter that could appear in a callable function (e.g. `rpc` or `on_connect`).
///
/// This trait is used to extract the parameter from the context and/or initialize it from
/// parameters used to create the callable function.
pub trait CallableParam<Ctx, Init>: Send + Sync + Sized {
    type Error: std::error::Error + Send;

    fn extract(
        ctx: &mut Ctx,
        init: &Init,
    ) -> impl Future<Output = Result<Self, Self::Error>> + Send + Sync;
}

/// A trait for simple types that can be used as parameters in callable functions.
pub trait CallableFetch<T>: Send + Sync {
    fn fetch(&self) -> T;
}

// Implement `CallableParams` for common types
macro_rules! impl_callable_param_fetch {
    ($t:ty) => {
        impl<Ctx: CallableFetch<$t>, Init: Send + Sync> CallableParam<Ctx, Init> for $t {
            type Error = std::convert::Infallible;

            async fn extract(ctx: &mut Ctx, _init: &Init) -> Result<Self, Self::Error> {
                Ok(ctx.fetch())
            }
        }
    };
}

impl_callable_param_fetch!(User);
impl_callable_param_fetch!(App);

impl SupportsAsync for User {}
impl SupportsAsync for App {}