lingxia-lxapp 0.7.0

LxApp (lightweight application) container and runtime for LingXia framework
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
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99

/// Internal helper macro for defining synchronous Host APIs.
///
/// Not exported; only usable within `lingxia-lxapp`.
macro_rules! host_api {
    // With parameter
    ($name:ident, $input:ty, $output:ty, |$lxapp:ident, $param:ident| $body:block) => {
        pub(crate) struct $name;

        impl $crate::host::HostHandler for $name {
            fn call<'a>(
                &'a self,
                $lxapp: std::sync::Arc<$crate::LxApp>,
                input: Option<String>,
                _cancel: $crate::host::HostCancel,
            ) -> $crate::host::HostFuture<'a> {
                Box::pin(async move {
                    let $param: $input = $crate::host::parse_input(input.as_deref())?;
                    // Wrap in a closure so `return` inside `$body` returns from the closure,
                    // not from this async block (which must return JSON string).
                    let result: Result<$output, $crate::LxAppError> = (|| $body)();
                    $crate::host::serialize_result(result)
                })
            }
        }
    };

    // No parameter
    ($name:ident, $output:ty, |$lxapp:ident| $body:block) => {
        pub(crate) struct $name;

        impl $crate::host::HostHandler for $name {
            fn call<'a>(
                &'a self,
                $lxapp: std::sync::Arc<$crate::LxApp>,
                _input: Option<String>,
                _cancel: $crate::host::HostCancel,
            ) -> $crate::host::HostFuture<'a> {
                Box::pin(async move {
                    let result: Result<$output, $crate::LxAppError> = (|| $body)();
                    $crate::host::serialize_result(result)
                })
            }
        }
    };
}

/// Internal helper macro for defining async Host APIs with cancel.
///
/// Not exported; only usable within `lingxia-lxapp`.
macro_rules! host_api_async {
    // With parameter
    ($name:ident, $input:ty, $output:ty, |$lxapp:ident, $param:ident, $cancel:ident| async $body:block) => {
        pub(crate) struct $name;

        impl $crate::host::HostHandler for $name {
            fn call<'a>(
                &'a self,
                $lxapp: std::sync::Arc<$crate::LxApp>,
                input: Option<String>,
                mut $cancel: $crate::host::HostCancel,
            ) -> $crate::host::HostFuture<'a> {
                Box::pin(async move {
                    let $param: $input = $crate::host::parse_input(input.as_deref())?;
                    // Wrap in an async block so `return` inside `$body` returns from the inner
                    // block, not from this async block (which must return JSON string).
                    let result: Result<$output, $crate::LxAppError> = (async move { $body }).await;
                    $crate::host::serialize_result(result)
                })
            }
        }
    };

    // No parameter
    ($name:ident, $output:ty, |$lxapp:ident, $cancel:ident| async $body:block) => {
        pub(crate) struct $name;

        impl $crate::host::HostHandler for $name {
            fn call<'a>(
                &'a self,
                $lxapp: std::sync::Arc<$crate::LxApp>,
                _input: Option<String>,
                mut $cancel: $crate::host::HostCancel,
            ) -> $crate::host::HostFuture<'a> {
                Box::pin(async move {
                    let result: Result<$output, $crate::LxAppError> = (async move { $body }).await;
                    $crate::host::serialize_result(result)
                })
            }
        }
    };
}

macro_rules! register_host_module {
    ($namespace:literal, { $($method:literal => $handler:expr),+ $(,)? }) => {{
        $(
            $crate::host::register_host_route($namespace, $method, $handler);
        )+
    }};
}