use proc_macro::TokenStream;
use proc_macro2::TokenStream as TokenStream2;
use quote::{format_ident, quote};
use syn::{parse_macro_input, Data, DeriveInput, Fields, Lit, Meta};
#[proc_macro_derive(RustioAdmin, attributes(rustio))]
pub fn derive_rustio_admin(input: TokenStream) -> TokenStream {
let input = parse_macro_input!(input as DeriveInput);
expand(input)
.unwrap_or_else(|e| e.to_compile_error())
.into()
}
fn expand(input: DeriveInput) -> syn::Result<TokenStream2> {
let struct_name = &input.ident;
let fields = struct_fields(&input)?;
let struct_overrides = parse_struct_attr(&input.attrs)?;
let admin_name = match struct_overrides.admin_name {
Some(ref s) => s.clone(),
None => plural_snake(&struct_name.to_string()),
};
let display_name = match struct_overrides.display_name {
Some(ref s) => s.clone(),
None => humanise(&plural_snake(&struct_name.to_string())),
};
let singular = struct_name.to_string();
let mut field_metas = Vec::new();
let mut display_value_arms = Vec::new();
let mut from_form_parses = Vec::new();
let mut from_form_fields = Vec::new();
let mut update_tuples = Vec::new();
for f in fields {
let fname = f.ident.as_ref().unwrap();
let fname_str = fname.to_string();
let kind = classify_type(&f.ty)?;
let kind = if matches!(kind, FieldKind::DateTime) && is_auto_timestamp_name(&fname_str) {
FieldKind::DateTimeAuto
} else {
kind
};
let editable = fname_str != "id" && kind != FieldKind::DateTimeAuto;
let type_variant = kind.field_type_ident();
let relation = parse_relation_attr(&f.attrs, &fname_str)?;
let relation_tokens = match &relation {
Some((target, display)) => {
let display_tok = match display {
Some(d) => quote! { ::std::option::Option::Some(#d) },
None => quote! { ::std::option::Option::None },
};
quote! {
::std::option::Option::Some(::rustio_admin::admin::AdminRelation {
target_model: #target,
display_field: #display_tok,
multi: false,
})
}
}
None => quote! { ::std::option::Option::None },
};
field_metas.push(quote! {
::rustio_admin::admin::AdminField {
name: #fname_str,
label: #fname_str,
field_type: ::rustio_admin::admin::FieldType::#type_variant,
editable: #editable,
relation: #relation_tokens,
choices: ::std::option::Option::None,
}
});
let display_arm = match kind {
FieldKind::String => quote! {
out.push((#fname_str.to_string(), self.#fname.clone()));
},
FieldKind::OptionalString => quote! {
out.push((#fname_str.to_string(), match &self.#fname {
Some(v) => v.clone(),
None => String::new(),
}));
},
FieldKind::I32 | FieldKind::I64 => quote! {
out.push((#fname_str.to_string(), self.#fname.to_string()));
},
FieldKind::OptionalI64 => quote! {
out.push((#fname_str.to_string(), match &self.#fname {
Some(v) => v.to_string(),
None => String::new(),
}));
},
FieldKind::Bool => quote! {
out.push((#fname_str.to_string(), if self.#fname { "true".to_string() } else { "false".to_string() }));
},
FieldKind::DateTime | FieldKind::DateTimeAuto => quote! {
out.push((#fname_str.to_string(), self.#fname.format("%Y-%m-%dT%H:%M").to_string()));
},
FieldKind::OptionalDateTime => quote! {
out.push((#fname_str.to_string(), match &self.#fname {
Some(v) => v.format("%Y-%m-%dT%H:%M").to_string(),
None => String::new(),
}));
},
};
display_value_arms.push(display_arm);
if fname_str == "id" {
from_form_fields.push(quote! { #fname: 0 });
continue;
}
let humanised_label = humanise_field(&fname_str);
let required_msg = format!("{humanised_label} is required.");
let number_msg = format!("{humanised_label} must be a number.");
let date_invalid_msg = format!("{humanised_label} is not a valid date.");
match kind {
FieldKind::String => {
from_form_parses.push(quote! {
let #fname = match form.get(#fname_str).map(str::trim) {
Some(v) if !v.is_empty() => v.to_string(),
_ => { errors.push(#required_msg.to_string()); String::new() }
};
});
from_form_fields.push(quote! { #fname });
}
FieldKind::OptionalString => {
from_form_parses.push(quote! {
let #fname: Option<String> = form
.get(#fname_str)
.map(|s| s.trim().to_string())
.filter(|s| !s.is_empty());
});
from_form_fields.push(quote! { #fname });
}
FieldKind::I32 => {
from_form_parses.push(quote! {
let #fname: i32 = match form.get(#fname_str).and_then(|v| v.parse().ok()) {
Some(v) => v,
None => { errors.push(#number_msg.to_string()); 0 }
};
});
from_form_fields.push(quote! { #fname });
}
FieldKind::I64 => {
from_form_parses.push(quote! {
let #fname: i64 = match form.get(#fname_str).and_then(|v| v.parse().ok()) {
Some(v) => v,
None => { errors.push(#number_msg.to_string()); 0 }
};
});
from_form_fields.push(quote! { #fname });
}
FieldKind::OptionalI64 => {
from_form_parses.push(quote! {
let #fname: Option<i64> = match form.get(#fname_str).map(str::trim) {
None | Some("") => None,
Some(raw) => match raw.parse::<i64>() {
Ok(n) => Some(n),
Err(_) => {
errors.push(#number_msg.to_string());
None
}
},
};
});
from_form_fields.push(quote! { #fname });
}
FieldKind::Bool => {
from_form_parses.push(quote! {
let #fname: bool = form.bool_flag(#fname_str);
});
from_form_fields.push(quote! { #fname });
}
FieldKind::DateTime => {
from_form_parses.push(quote! {
let #fname = match form.get(#fname_str) {
Some(raw) if !raw.is_empty() => {
match ::chrono::NaiveDateTime::parse_from_str(raw, "%Y-%m-%dT%H:%M") {
Ok(dt) => ::chrono::DateTime::<::chrono::Utc>::from_naive_utc_and_offset(dt, ::chrono::Utc),
Err(_) => { errors.push(#date_invalid_msg.to_string()); ::chrono::Utc::now() }
}
}
_ => { errors.push(#required_msg.to_string()); ::chrono::Utc::now() }
};
});
from_form_fields.push(quote! { #fname });
}
FieldKind::DateTimeAuto => {
from_form_parses.push(quote! {
let #fname = ::chrono::Utc::now();
});
from_form_fields.push(quote! { #fname });
}
FieldKind::OptionalDateTime => {
from_form_parses.push(quote! {
let #fname: ::std::option::Option<::chrono::DateTime<::chrono::Utc>> =
match form.get(#fname_str).map(str::trim) {
None | Some("") => ::std::option::Option::None,
Some(raw) => match ::chrono::NaiveDateTime::parse_from_str(raw, "%Y-%m-%dT%H:%M") {
Ok(dt) => ::std::option::Option::Some(
::chrono::DateTime::<::chrono::Utc>::from_naive_utc_and_offset(dt, ::chrono::Utc),
),
Err(_) => {
errors.push(#date_invalid_msg.to_string());
::std::option::Option::None
}
},
};
});
from_form_fields.push(quote! { #fname });
}
}
update_tuples.push(quote! {
(#fname_str, self.#fname.clone().into())
});
}
let object_label_expr = find_label_field(fields)
.map(|n| {
let id = format_ident!("{n}");
quote! { self.#id.clone().to_string() }
})
.unwrap_or_else(|| quote! { format!("#{}", self.id) });
Ok(quote! {
impl ::rustio_admin::admin::AdminModel for #struct_name {
const ADMIN_NAME: &'static str = #admin_name;
const DISPLAY_NAME: &'static str = #display_name;
const SINGULAR_NAME: &'static str = #singular;
const FIELDS: &'static [::rustio_admin::admin::AdminField] = &[
#(#field_metas),*
];
fn display_values(&self) -> ::std::vec::Vec<(::std::string::String, ::std::string::String)> {
let mut out = ::std::vec::Vec::new();
#(#display_value_arms)*
out
}
fn from_form(form: &::rustio_admin::http::FormData) -> ::std::result::Result<Self, ::std::vec::Vec<::std::string::String>>
where
Self: Sized,
{
let mut errors: ::std::vec::Vec<::std::string::String> = ::std::vec::Vec::new();
#(#from_form_parses)*
if !errors.is_empty() {
return Err(errors);
}
Ok(Self { #(#from_form_fields),* })
}
fn object_label(&self) -> ::std::string::String {
#object_label_expr
}
fn id(&self) -> i64 {
self.id
}
fn values_to_update(&self) -> ::std::vec::Vec<(&'static str, ::rustio_admin::orm::Value)> {
::std::vec![#(#update_tuples),*]
}
}
})
}
fn struct_fields(
input: &DeriveInput,
) -> syn::Result<&syn::punctuated::Punctuated<syn::Field, syn::Token![,]>> {
let data = match &input.data {
Data::Struct(s) => s,
_ => {
return Err(syn::Error::new_spanned(
&input.ident,
"RustioAdmin can only derive on structs",
))
}
};
match &data.fields {
Fields::Named(named) => Ok(&named.named),
_ => Err(syn::Error::new_spanned(
&input.ident,
"RustioAdmin requires a struct with named fields",
)),
}
}
#[derive(Debug, PartialEq, Clone, Copy)]
enum FieldKind {
I32,
I64,
Bool,
String,
DateTime,
DateTimeAuto,
OptionalString,
OptionalI64,
OptionalDateTime,
}
impl FieldKind {
fn field_type_ident(&self) -> proc_macro2::Ident {
match self {
FieldKind::I32 => format_ident!("I32"),
FieldKind::I64 => format_ident!("I64"),
FieldKind::Bool => format_ident!("Bool"),
FieldKind::String => format_ident!("String"),
FieldKind::DateTime | FieldKind::DateTimeAuto => format_ident!("DateTime"),
FieldKind::OptionalString => format_ident!("OptionalString"),
FieldKind::OptionalI64 => format_ident!("OptionalI64"),
FieldKind::OptionalDateTime => format_ident!("OptionalDateTime"),
}
}
}
fn is_auto_timestamp_name(name: &str) -> bool {
matches!(name, "created_at" | "updated_at")
}
fn humanise_field(s: &str) -> String {
let mut out = String::with_capacity(s.len());
let mut next_upper = true;
for ch in s.chars() {
if ch == '_' {
out.push(' ');
next_upper = true;
} else if next_upper {
out.push(ch.to_ascii_uppercase());
next_upper = false;
} else {
out.push(ch);
}
}
out
}
fn classify_type(ty: &syn::Type) -> syn::Result<FieldKind> {
let as_string = quote! { #ty }.to_string().replace(' ', "");
let kind = match as_string.as_str() {
"i32" => FieldKind::I32,
"i64" => FieldKind::I64,
"bool" => FieldKind::Bool,
"String" => FieldKind::String,
"DateTime<Utc>" | "chrono::DateTime<chrono::Utc>" => FieldKind::DateTime,
"Option<String>" => FieldKind::OptionalString,
"Option<i64>" => FieldKind::OptionalI64,
"Option<DateTime<Utc>>" | "Option<chrono::DateTime<chrono::Utc>>" => {
FieldKind::OptionalDateTime
}
other => {
return Err(syn::Error::new_spanned(
ty,
format!("unsupported field type for RustioAdmin: {other}"),
))
}
};
Ok(kind)
}
#[derive(Default)]
struct StructOverrides {
admin_name: Option<String>,
display_name: Option<String>,
}
fn parse_struct_attr(attrs: &[syn::Attribute]) -> syn::Result<StructOverrides> {
let mut out = StructOverrides::default();
for attr in attrs {
if !attr.path().is_ident("rustio") {
continue;
}
attr.parse_nested_meta(|m| {
if m.path.is_ident("admin_name") {
let value = m.value()?;
let lit: Lit = value.parse()?;
if let Lit::Str(s) = lit {
out.admin_name = Some(s.value());
}
Ok(())
} else if m.path.is_ident("display_name") {
let value = m.value()?;
let lit: Lit = value.parse()?;
if let Lit::Str(s) = lit {
out.display_name = Some(s.value());
}
Ok(())
} else {
Err(m.error(
"unknown rustio struct attribute; expected `admin_name` or `display_name`",
))
}
})?;
}
Ok(out)
}
fn parse_relation_attr(
attrs: &[syn::Attribute],
field_name: &str,
) -> syn::Result<Option<(String, Option<String>)>> {
for attr in attrs {
if !attr.path().is_ident("rustio") {
continue;
}
let mut target: Option<String> = None;
let mut display: Option<String> = None;
attr.parse_nested_meta(|m| {
if m.path.is_ident("belongs_to") {
let value = m.value()?;
let lit: Lit = value.parse()?;
if let Lit::Str(s) = lit {
target = Some(s.value());
}
Ok(())
} else if m.path.is_ident("display") {
let value = m.value()?;
let lit: Lit = value.parse()?;
if let Lit::Str(s) = lit {
display = Some(s.value());
}
Ok(())
} else {
Err(m.error(format!("unknown rustio attribute for field `{field_name}`")))
}
})?;
if let Some(t) = target {
return Ok(Some((t, display)));
}
if display.is_some() {
return Err(syn::Error::new_spanned(
attr,
"`display` requires `belongs_to` alongside it",
));
}
}
let _ = std::marker::PhantomData::<Meta>;
Ok(None)
}
fn plural_snake(camel: &str) -> String {
let snake = camel_to_snake(camel);
if snake.ends_with('s') {
snake
} else if snake.ends_with('x')
|| snake.ends_with('z')
|| snake.ends_with("ch")
|| snake.ends_with("sh")
{
format!("{snake}es")
} else if let Some(stem) = snake.strip_suffix('y') {
let before = stem.chars().last();
if matches!(before, Some('a' | 'e' | 'i' | 'o' | 'u')) || stem.is_empty() {
format!("{snake}s")
} else {
format!("{stem}ies")
}
} else {
format!("{snake}s")
}
}
#[cfg(test)]
mod plural_snake_tests {
use super::plural_snake;
#[test]
fn regular_plurals() {
assert_eq!(plural_snake("Post"), "posts");
assert_eq!(plural_snake("Loan"), "loans");
assert_eq!(plural_snake("BlogPost"), "blog_posts");
assert_eq!(plural_snake("CaseAction"), "case_actions");
}
#[test]
fn ch_sh_x_z_suffixes_take_es() {
assert_eq!(plural_snake("Branch"), "branches");
assert_eq!(plural_snake("Box"), "boxes");
assert_eq!(plural_snake("Dish"), "dishes");
assert_eq!(plural_snake("Buzz"), "buzzes");
}
#[test]
fn consonant_y_becomes_ies_vowel_y_keeps_s() {
assert_eq!(plural_snake("Category"), "categories");
assert_eq!(plural_snake("Story"), "stories");
assert_eq!(plural_snake("Toy"), "toys");
assert_eq!(plural_snake("Day"), "days");
}
#[test]
fn trailing_s_left_alone() {
assert_eq!(plural_snake("Posts"), "posts");
assert_eq!(plural_snake("Status"), "status");
}
}
fn camel_to_snake(s: &str) -> String {
let mut out = String::new();
for (i, c) in s.chars().enumerate() {
if c.is_ascii_uppercase() && i > 0 {
out.push('_');
}
out.push(c.to_ascii_lowercase());
}
out
}
fn humanise(snake: &str) -> String {
let mut chars = snake.chars();
let mut out = String::new();
if let Some(first) = chars.next() {
out.push(first.to_ascii_uppercase());
}
for c in chars {
if c == '_' {
out.push(' ');
} else {
out.push(c);
}
}
out
}
fn find_label_field(
fields: &syn::punctuated::Punctuated<syn::Field, syn::Token![,]>,
) -> Option<String> {
let names = ["name", "title", "full_name", "label", "email"];
for candidate in names {
if fields
.iter()
.any(|f| f.ident.as_ref().map(|i| i == candidate).unwrap_or(false))
{
return Some(candidate.to_string());
}
}
None
}