uxar-macros 0.1.1

Procedural macros for the uxar web framework
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

//! Periodic macro implementation using bundlepart infrastructure.
//!
//! Provides #[periodic] attribute macro for periodic task handlers.
//! Delegates to bundlepart.rs for consistent code generation.

use darling::FromMeta;
use proc_macro::TokenStream;
use quote::quote;

use crate::bundlepart::{self, FnSpec};

/// Periodic configuration metadata.
///
/// Maps to uxar::emitters::PeriodicConf runtime structure.
#[derive(Debug, FromMeta, Default)]
struct PeriodicConfMeta {
    /// Duration in seconds
    #[darling(default)]
    secs: Option<u64>,
    
    /// Duration in milliseconds
    #[darling(default)]
    millis: Option<u64>,
    
    /// Optional target configuration
    #[darling(default)]
    target: Option<String>,
}

/// Entry point for #[periodic] macro.
///
/// Handles both free functions and methods in impl blocks.
pub(crate) fn parse_periodic(attr: TokenStream, item: TokenStream) -> TokenStream {
    bundlepart::generate_bundle_part::<PeriodicConfMeta>(
        attr,
        item,
        "periodic",
        build_periodic_conf,
    )
}

/// Build PeriodicConf from parsed metadata and function spec.
///
/// Validates duration parameters and generates PeriodicConf construction.
fn build_periodic_conf(
    conf: &PeriodicConfMeta,
    _spec: &FnSpec,
) -> Result<proc_macro2::TokenStream, syn::Error> {
    let interval = match (conf.secs, conf.millis) {
        (Some(s), None) => quote! { ::tokio::time::Duration::from_secs(#s) },
        (None, Some(m)) => quote! { ::tokio::time::Duration::from_millis(#m) },
        (Some(s), Some(m)) => {
            quote! { ::tokio::time::Duration::from_secs(#s) + ::tokio::time::Duration::from_millis(#m) }
        }
        (None, None) => {
            return Err(syn::Error::new(
                proc_macro2::Span::call_site(),
                "Periodic requires at least one of: secs, millis. Use: #[periodic(secs = 60)] or #[periodic(millis = 1000)]"
            ));
        }
    };
    
    let target = if let Some(target_str) = &conf.target {
        quote! { ::uxar::emitters::EmitTarget::from_str(#target_str).unwrap_or_default() }
    } else {
        quote! { ::uxar::emitters::EmitTarget::default() }
    };

    Ok(quote! {
        ::uxar::emitters::PeriodicConf {
            interval: #interval,
            target: #target,
        }
    })
}