pyro_macro/ffi/

capability.rs

//! Transforms:
//! ```ignore
//! #[pyroduct::capability]
//! impl StatefulServer {
//!     type Config = MyConfig;
//!     type Client = SimpleClient;
//!     type Error = MyError; // Optional
//!
//!     fn new(config: &MyConfig) -> Self { Self }
//!     fn reset(&mut self) {}
//!     fn register(&self, _client: &SimpleClient) {}
//!     fn call(&self, _client: &SimpleClient) -> f32 { 42.0 }
//! }
//! ```

use std::rc::Rc;

use heck::AsSnakeCase;
use proc_macro2::TokenStream;
use quote::{format_ident, quote};
use syn::{Error, Ident, ImplItem, ItemImpl, Type, parse_quote};

use crate::{
    ffi::{
        lifecycle::{InitFn, NewClientFn, ResetFn},
        methods::ImplMethod,
        paths::CapabilityIdent,
    },
    utils::extract_ident_from_type,
};

/// Parsed capability from an impl block
#[derive(Debug)]
pub struct CapabilityImpl {
    // Identity storage
    pub ident: Rc<CapabilityIdent>,

    // Lifecycle
    pub init_fn: InitFn,
    pub reset_fn: ResetFn,
    pub register_fn: NewClientFn,

    // Methods
    pub methods: Vec<ImplMethod>,

    // Other items (consts, etc.) - excluding type aliases
    pub other_items: Vec<ImplItem>,
    pub attrs: Vec<syn::Attribute>,
}

impl CapabilityImpl {
    pub fn new(
        input: ItemImpl,
        required_docs: bool,
        cap_name: &str,
        cap_semver: &str,
    ) -> syn::Result<Self> {
        // 1. Extract state/server type name
        let state_tn =
            match &*input.self_ty {
                Type::Path(tp) => tp.path.get_ident().cloned().ok_or_else(|| {
                    Error::new_spanned(&input.self_ty, "Expected simple type name")
                })?,
                _ => {
                    return Err(Error::new_spanned(
                        &input.self_ty,
                        "Expected simple type name",
                    ));
                }
            };

        // 2. Ensure no trait impl
        if input.trait_.is_some() {
            return Err(Error::new_spanned(
                &input,
                "#[capability] cannot be used on trait implementations",
            ));
        }
        let attrs = input.attrs.clone();

        // 3. First pass: collect types
        let mut client_tn: Option<Ident> = None;
        let mut config_tn: Option<Ident> = None;

        let mut init_fn: Option<InitFn> = None;
        let mut reset_fn: Option<ResetFn> = None;
        let mut register_fn: Option<NewClientFn> = None;
        let mut method_fns = Vec::new();
        let mut other_items = Vec::new();

        for item in &input.items {
            if let ImplItem::Type(ty) = item {
                if ty.ident == "Client" {
                    client_tn = Some(extract_ident_from_type(&ty.ty)?);
                } else if ty.ident == "Config" {
                    config_tn = Some(extract_ident_from_type(&ty.ty)?);
                }
                // Note: We intentionally do NOT add type aliases to other_items
                // because inherent associated types are unstable in Rust
            }
        }

        let client_tn = client_tn
            .ok_or_else(|| Error::new_spanned(&state_tn, "Missing `type Client = ...;`"))?;

        // Build identifiers
        let ident = Rc::new(CapabilityIdent {
            pkg_name: cap_name.to_string(),
            pkg_version: cap_semver.to_string(),
            state_tn,
            client_tn,
            config_tn,
        });

        for item in &input.items {
            match item {
                ImplItem::Fn(f) => {
                    let name = f.sig.ident.to_string();
                    match name.as_str() {
                        "new" => {
                            let conf = ident.config_tn.clone().map(|t| parse_quote! { #t });
                            init_fn = Some(InitFn::parse(conf, f)?);
                        }
                        "reset" => {
                            reset_fn = Some(ResetFn::parse(f)?);
                        }
                        "register" => {
                            register_fn = Some(NewClientFn::parse(f, &ident)?);
                        }
                        _ => {
                            // Defer method parsing until we have the class
                            method_fns.push(f.clone());
                        }
                    }
                }
                ImplItem::Type(_) => {
                    // Skip type aliases - they were already processed above
                    // and we don't want them in the output impl block
                }
                other => other_items.push(other.clone()),
            }
        }

        let register_fn = register_fn.ok_or_else(|| {
            Error::new_spanned(
                &ident.state_tn,
                "Missing `fn register(&self, client: &Client)`",
            )
        })?;
        let init_fn = init_fn.ok_or_else(|| {
            Error::new_spanned(
                &ident.state_tn,
                "Missing `fn new() -> Self` or `fn new(config: &Config) -> Self`",
            )
        })?;
        let reset_fn = reset_fn
            .ok_or_else(|| Error::new_spanned(&ident.state_tn, "Missing `fn reset(&mut self)`"))?;

        // 5. Second pass: parse methods with class context
        let methods: Result<Vec<_>, _> = method_fns
            .iter()
            .map(|f| ImplMethod::parse(f, &ident, required_docs))
            .collect();
        let methods = methods?;

        Ok(Self {
            ident,
            init_fn,
            reset_fn,
            register_fn,
            methods,
            other_items,
            attrs,
        })
    }

    /// Generate all output code
    pub fn expand_capability(&self) -> TokenStream {
        let server_impl = self.generate_server_impl();
        let lifecycle_ffi = self.generate_lifecycle_ffi();
        let method_ffis = self.generate_method_ffis();
        let export_table = self.generate_export_table();

        quote! {
            #server_impl
            #lifecycle_ffi
            #method_ffis
            #export_table
        }
    }

    /// Generate all output code
    pub fn expand_module(&self) -> TokenStream {
        let wasm_imports = self.generate_wasm_imports();
        let client_impl = self.generate_client_impl();

        quote! {
            #client_impl
            #wasm_imports
        }
    }

    fn generate_server_impl(&self) -> TokenStream {
        let server = &self.ident.state_tn;
        let init_method = self.init_fn.generate_impl_method();
        let reset_method = self.reset_fn.generate_impl_method();
        let new_client_method = self.register_fn.generate_impl_method();
        let other_items = &self.other_items;

        let methods: Vec<_> = self
            .methods
            .iter()
            .map(|m| m.generate_server_method())
            .collect();

        quote! {
            impl #server {
                #init_method
                #reset_method
                #new_client_method
                #(#other_items)*
                #(#methods)*
            }
        }
    }

    fn generate_client_impl(&self) -> TokenStream {
        let client = &self.ident.client_tn;
        let module = format_ident!("wasm");

        // 1. Generate the Register Method (on the user struct)
        let client_impl = self.register_fn.generate_client_impl(Some(&module));

        // 2. Generate the trait with method signatures
        let trait_name = format_ident!("{}Methods", client);

        let trait_methods: Vec<_> = self
            .methods
            .iter()
            .map(|m| {
                let name = &m.name.0;
                let output = &m.output.to_return_type();
                let args: Vec<_> = m.inputs.iter().map(|(n, t)| quote!(#n: #t)).collect();
                let docs = m.doc_attrs();

                quote! {
                    #(#docs)*
                    fn #name(&self, #(#args),*) #output;
                }
            })
            .collect();

        let trait_def = quote! {
            pub trait #trait_name {
                #(#trait_methods)*
            }
        };

        // 3. Generate the trait implementation for Client<T>
        let method_impls: Vec<_> = self
            .methods
            .iter()
            .map(|m| m.generate_client_method(Some(&module)))
            .collect();

        let trait_impl = quote! {
            impl #trait_name for ::pyroduct::wasm::Client<#client> {
                #(#method_impls)*
            }
        };

        quote! {
            #client_impl
            #trait_def
            #trait_impl
        }
    }

    fn generate_lifecycle_ffi(&self) -> TokenStream {
        let server = &self.ident.state_tn;

        let init_ffi = self.init_fn.generate_ffi(server);
        let reset_ffi = self.reset_fn.generate_ffi(server);
        let register_ffi = self.register_fn.generate_capability_ffi();

        quote! {
            #init_ffi
            #reset_ffi
            #register_ffi
        }
    }

    fn generate_method_ffis(&self) -> TokenStream {
        let method_ffis: Vec<_> = self
            .methods
            .iter()
            .map(|m| m.generate_server_ffi())
            .collect();

        quote! {
            #(#method_ffis)*
        }
    }

    fn generate_export_table(&self) -> TokenStream {
        let cap_id = self.ident.cap_id();

        let server = &self.ident.state_tn;
        let server_snake = AsSnakeCase(server.to_string()).to_string();
        let server_upper = server_snake.to_uppercase();

        let class_name_static = format_ident!("p__{}", server_upper);
        let class_name_string = format!("{}", server_snake);

        let static_strs: Vec<_> = self
            .methods
            .iter()
            .map(|m| {
                let trace_name = self.ident.wasm_name(&m.name).to_string();
                let static_name = self.ident.trace_name_static(&m.name);
                quote! { const #static_name: &'static str = #trace_name; }
            })
            .collect();

        let exports: Vec<_> = self
            .methods
            .iter()
            .map(|ffi| ffi.generate_vtable_entry())
            .collect();

        let num_exports = exports.len();
        let exports_array_name = format_ident!("{}__METHODS", class_name_static);

        let init_export = self.init_fn.generate_export(server);
        let reset_export = self.reset_fn.generate_export(server);
        let register_export = self.register_fn.generate_export();

        let capability_manifest_fn = quote! {
            #[unsafe(no_mangle)]
            pub extern "C" fn pyro_capability_manifest(
                id: i64,
                log_callback: ::pyroduct::ffi::LogCallback,
            ) -> ::pyroduct::ffi::ClassExport {
                ::pyroduct::ffi::guest::logger::init_logging(id, log_callback);

                ::pyroduct::ffi::ClassExport {
                    name: #class_name_static.as_ptr(),
                    name_len: #class_name_static.len(),
                    len: #exports_array_name.len(),
                    ptr: #exports_array_name.as_ptr() as *mut _,
                    init: #init_export,
                    reset: #reset_export,
                    register: #register_export,
                }
            }
        };

        quote! {
            const CAPABILITY_NAME_VERSION: &'static str = #cap_id;
            const #class_name_static: &'static str = #class_name_string;
            #(#static_strs)*

            const #exports_array_name: [::pyroduct::ffi::MethodExport; #num_exports] = [
                #(#exports),*
            ];

            #capability_manifest_fn
        }
    }

    fn generate_wasm_imports(&self) -> TokenStream {
        let class_id = self.ident.class_name();
        let new_client_decl = self.register_fn.generate_client_wasm();

        let method_decls: Vec<_> = self
            .methods
            .iter()
            .map(|m| m.generate_client_wasm())
            .collect();

        quote! {
            mod wasm {
                use super::*;
                #[link(wasm_import_module = #class_id)]
                unsafe extern "C" {
                    #new_client_decl
                    #(#method_decls)*
                }
            }
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use syn::parse2;

    #[test]
    fn test_basic_capability_impl() {
        let code = quote! {
            impl StatefulServer {
                type Client = SimpleClient;

                fn new() -> Result<Self, CapturedError> { Ok(Self) }
                fn reset(&mut self) -> Result<(), CapturedError> { Ok(()) }
                fn register(&self, _client: &SimpleClient) -> Result<(), CapturedError> { Ok(()) }
                fn call(&self, _client: &SimpleClient) -> Result<f32, CapturedError> { Ok(42.0) }
            }
        };

        let input: ItemImpl = parse2(code).unwrap();
        let cap = CapabilityImpl::new(input, false, "cap_name", "0.1.0").unwrap();

        assert_eq!(cap.ident.state_tn.to_string(), "StatefulServer");
        assert_eq!(cap.ident.client_tn.to_string(), "SimpleClient");
        assert_eq!(cap.methods.len(), 1);
        assert_eq!(cap.methods[0].name.to_string(), "call");
        assert!(!cap.init_fn.is_async);
        assert!(cap.init_fn.config_type.is_none());
        assert!(cap.ident.config_tn.is_none());
    }

    #[test]
    fn test_with_config() {
        let code = quote! {
            impl StatefulServer {
                type Config = MyConfig;
                type Client = SimpleClient;

                fn new(config: Option<MyConfig>) -> Result<Self, CapturedError> { Ok(Self) }
                fn reset(&mut self) -> Result<(), CapturedError> { Ok(()) }
                fn register(&self, client: &SimpleClient) -> Result<(), CapturedError> { Ok(()) }
            }
        };

        let input: ItemImpl = parse2(code).unwrap();
        let cap = CapabilityImpl::new(input, false, "cap_name", "0.1.0").unwrap();

        assert!(cap.init_fn.config_type.is_some());
        assert!(cap.ident.config_tn.is_some());

        let cfg = cap.ident.config_tn.as_ref().unwrap();
        assert_eq!(quote!(#cfg).to_string(), "MyConfig");
    }

    #[test]
    fn test_config_mismatch() {
        let code = quote! {
            impl StatefulServer {
                type Config = MyConfig;
                type Client = SimpleClient;

                fn new(config: Option<OtherConfig>) -> Result<Self, CapturedError> { Ok(Self) }
                fn reset(&mut self) -> Result<(), CapturedError> { Ok(()) }
                fn register(&self, client: &SimpleClient) -> Result<(), CapturedError> { Ok(()) }
            }
        };

        let input: ItemImpl = parse2(code).unwrap();
        let err = CapabilityImpl::new(input, false, "cap_name", "0.1.0").unwrap_err();
        println!("{}", err);
        assert!(err.to_string().contains("Type mismatch. Expected 'Option<MyConfig>' based on macro attribute, found 'Option<OtherConfig>'"));
    }

    #[test]
    fn test_async_lifecycle() {
        let code = quote! {
            impl StatefulServer {
                type Client = SimpleClient;

                async fn new() -> Result<Self, CapturedError> { Ok(Self) }
                async fn reset(&mut self) -> Result<(), CapturedError> { Ok(()) }
                fn register(&self, client: &SimpleClient) -> Result<(), CapturedError> { Ok(()) }
            }
        };

        let input: ItemImpl = parse2(code).unwrap();
        let cap = CapabilityImpl::new(input, false, "cap_name", "0.1.0").unwrap();

        assert!(cap.init_fn.is_async);
        assert!(cap.reset_fn.is_async);
    }

    #[test]
    fn test_with_error_type_fails() {
        let code = quote! {
            impl StatefulServer {
                type Client = SimpleClient;
                type Error = MyError;

                fn new() -> Result<Self, CapturedError> { Ok(Self) }
                fn reset(&mut self) -> Result<(), CapturedError> { Ok(()) }
                fn register(&self, client: &SimpleClient) -> Result<(), MyError> { Ok(()) }
            }
        };

        let input: ItemImpl = parse2(code).unwrap();
        let err = CapabilityImpl::new(input, false, "cap_name", "0.1.0").unwrap_err();
        assert!(
            err.to_string()
                .contains("Invalid error type. Expected 'CapturedError', found 'MyError'")
        );
    }

    #[test]
    fn test_with_captured_error() {
        let code = quote! {
            impl StatefulServer {
                type Client = SimpleClient;

                fn new() -> Result<Self, CapturedError> { Ok(Self) }
                fn reset(&mut self) -> Result<(), CapturedError> { Ok(()) }
                fn register(&self, client: &SimpleClient) -> Result<(), CapturedError> { Ok(()) }
                fn fallible(&self, _client: &SimpleClient) -> Result<u32, CapturedError> { Ok(42) }
            }
        };

        let input: ItemImpl = parse2(code).unwrap();
        let cap = CapabilityImpl::new(input, false, "cap_name", "0.1.0").unwrap();

        assert_eq!(cap.methods.len(), 1);
    }

    #[test]
    fn test_generate_export_table() {
        let code = quote! {
            impl TestServer {
                type Client = TestClient;

                fn new() -> Result<Self, CapturedError> { Ok(Self) }
                fn reset(&mut self) -> Result<(), CapturedError> { Ok(()) }
                fn register(&self, client: &TestClient) -> Result<(), CapturedError> { Ok(()) }
                fn get_value(&self, client: &TestClient) -> Result<u32, CapturedError> { Ok(0) }
            }
        };

        let input: ItemImpl = parse2(code).unwrap();
        let cap = CapabilityImpl::new(input, false, "cap_name", "0.1.0").unwrap();

        let output = cap.generate_export_table();

        let expected = quote! {
            const CAPABILITY_NAME_VERSION: &'static str = "cap_name";
            const p__TEST_SERVER: &'static str = "test_server";
            const p__TEST_SERVER__GET_VALUE: &'static str = "p__test_server__get_value__wasm";

            const p__TEST_SERVER__METHODS: [::pyroduct::ffi::MethodExport; 1usize] = [
                ::pyroduct::ffi::MethodExport {
                    name: p__TEST_SERVER__GET_VALUE.as_ptr(),
                    name_len: p__TEST_SERVER__GET_VALUE.len(),
                    func: ::pyroduct::ffi::Function::Sync(p__test_server__get_value__ffi),
                }
            ];

            #[unsafe(no_mangle)]
            pub extern "C" fn pyro_capability_manifest(
                id: i64,
                log_callback: ::pyroduct::ffi::LogCallback,
            ) -> ::pyroduct::ffi::ClassExport {
                ::pyroduct::ffi::guest::logger::init_logging(id, log_callback);

                ::pyroduct::ffi::ClassExport {
                    name: p__TEST_SERVER.as_ptr(),
                    name_len: p__TEST_SERVER.len(),
                    len: p__TEST_SERVER__METHODS.len(),
                    ptr: p__TEST_SERVER__METHODS.as_ptr() as *mut _,
                    init: ::pyroduct::ffi::ClassInitFn::Sync(p__test_server__ffi_init),
                    reset: ::pyroduct::ffi::ClassResetFn::Sync(p__test_server__ffi_reset),
                    register: ::pyroduct::ffi::ClientRegisterFn::Sync(p__test_server__register__ffi),
                }
            }
        };

        crate::fmt::assert_code_eq_token(&output, &expected);

        let output = cap.generate_wasm_imports();

        let expected = quote! {
            mod wasm {
                use super::*;
                #[link(wasm_import_module = "test_server")]
                unsafe extern "C" {
                    pub fn register(ptr: *const u8) -> *mut u8;
                    pub fn p__test_server__get_value__wasm(
                        cs_ptr: *const u8,
                        in_ptr: *const u8,
                    ) -> *mut u8;
                }
            }
        };
        crate::fmt::assert_code_eq_token(&output, &expected);
    }

    #[test]
    fn test_generate_client_impl_integration() {
        // 1. Define Input
        let code = quote! {
            impl MyState {
                type Client = MyClient;
                type Config = MyConfig;

                fn new(config: Option<MyConfig>) -> Result<Self, CapturedError> { Ok(Self) }
                fn reset(&mut self) -> Result<(), CapturedError> { Ok(()) }
                fn register(&self, client: &MyClient) -> Result<(), CapturedError> { Ok(()) }
                fn get_info(&self, client: &MyClient) -> Result<u32, CapturedError> { Ok(0) }
                fn get_other_info(&self, client: &MyClient, data: f32) -> Result<u32, CapturedError> { Ok(0) }
            }
        };

        // 2. Parse
        let input: ItemImpl = parse2(code).unwrap();
        let cap = CapabilityImpl::new(input, false, "cap_name", "0.1.0").unwrap();

        // 3. Generate Output
        let output = cap.generate_client_impl();

        // 4. Define Expected Output
        // Checks constructor generation (using rkyv for config) and normal method generation.
        let expected = quote! {
            impl MyClient {
                pub fn register(self) -> Result<::pyroduct::wasm::Client<Self>, ::pyroduct::CapturedError> {
                    ::pyroduct::wasm::Client::<Self>::__register_result(self, |ptr| unsafe { wasm::register(ptr) })
                }
            }
            pub trait MyClientMethods {
                fn get_info(&self) -> Result<u32, ::pyroduct::CapturedError>;
                fn get_other_info(&self, data: f32) -> Result<u32, ::pyroduct::CapturedError>;
            }
            impl MyClientMethods for ::pyroduct::wasm::Client<MyClient> {
                fn get_info(&self) -> Result<u32, ::pyroduct::CapturedError> {
                    self.__call_result_from_wasm::<(), u32, _>(None,
                        |client_state_ptr: *const u8,
                            input_ptr: *const u8| {
                            unsafe {
                                wasm::p__my_state__get_info__wasm(
                                    client_state_ptr,
                                    input_ptr,
                                )
                            }
                        })
                }

                fn get_other_info(&self, data: f32) -> Result<u32, ::pyroduct::CapturedError> {
                    self.__call_result_from_wasm::<
                        f32,
                        u32,
                        _,
                    >(Some(&data),
                        |client_state_ptr: *const u8,
                            input_ptr: *const u8| {
                            unsafe {
                                wasm::p__my_state__get_other_info__wasm(
                                    client_state_ptr,
                                    input_ptr,
                                )
                            }
                        },
                    )
                }
            }
        };

        crate::fmt::assert_code_eq_token(&output, &expected);
    }

    #[test]
    fn test_generate_client_impl_with_error_and_input_structs() {
        // 1. Define Input: Complex case with Errors and Arguments
        let code = quote! {
            impl AdvancedStruct {
                type Client = AdvancedClient;

                fn new() -> Result<Self, CapturedError> { Ok(Self) }
                fn reset(&mut self) -> Result<(), CapturedError> { Ok(()) }

                fn register(&self, client: &AdvancedClient) -> Result<(), CapturedError> {
                    Ok(())
                }

                async fn process(&self, client: &AdvancedClient, val: u32, flag: bool) -> Result<u32, CapturedError> {
                    Ok(val)
                }
            }
        };

        // 2. Parse
        let input: ItemImpl = parse2(code).unwrap();
        let cap = CapabilityImpl::new(input, false, "cap_name", "0.1.0").unwrap();

        // 3. Generate Output
        let output = cap.generate_client_impl();

        // 4. Define Expected Output
        // - new_client constructor should return Result<Self, CapturedError>.
        // - process method should define an input struct and return Result<u32, CapturedError>.
        let expected = quote! {
            impl AdvancedClient {
                pub fn register(self) -> Result<::pyroduct::wasm::Client<Self>, ::pyroduct::CapturedError> {
                    ::pyroduct::wasm::Client::<Self>::__register_result(self, |ptr| unsafe { wasm::register(ptr) })
                }
            }
            pub trait AdvancedClientMethods {
                fn process(&self, val: u32, flag: bool) -> Result<u32, ::pyroduct::CapturedError>;
            }
            impl AdvancedClientMethods for ::pyroduct::wasm::Client<AdvancedClient> {
                fn process(&self, val: u32, flag: bool) -> Result<u32, ::pyroduct::CapturedError> {
                    #[::pyroduct::magma]
                    struct p__AdvancedStruct__Process__Input {
                        pub val: u32,
                        pub flag: bool
                    }

                    self.__call_result_from_wasm::<
                        p__AdvancedStruct__Process__Input,
                        u32,
                        _
                    >(
                        Some(&p__AdvancedStruct__Process__Input { val, flag }),
                        |client_state_ptr: *const u8,
                         input_ptr: *const u8| {
                            unsafe {
                                wasm::p__advanced_struct__process__wasm(
                                    client_state_ptr,
                                    input_ptr,
                                )
                            }
                        }
                    )
                }
            }
        };

        crate::fmt::assert_code_eq_token(&output, &expected);
    }
}