pdk-macros 1.6.0

PDK 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

// Copyright (c) 2025, Salesforce, Inc.,
// All rights reserved.
// For full license text, see the LICENSE.txt file

mod args;

#[cfg(test)]
mod tests;

use args::Args;
use proc_macro2::TokenStream;
use quote::quote;
use std::iter::FromIterator;
use syn::{parse2, Error, ItemFn};

pub fn generate_entrypoint(
    metadata: TokenStream,
    input: TokenStream,
) -> Result<TokenStream, Error> {
    let annotated_fn = input.clone();
    let input_fn: ItemFn = parse2(input)?;
    let args: Args = parse2(metadata)?;

    let generated_code = emit_entrypoint(args, input_fn);

    Ok(TokenStream::from_iter([annotated_fn, generated_code]))
}

fn emit_entrypoint(args: Args, input_fn: ItemFn) -> proc_macro2::TokenStream {
    let _log_level = args.log_level; // Unused param left intentionally as an example
    let annotated_fn_name = input_fn.sig.ident;

    quote! {
        ::pdk::classy::proxy_wasm::main! {{
            ::pdk::classy::proxy_wasm::set_root_context(|context_id| {
                ::pdk::__internal::RootContextAdapter::new(
                    ::pdk::__internal::configure(context_id)
                        .entrypoint(#annotated_fn_name)
                        .create_root_context(context_id)
                ).boxed()
            });
        }}
    }
}

pub fn generate_entrypoint_flex(
    metadata: TokenStream,
    input: TokenStream,
) -> Result<TokenStream, Error> {
    let annotated_fn = input.clone();
    let input_fn: ItemFn = parse2(input)?;
    let args: Args = parse2(metadata)?;

    let generated_code = emit_entrypoint_flex(args, input_fn);

    Ok(TokenStream::from_iter([annotated_fn, generated_code]))
}

fn emit_entrypoint_flex(args: Args, input_fn: ItemFn) -> proc_macro2::TokenStream {
    let _log_level = args.log_level; // Unused param left intentionally as an example
    let annotated_fn_name = input_fn.sig.ident;

    quote! {
        #[no_mangle]
        pub extern "C" fn flex_abi_version_0_1_0() {}

        #[cfg_attr(all(target_arch = "wasm32"), export_name = "flex_on_policy_initialize")]
        #[no_mangle]
        extern "C" fn _flex_start() -> bool {
            ::pdk::flex_abi::entrypoint::wrap_entrypoint(#annotated_fn_name)
        }
    }
}