diesel_derives/

has_query.rs

use proc_macro2::TokenStream;
use syn::punctuated::Punctuated;
use syn::{parse_quote, DeriveInput};

use crate::model::{CheckForBackend, Model};

pub(crate) fn derive(item: DeriveInput) -> syn::Result<TokenStream> {
    // other required traits
    let mut checks = Punctuated::new();
    if cfg!(feature = "postgres") {
        checks.push(parse_quote! {diesel::pg::Pg});
    }
    if cfg!(feature = "sqlite") {
        checks.push(parse_quote! {diesel::sqlite::Sqlite});
    }
    if cfg!(feature = "mysql") {
        checks.push(parse_quote! {diesel::mysql::Mysql});
    }
    let selectable = super::selectable::derive(
        item.clone(),
        (!checks.is_empty()).then_some(CheckForBackend::Backends(checks)),
    )?;
    let queryable = super::queryable::derive(item.clone())?;

    let ident = &item.ident;
    let model = Model::from_item(&item, false, false)?;
    let (_original_impl_generics, ty_generics, _original_where_clause) =
        item.generics.split_for_impl();

    let mut generics = item.generics.clone();
    generics
        .params
        .push(parse_quote!(__DB: diesel::backend::Backend));

    let (impl_generics, _, where_clause) = generics.split_for_impl();

    let mut errors = Vec::new();

    let (query_expr, query_type) = if let Some(base_query) = model.base_query {
        if let Some(query_type) = model.base_query_type {
            (base_query, query_type)
        } else {
            use dsl_auto_type::auto_type::expression_type_inference as type_inference;

            let (inferred_type, infer_errors) = type_inference::infer_expression_type(
                &base_query,
                None,
                &type_inference::InferrerSettings::builder()
                    .dsl_path(parse_quote!(diesel::dsl))
                    .function_types_case(crate::AUTO_TYPE_DEFAULT_FUNCTION_TYPE_CASE)
                    .method_types_case(crate::AUTO_TYPE_DEFAULT_METHOD_TYPE_CASE)
                    .build(),
            );

            errors = infer_errors
                .into_iter()
                .map(|e| e.into_compile_error())
                .collect();
            (base_query, inferred_type)
        }
    } else {
        let table_name = &model.table_names()[0];
        let query_type =
            parse_quote!(<#table_name::table as diesel::query_builder::AsQuery>::Query);

        let query_expr = parse_quote! {
            diesel::query_builder::AsQuery::as_query(#table_name::table)
        };
        (query_expr, query_type)
    };

    let mut query_model = crate::util::wrap_in_dummy_mod(quote::quote! {
        impl #impl_generics diesel::HasQuery<__DB> for #ident #ty_generics #where_clause {
            type BaseQuery = #query_type;

            fn base_query() -> Self::BaseQuery {
                #query_expr
            }

        }
        #(#errors)*
    });
    query_model.extend(selectable);
    query_model.extend(queryable);
    Ok(query_model)
}