myko-macros 4.4.0

myko macros
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
84
85
86
87
88

use proc_macro2::TokenStream;
use quote::quote;
use syn::ItemStruct;

/// Generates a saga registration entry and a typed Saga impl.
///
/// `#[myko_saga]` on a struct generates a `Saga` implementation that delegates
/// business logic to `impl SagaHandler for Struct`.
pub fn myko_saga_impl(attr: TokenStream, input_struct: ItemStruct) -> TokenStream {
    if !attr.is_empty() {
        return syn::Error::new(
            proc_macro2::Span::call_site(),
            "#[myko_saga] no longer accepts arguments; use SagaHandler associated types/consts",
        )
        .to_compile_error();
    }

    let struct_name = &input_struct.ident;
    let struct_name_str = struct_name.to_string();
    let krate = crate::myko_path();

    quote! {
        #input_struct

        impl #krate::saga::Saga for #struct_name {
            type State = ();
            type Command = <#struct_name as #krate::saga::SagaHandler>::Command;

            fn name() -> &'static str {
                #struct_name_str
            }

            fn build(
                events: #krate::saga::EventStream,
                ctx: std::sync::Arc<#krate::saga::SagaContext>,
            ) -> #krate::futures::stream::BoxStream<'static, Self::Command> {
                use #krate::futures::StreamExt as _;
                use #krate::saga::SagaStreamExt as _;

                Box::pin(
                    events
                        .of_item_type(<<#struct_name as #krate::saga::SagaHandler>::EventItem as #krate::item::Eventable>::ENTITY_NAME_STATIC)
                        .of_change_type(<#struct_name as #krate::saga::SagaHandler>::EVENT_TYPE)
                        .filter_map(move |event| {
                            let ctx = ctx.clone();
                            async move {
                                log::debug!(
                                    "{} matched event item_type={} change_type={:?} tx={}",
                                    #struct_name_str,
                                    event.item_type,
                                    event.change_type,
                                    event.tx
                                );
                                let item = match #krate::serde_json::from_value::<<#struct_name as #krate::saga::SagaHandler>::EventItem>(event.item.clone()) {
                                    Ok(item) => item,
                                    Err(err) => {
                                        log::warn!(
                                            "{}: failed to deserialize {} event item: {}",
                                            #struct_name_str,
                                            <<#struct_name as #krate::saga::SagaHandler>::EventItem as #krate::item::Eventable>::ENTITY_NAME_STATIC,
                                            err
                                        );
                                        return None;
                                    }
                                };

                                let out = <#struct_name as #krate::saga::SagaHandler>::handle(item, event, ctx);
                                if out.is_some() {
                                    log::debug!("{} emitted command", #struct_name_str);
                                } else {
                                    log::debug!("{} emitted no command", #struct_name_str);
                                }
                                out
                            }
                        }),
                )
            }
        }

        #[cfg(not(target_arch = "wasm32"))]
        #krate::submit! {
            #krate::saga::SagaRegistration {
                saga_id: #struct_name_str,
                create: || std::sync::Arc::new(#struct_name) as std::sync::Arc<dyn #krate::saga::AnySaga>,
            }
        }
    }
}