pipederive 0.2.1

Proc macros for data integration app using pipebase framework
Documentation
use proc_macro2::{Ident, Span, TokenStream};
use quote::{quote, ToTokens};
use syn::{Attribute, ItemFn, Lit, Meta, MetaList, MetaNameValue, NestedMeta};
use syn::{Data, Field, Fields, FieldsNamed};

// traversal tree with full path
pub fn find_meta_value_by_meta_path(full_path: &[&str], meta: &Meta) -> Option<Lit> {
    assert!(!full_path.is_empty(), "empty meta path");
    // reach last segment of full path
    if full_path.len() == 1 {
        if let Meta::NameValue(MetaNameValue {
            ref path, ref lit, ..
        }) = meta
        {
            let last_segment = full_path[0];
            let path = path.get_ident().unwrap().to_string();
            if path.eq(last_segment) {
                // we find the meta
                return Some(lit.clone());
            }
            return None;
        }
        return None;
    }
    if let Meta::List(ref meta_list) = meta {
        let expected_path = full_path[0];
        let actual_path = meta_list.path.get_ident().unwrap().to_string();
        if !actual_path.eq(expected_path) {
            return None;
        }
        let nested_metas = &meta_list.nested;
        for nested_meta in nested_metas.iter() {
            if let NestedMeta::Meta(ref nested) = nested_meta {
                match find_meta_value_by_meta_path(&full_path[1..], nested) {
                    Some(lit) => return Some(lit),
                    None => continue,
                }
            }
        }
        return None;
    }
    None
}

pub fn is_meta_with_prefix(prefix_path: &[&str], meta: &Meta) -> bool {
    assert!(!prefix_path.is_empty(), "empty meta prefix path");
    if prefix_path.len() == 1 {
        let last_segment = prefix_path[0];
        match meta {
            Meta::Path(ref path) => {
                let path = path.get_ident().unwrap().to_string();
                if path.eq(last_segment) {
                    // we find the meta
                    return true;
                }
                return false;
            }
            Meta::NameValue(MetaNameValue { ref path, .. }) => {
                let path = path.get_ident().unwrap().to_string();
                if path.eq(last_segment) {
                    // we find the meta
                    return true;
                }
                return false;
            }
            Meta::List(MetaList { ref path, .. }) => {
                let path = path.get_ident().unwrap().to_string();
                if path.eq(last_segment) {
                    // we find the meta
                    return true;
                }
                return false;
            }
        }
    }
    if let Meta::List(ref meta_list) = meta {
        let expected_path = prefix_path[0];
        let actual_path = meta_list.path.get_ident().unwrap().to_string();
        if !actual_path.eq(expected_path) {
            return false;
        }
        let nested_metas = &meta_list.nested;
        for nested_meta in nested_metas.iter() {
            if let NestedMeta::Meta(ref nested) = nested_meta {
                if is_meta_with_prefix(&prefix_path[1..], nested) {
                    return true;
                }
            }
        }
        return false;
    }
    false
}

pub fn parse_lit_as_string(lit: &Lit) -> Option<String> {
    if let Lit::Str(lit) = lit {
        return Some(lit.value());
    }
    None
}

pub fn parse_lit_as_number(lit: &Lit) -> Option<String> {
    if let Lit::Int(lit) = lit {
        return Some(lit.base10_digits().to_owned());
    }
    None
}

pub fn get_any_attribute_by_meta_prefix(
    prefix: &str,
    attributes: &[Attribute],
    is_required: bool,
    ident_location: &str,
) -> Option<Attribute> {
    let prefix_path = prefix.split('.').collect::<Vec<&str>>();
    for attribute in attributes {
        if is_meta_with_prefix(&prefix_path, &attribute.parse_meta().unwrap()) {
            return Some(attribute.clone());
        }
    }
    if is_required {
        panic!("error: {}", meta_prefix_not_found(prefix, ident_location))
    }
    None
}

pub fn get_all_attributes_by_meta_prefix(prefix: &str, attributes: &[Attribute]) -> Vec<Attribute> {
    let prefix_path = prefix.split('.').collect::<Vec<&str>>();
    attributes
        .iter()
        .filter(|&attribute| is_meta_with_prefix(&prefix_path, &attribute.parse_meta().unwrap()))
        .map(|attribute| attribute.to_owned())
        .collect()
}

pub fn get_meta_number_value_by_meta_path(
    full_path: &str,
    meta: &Meta,
    is_required: bool,
    ident_location: &str,
) -> Option<String> {
    get_meta_value_by_meta_path(
        full_path,
        meta,
        is_required,
        ident_location,
        &parse_lit_as_number,
    )
}

pub fn get_meta_string_value_by_meta_path(
    full_path: &str,
    meta: &Meta,
    is_required: bool,
    ident_location: &str,
) -> Option<String> {
    get_meta_value_by_meta_path(
        full_path,
        meta,
        is_required,
        ident_location,
        &parse_lit_as_string,
    )
}

pub fn get_meta_value_by_meta_path(
    full_path: &str,
    meta: &Meta,
    is_required: bool,
    ident_location: &str,
    parse: &dyn Fn(&Lit) -> Option<String>,
) -> Option<String> {
    let full_path_vec = &full_path.split('.').collect::<Vec<&str>>();
    if let Some(ref lit) = find_meta_value_by_meta_path(full_path_vec, meta) {
        if let Some(value) = parse(lit) {
            return Some(value);
        }
    }
    if is_required {
        panic!("error: {}", meta_value_not_found(full_path, ident_location))
    }
    None
}

pub fn get_type_name_token(
    meta: &Meta,
    type_name_meta_path: &str,
    ident_location: &str,
) -> TokenStream {
    let type_literal =
        get_meta_string_value_by_meta_path(type_name_meta_path, meta, true, ident_location)
            .unwrap();
    resolve_type_name_token(&type_literal)
}

pub fn resolve_type_name_token(type_literal: &str) -> proc_macro2::TokenStream {
    type_literal.parse().unwrap()
}

/// Resolve dotted field ident
pub fn resolve_field_path_token(field_path: &str) -> TokenStream {
    let field_idents = field_path.split('.').map(resolve_ident);
    quote! {
        #(#field_idents).*
    }
}

pub fn resolve_module_path_token(module_path: &str) -> TokenStream {
    let module_idents = module_path.split("::").map(resolve_ident);
    quote! {
        #(#module_idents)::*
    }
}

pub fn resolve_ident(field: &str) -> Ident {
    Ident::new(field, Span::call_site())
}

pub fn resolve_first_field(
    data: &Data,
    predicate: &dyn Fn(&Field) -> bool,
    required: bool,
    panic_msg: &str,
) -> Option<Field> {
    let fields = resolve_all_fields(data, required, predicate, panic_msg);
    fields.into_iter().next()
}

pub fn resolve_all_fields(
    data: &Data,
    at_least_one: bool,
    predicate: &dyn Fn(&Field) -> bool,
    panic_msg: &str,
) -> Vec<Field> {
    let data_struct = match *data {
        Data::Struct(ref data_struct) => data_struct,
        Data::Enum(_) | Data::Union(_) => unimplemented!(),
    };
    let fields = match data_struct.fields {
        Fields::Named(ref fields) => find_all_fields(fields, predicate),
        Fields::Unnamed(_) | Fields::Unit => unimplemented!(),
    };
    if at_least_one && fields.is_empty() {
        panic!("error: {}", panic_msg)
    }
    fields
}

pub fn find_all_fields(fields: &FieldsNamed, predicate: &dyn Fn(&Field) -> bool) -> Vec<Field> {
    fields
        .named
        .iter()
        .filter(|&field| predicate(field))
        .map(|f| f.to_owned())
        .collect()
}

pub fn get_last_stmt_span(function: &ItemFn) -> (Span, Span) {
    let mut last_stmt = function
        .block
        .stmts
        .last()
        .map(ToTokens::into_token_stream)
        .unwrap_or_default()
        .into_iter();
    let start = last_stmt.next().map_or_else(Span::call_site, |t| t.span());
    let end = last_stmt.last().map_or(start, |t| t.span());
    (start, end)
}

pub fn get_meta(attribute: &Attribute) -> Meta {
    attribute.parse_meta().unwrap()
}

pub fn resolve_data(
    data: &Data,
    input_type_token: &TokenStream,
    ident_location: &str,
    resolve: &dyn Fn(&Field, &TokenStream, &str) -> TokenStream,
) -> TokenStream {
    match *data {
        Data::Struct(ref data) => match data.fields {
            Fields::Named(ref fields) => {
                resolve_fields_named(fields, input_type_token, ident_location, resolve)
            }
            Fields::Unnamed(_) | Fields::Unit => unimplemented!(),
        },
        Data::Enum(_) | Data::Union(_) => unimplemented!(),
    }
}

fn resolve_fields_named(
    fields: &FieldsNamed,
    input_type_token: &TokenStream,
    ident_location: &str,
    resolve: &dyn Fn(&Field, &TokenStream, &str) -> TokenStream,
) -> TokenStream {
    let resolved_fields = fields
        .named
        .iter()
        .map(|f| resolve(f, input_type_token, ident_location));
    quote! {
        #(#resolved_fields),*
    }
}

pub fn meta_not_found_in_all_fields(meta_path: &str, ty: &str) -> String {
    format!("meta '{}' not found in '{}' fields", meta_path, ty)
}

pub fn meta_value_not_found(meta_path: &str, ident_location: &str) -> String {
    format!(
        "meta value not found for meta '{}' at '{}'",
        meta_path, ident_location
    )
}

pub fn meta_prefix_not_found(meta_prefix: &str, ident_location: &str) -> String {
    format!(
        "meta prefix '{}' not found at '{}'",
        meta_prefix, ident_location
    )
}