hyperlane-macros 21.0.0

A comprehensive collection of procedural macros for building HTTP servers with enhanced functionality. This crate provides attribute macros that simplify HTTP request handling, protocol validation, response management, and request data extraction.
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

use crate::*;

/// Tries to send data via stream after function execution.
///
/// If an attribute argument is provided, it is used as the data to send.
/// If no argument is provided, the response is built from the context automatically.
///
/// # Arguments
///
/// - `TokenStream` - Optional attribute containing the data expression to send.
/// - `TokenStream` - The input token stream to process.
/// - `Position` - The position to inject the code.
///
/// # Returns
///
/// - `TokenStream` - The expanded token stream with try send operation.
pub(crate) fn try_send_macro(
    attr: TokenStream,
    item: TokenStream,
    position: Position,
) -> TokenStream {
    let data_expr: Option<Expr> = if attr.is_empty() {
        None
    } else {
        let data: SendData = parse_macro_input!(attr as SendData);
        Some(data.data)
    };
    inject(position, item, |context, stream| match data_expr {
        Some(expr) => {
            quote! {
                let _ = #stream.try_send(#expr).await;
            }
        }
        None => {
            quote! {
                let _ = #stream.try_send(#context.get_mut_response().build()).await;
            }
        }
    })
}

/// Sends data via stream after function execution, panics on failure.
///
/// If an attribute argument is provided, it is used as the data to send.
/// If no argument is provided, the response is built from the context automatically.
///
/// # Arguments
///
/// - `TokenStream` - Optional attribute containing the data expression to send.
/// - `TokenStream` - The input token stream to process.
/// - `Position` - The position to inject the code.
///
/// # Returns
///
/// - `TokenStream` - The expanded token stream with send operation that panics on failure.
pub(crate) fn send_macro(attr: TokenStream, item: TokenStream, position: Position) -> TokenStream {
    let data_expr: Option<Expr> = if attr.is_empty() {
        None
    } else {
        let data: SendData = parse_macro_input!(attr as SendData);
        Some(data.data)
    };
    inject(position, item, |context, stream| match data_expr {
        Some(expr) => {
            quote! {
                #stream.send(#expr).await;
            }
        }
        None => {
            quote! {
                #stream.send(#context.get_mut_response().build()).await;
            }
        }
    })
}