use proc_macro::TokenStream;
use quote::quote;
use syn::{Data, DeriveInput, Fields, Ident, parse_macro_input};
#[proc_macro_derive(GrpcError, attributes(grpc))]
pub fn derive_grpc_error(input: TokenStream) -> TokenStream {
let input = parse_macro_input!(input as DeriveInput);
let name = &input.ident;
let vis = &input.vis;
let grpc_name = Ident::new(&format!("{name}GrpcError"), name.span());
let variants = match &input.data {
Data::Enum(data) => &data.variants,
_ => {
return syn::Error::new_spanned(name, "GrpcError can only be derived for enums")
.to_compile_error()
.into();
},
};
let mut grpc_variants = Vec::new();
let mut api_error_arms = Vec::new();
grpc_variants.push(quote! {
Internal = 0
});
let mut discriminant = 1u8;
for variant in variants {
let variant_name = &variant.ident;
let is_internal = variant.attrs.iter().any(|attr| {
attr.path().is_ident("grpc")
&& attr.parse_args::<Ident>().map(|i| i == "internal").unwrap_or(false)
});
let docs: Vec<_> =
variant.attrs.iter().filter(|attr| attr.path().is_ident("doc")).collect();
if is_internal {
let pattern = match &variant.fields {
Fields::Unit => quote! { #name::#variant_name },
Fields::Unnamed(_) => quote! { #name::#variant_name(..) },
Fields::Named(_) => quote! { #name::#variant_name { .. } },
};
api_error_arms.push(quote! {
#pattern => #grpc_name::Internal
});
} else {
grpc_variants.push(quote! {
#(#docs)*
#variant_name = #discriminant
});
let pattern = match &variant.fields {
Fields::Unit => quote! { #name::#variant_name },
Fields::Unnamed(_) => quote! { #name::#variant_name(..) },
Fields::Named(_) => quote! { #name::#variant_name { .. } },
};
api_error_arms.push(quote! {
#pattern => #grpc_name::#variant_name
});
discriminant += 1;
}
}
let expanded = quote! {
#[derive(Debug, Copy, Clone, PartialEq, Eq)]
#[repr(u8)]
#vis enum #grpc_name {
#(#grpc_variants,)*
}
impl #grpc_name {
pub fn api_code(self) -> u8 {
self as u8
}
pub fn is_internal(&self) -> bool {
matches!(self, Self::Internal)
}
pub fn tonic_code(&self) -> tonic::Code {
if self.is_internal() {
tonic::Code::Internal
} else {
tonic::Code::InvalidArgument
}
}
}
impl #name {
pub fn api_error(&self) -> #grpc_name {
match self {
#(#api_error_arms,)*
}
}
}
impl From<#name> for tonic::Status {
fn from(value: #name) -> Self {
let api_error = value.api_error();
let message = if api_error.is_internal() {
"Internal error".to_owned()
} else {
use miden_node_utils::ErrorReport as _;
value.as_report()
};
tonic::Status::with_details(
api_error.tonic_code(),
message,
vec![api_error.api_code()].into(),
)
}
}
};
TokenStream::from(expanded)
}