graphite_macros/

lib.rs

//! Proc macros for the Graphite subgraph SDK.
//!
//! Provides `#[derive(Entity)]` and `#[handler]` macros for ergonomic
//! subgraph development.

use proc_macro::TokenStream;
use quote::quote;
use syn::{DeriveInput, ItemFn, parse_macro_input};

/// Derive macro for entity types.
///
/// Generates `Store` trait implementation with `load()`, `save()`, and `remove()` methods.
///
/// # Example
///
/// ```rust,ignore
/// #[derive(Entity)]
/// pub struct Transfer {
///     #[id]
///     id: String,
///     from: Address,
///     to: Address,
///     value: BigInt,
/// }
/// ```
///
/// The struct must have exactly one field marked with `#[id]`.
#[proc_macro_derive(Entity, attributes(id, graphite))]
pub fn derive_entity(input: TokenStream) -> TokenStream {
    let input = parse_macro_input!(input as DeriveInput);
    let name = &input.ident;
    let entity_type = name.to_string();

    let fields = match &input.data {
        syn::Data::Struct(data) => match &data.fields {
            syn::Fields::Named(fields) => &fields.named,
            _ => panic!("Entity derive only supports structs with named fields"),
        },
        _ => panic!("Entity derive only supports structs"),
    };

    // Find the #[id] field
    let id_field = fields
        .iter()
        .find(|f| f.attrs.iter().any(|a| a.path().is_ident("id")))
        .expect("Entity must have exactly one field marked with #[id]");
    let id_field_name = id_field.ident.as_ref().unwrap();

    // Generate field setters for to_entity
    let field_setters = fields.iter().map(|f| {
        let field_name = f.ident.as_ref().unwrap();
        let field_name_str = to_camel_case(&field_name.to_string());
        quote! {
            entity.set(#field_name_str, self.#field_name.clone());
        }
    });

    // Generate field getters for from_entity
    let field_getters = fields.iter().map(|f| {
        let field_name = f.ident.as_ref().unwrap();
        let field_name_str = to_camel_case(&field_name.to_string());
        let field_type = &f.ty;
        quote! {
            #field_name: entity
                .get(#field_name_str)
                .and_then(|v| <#field_type as graphite::store::FromValue>::from_value(v.clone()))
                .ok_or_else(|| graphite::store::EntityError::MissingField(#field_name_str.into()))?
        }
    });

    // Generate Default-like field initializers for new()
    let field_defaults = fields.iter().map(|f| {
        let field_name = f.ident.as_ref().unwrap();
        if f.attrs.iter().any(|a| a.path().is_ident("id")) {
            quote! { #field_name: id.into() }
        } else {
            quote! { #field_name: Default::default() }
        }
    });

    let expanded = quote! {
        impl #name {
            /// Create a new instance with the given ID and default field values.
            pub fn new(id: impl Into<String>) -> Self {
                Self {
                    #(#field_defaults),*
                }
            }

            /// Load an entity from the store.
            pub fn load<H: graphite::host::HostFunctions>(host: &H, id: &str) -> Option<Self> {
                host.store_get(#entity_type, id)
                    .and_then(|e| Self::from_entity(e).ok())
            }

            /// Save this entity to the store.
            pub fn save<H: graphite::host::HostFunctions>(&self, host: &mut H) {
                host.store_set(#entity_type, &self.id(), self.to_entity());
            }

            /// Remove this entity from the store.
            pub fn remove<H: graphite::host::HostFunctions>(host: &mut H, id: &str) {
                host.store_remove(#entity_type, id);
            }
        }

        impl graphite::store::Store for #name {
            const ENTITY_TYPE: &'static str = #entity_type;

            fn id(&self) -> &str {
                &self.#id_field_name
            }

            fn to_entity(&self) -> graphite::store::Entity {
                let mut entity = graphite::store::Entity::new();
                #(#field_setters)*
                entity
            }

            fn from_entity(entity: graphite::store::Entity) -> Result<Self, graphite::store::EntityError> {
                Ok(Self {
                    #(#field_getters),*
                })
            }
        }
    };

    TokenStream::from(expanded)
}

/// Attribute macro for handler functions.
///
/// Generates the `extern "C"` wrapper that graph-node calls, reading the
/// EthereumEvent from AS memory via `graph_as_runtime::ethereum::read_ethereum_event`,
/// constructing the typed event via `EventType::from_raw_event`, and delegating
/// to the user's handler implementation.
///
/// graph-node enforces strict return-type rules on exported WASM functions:
/// - **Event handlers** must return `()` (void) — use `#[handler]`
/// - **Block handlers** must return `i32` — use `#[handler(block)]`
///
/// # Signature
///
/// The user's function must take two parameters:
/// - First: the event/block type (e.g. `TransferEvent`) — read from AS memory
/// - Second: `ctx: &graphite::EventContext` — block/tx metadata
///
/// # Examples
///
/// ```rust,ignore
/// // Event handler — WASM export returns void
/// #[handler]
/// pub fn handle_transfer(event: &ERC20TransferEvent, ctx: &graphite::EventContext) {
///     // Handler logic here
/// }
///
/// // Block handler — WASM export returns i32
/// #[handler(block)]
/// pub fn handle_block(block: &EthereumBlock, ctx: &graphite::EventContext) {
///     // Block handler logic here
/// }
/// ```
#[proc_macro_attribute]
pub fn handler(attr: TokenStream, item: TokenStream) -> TokenStream {
    let attr_str = attr.to_string();
    let attr_str = attr_str.trim();

    // Detect the handler variant.
    let is_block_handler = !attr.is_empty() && attr_str == "block";
    let is_call_handler = !attr.is_empty() && attr_str == "call";
    let is_file_handler = !attr.is_empty() && attr_str == "file";

    let input = parse_macro_input!(item as ItemFn);
    let fn_name = &input.sig.ident;
    let fn_body = &input.block;
    let fn_inputs = &input.sig.inputs;
    let fn_vis = &input.vis;

    // Extract the event/block parameter type from the first argument.
    let event_param = fn_inputs
        .first()
        .expect("Handler must have at least one parameter (event)");
    let (param_name, param_type) = match event_param {
        syn::FnArg::Typed(pat_type) => {
            let name = match &*pat_type.pat {
                syn::Pat::Ident(ident) => &ident.ident,
                _ => panic!("Expected identifier pattern for event parameter"),
            };
            (name, &pat_type.ty)
        }
        _ => panic!("Handler cannot have self parameter"),
    };

    // The impl function gets the original name suffixed with _impl.
    let impl_name = syn::Ident::new(&format!("{}_impl", fn_name), fn_name.span());

    // Build the WASM entry point. Event handlers return void; block handlers return i32;
    // call handlers return void; file handlers return void.
    let wasm_entry = if is_file_handler {
        quote! {
            #[cfg(target_arch = "wasm32")]
            #[unsafe(no_mangle)]
            pub extern "C" fn #fn_name(content_ptr: i32) {
                let content = unsafe {
                    graph_as_runtime::store_read::read_asc_bytes(content_ptr as u32)
                };
                let ctx = graphite::FileContext::new();
                #impl_name(&content, &ctx);
            }
        }
    } else if is_call_handler {
        quote! {
            #[cfg(target_arch = "wasm32")]
            #[unsafe(no_mangle)]
            pub extern "C" fn #fn_name(call_ptr: i32) {
                let raw = unsafe {
                    graph_as_runtime::ethereum::read_ethereum_call(call_ptr as u32)
                };
                let #param_name = match <#param_type as graph_as_runtime::ethereum::FromRawCall>::from_raw_call(&raw) {
                    Ok(c) => c,
                    Err(_) => return,
                };
                let ctx = graphite::CallContext {
                    address:                  raw.address,
                    block_hash:               raw.block_hash,
                    block_number:             raw.block_number.clone(),
                    block_timestamp:          raw.block_timestamp.clone(),
                    block_gas_used:           raw.block_gas_used.clone(),
                    block_gas_limit:          raw.block_gas_limit.clone(),
                    block_difficulty:         raw.block_difficulty.clone(),
                    block_base_fee_per_gas:   raw.block_base_fee_per_gas.clone(),
                    tx_hash:                  raw.tx_hash,
                    tx_index:                 raw.tx_index.clone(),
                    from:                     raw.from,
                    tx_to:                    raw.tx_to,
                    tx_value:                 raw.tx_value.clone(),
                    tx_gas_limit:             raw.tx_gas_limit.clone(),
                    tx_gas_price:             raw.tx_gas_price.clone(),
                    tx_nonce:                 raw.tx_nonce.clone(),
                };
                #impl_name(&#param_name, &ctx);
            }
        }
    } else if is_block_handler {
        quote! {
            #[cfg(target_arch = "wasm32")]
            #[unsafe(no_mangle)]
            pub extern "C" fn #fn_name(event_ptr: i32) -> i32 {
                let raw = unsafe {
                    graph_as_runtime::ethereum::read_ethereum_event(event_ptr as u32)
                };
                let #param_name = match <#param_type as graph_as_runtime::ethereum::FromRawEvent>::from_raw_event(&raw) {
                    Ok(e) => e,
                    Err(_) => return 1,
                };
                let ctx = graphite::EventContext {
                    address:                  raw.address,
                    log_index:                raw.log_index.clone(),
                    block_hash:               raw.block_hash,
                    block_number:             raw.block_number.clone(),
                    block_timestamp:          raw.block_timestamp.clone(),
                    block_gas_used:           raw.block_gas_used.clone(),
                    block_gas_limit:          raw.block_gas_limit.clone(),
                    block_difficulty:         raw.block_difficulty.clone(),
                    block_base_fee_per_gas:   raw.block_base_fee_per_gas.clone(),
                    tx_hash:                  raw.tx_hash,
                    tx_index:                 raw.tx_index.clone(),
                    tx_from:                  raw.tx_from,
                    tx_to:                    raw.tx_to,
                    tx_value:                 raw.tx_value.clone(),
                    tx_gas_limit:             raw.tx_gas_limit.clone(),
                    tx_gas_price:             raw.tx_gas_price.clone(),
                    tx_nonce:                 raw.tx_nonce.clone(),
                    receipt:                  raw.receipt,
                };
                #impl_name(&#param_name, &ctx);
                0
            }
        }
    } else {
        // Event handler — graph-node expects no return value (void).
        quote! {
            #[cfg(target_arch = "wasm32")]
            #[unsafe(no_mangle)]
            pub extern "C" fn #fn_name(event_ptr: i32) {
                let raw = unsafe {
                    graph_as_runtime::ethereum::read_ethereum_event(event_ptr as u32)
                };
                let #param_name = match <#param_type as graph_as_runtime::ethereum::FromRawEvent>::from_raw_event(&raw) {
                    Ok(e) => e,
                    Err(_) => return,
                };
                let ctx = graphite::EventContext {
                    address:                  raw.address,
                    log_index:                raw.log_index.clone(),
                    block_hash:               raw.block_hash,
                    block_number:             raw.block_number.clone(),
                    block_timestamp:          raw.block_timestamp.clone(),
                    block_gas_used:           raw.block_gas_used.clone(),
                    block_gas_limit:          raw.block_gas_limit.clone(),
                    block_difficulty:         raw.block_difficulty.clone(),
                    block_base_fee_per_gas:   raw.block_base_fee_per_gas.clone(),
                    tx_hash:                  raw.tx_hash,
                    tx_index:                 raw.tx_index.clone(),
                    tx_from:                  raw.tx_from,
                    tx_to:                    raw.tx_to,
                    tx_value:                 raw.tx_value.clone(),
                    tx_gas_limit:             raw.tx_gas_limit.clone(),
                    tx_gas_price:             raw.tx_gas_price.clone(),
                    tx_nonce:                 raw.tx_nonce.clone(),
                    receipt:                  raw.receipt,
                };
                #impl_name(&#param_name, &ctx);
            }
        }
    };

    // Choose the context type and the parameter type for the _impl function.
    let (ctx_type, param_override) = if is_file_handler {
        (quote! { graphite::FileContext }, Some(quote! { alloc::vec::Vec<u8> }))
    } else if is_call_handler {
        (quote! { graphite::CallContext }, None)
    } else {
        (quote! { graphite::EventContext }, None)
    };

    // For file handlers, the _impl param type is Vec<u8>; for others, use the declared type.
    let impl_param_type = if let Some(ref override_ty) = param_override {
        quote! { #override_ty }
    } else {
        quote! { #param_type }
    };

    let expanded = quote! {
        // ---------------------------------------------------------------
        // Implementation function — contains the user's handler body.
        // In native builds the test harness calls this directly.
        // ---------------------------------------------------------------
        #fn_vis fn #impl_name(
            #param_name: #impl_param_type,
            ctx: &#ctx_type,
        ) #fn_body

        // ---------------------------------------------------------------
        // Native (non-WASM) entry point — caller supplies event + context.
        // Used by unit tests and the native test harness.
        // ---------------------------------------------------------------
        #[cfg(not(target_arch = "wasm32"))]
        #fn_vis fn #fn_name(
            #param_name: #impl_param_type,
            ctx: &#ctx_type,
        ) {
            #impl_name(#param_name, ctx)
        }

        // ---------------------------------------------------------------
        // WASM entry point — called by graph-node with an AscPtr to the
        // event/block object in linear memory.
        // ---------------------------------------------------------------
        #wasm_entry
    };

    TokenStream::from(expanded)
}

/// Convert snake_case to camelCase for GraphQL field names.
fn to_camel_case(s: &str) -> String {
    let mut result = String::new();
    let mut capitalize_next = false;

    for c in s.chars() {
        if c == '_' {
            capitalize_next = true;
        } else if capitalize_next {
            result.push(c.to_ascii_uppercase());
            capitalize_next = false;
        } else {
            result.push(c);
        }
    }

    result
}