es_entity_macros/
lib.rs

1#![cfg_attr(feature = "fail-on-warnings", deny(warnings))]
2#![cfg_attr(feature = "fail-on-warnings", deny(clippy::all))]
3
4mod entity;
5mod event;
6mod query;
7mod repo;
8mod retry_on_concurrent_modification;
9
10use proc_macro::TokenStream;
11use syn::parse_macro_input;
12
13#[proc_macro_derive(EsEvent, attributes(es_event))]
14pub fn es_event_derive(input: TokenStream) -> TokenStream {
15    let ast = parse_macro_input!(input as syn::DeriveInput);
16    match event::derive(ast) {
17        Ok(tokens) => tokens.into(),
18        Err(e) => e.write_errors().into(),
19    }
20}
21
22#[proc_macro_attribute]
23pub fn retry_on_concurrent_modification(args: TokenStream, input: TokenStream) -> TokenStream {
24    let ast = parse_macro_input!(input as syn::ItemFn);
25    match retry_on_concurrent_modification::make(args, ast) {
26        Ok(tokens) => tokens.into(),
27        Err(e) => e.write_errors().into(),
28    }
29}
30
31#[proc_macro_derive(EsEntity, attributes(es_entity))]
32pub fn es_entity_derive(input: TokenStream) -> TokenStream {
33    let ast = parse_macro_input!(input as syn::DeriveInput);
34    match entity::derive(ast) {
35        Ok(tokens) => tokens.into(),
36        Err(e) => e.write_errors().into(),
37    }
38}
39
40#[proc_macro_derive(EsRepo, attributes(es_repo))]
41pub fn es_repo_derive(input: TokenStream) -> TokenStream {
42    let ast = parse_macro_input!(input as syn::DeriveInput);
43    match repo::derive(ast) {
44        Ok(tokens) => tokens.into(),
45        Err(e) => e.write_errors().into(),
46    }
47}
48
49#[proc_macro]
50pub fn expand_es_query(input: TokenStream) -> TokenStream {
51    let input = parse_macro_input!(input as query::QueryInput);
52    match query::expand(input) {
53        Ok(tokens) => tokens.into(),
54        Err(e) => e.write_errors().into(),
55    }
56}
es_entity_macros/lib.rs

es_entity_macros/
lib.rs
