1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103

extern crate proc_macro;

use proc_macro::TokenStream;
use proc_macro_error::{emit_error, proc_macro_error};
use quote::quote;
use serde_query_core::DeriveTarget;
use syn::{parse_macro_input, DeriveInput};

/// Generate a minimal, non-functioning Deserialize(Query) implementation on errors
fn set_dummy(input: &DeriveInput, target: DeriveTarget) {
    let name = &input.ident;
    let generics = &input.generics;

    match target {
        DeriveTarget::Deserialize => {
            proc_macro_error::set_dummy(quote! {
                const _: () = {
                    impl<'de> serde_query::__priv::serde::de::Deserialize<'de> for #name #generics {
                        fn deserialize<D>(deserializer: D) -> core::result::Result<Self, D::Error>
                        where
                            D: serde_query::__priv::serde::de::Deserializer<'de>
                        {
                            unimplemented!()
                        }
                    }
                };
            });
        }
        DeriveTarget::DeserializeQuery => {
            proc_macro_error::set_dummy(quote! {
                const _: () = {
                    struct __QueryWrapper;

                    impl<'de> serde_query::__priv::serde::de::Deserialize<'de> for __QueryWrapper {
                        fn deserialize<D>(deserializer: D) -> core::result::Result<Self, D::Error>
                        where
                            D: serde_query::__priv::serde::de::Deserializer<'de>
                        {
                            todo!()
                        }
                    }

                    impl core::convert::From<__QueryWrapper> for #name #generics {
                        fn from(val: __QueryWrapper) -> Self {
                            todo!()
                        }
                    }

                    impl core::ops::Deref for __QueryWrapper {
                        type Target = #name;

                        fn deref(&self) -> &Self::Target {
                            todo!()
                        }
                    }

                    impl core::ops::DerefMut for __QueryWrapper {
                        fn deref_mut(&mut self) -> &mut Self::Target {
                            todo!()
                        }
                    }

                    impl<'de> serde_query::DeserializeQuery<'de> for #name #generics {
                        type Query = __QueryWrapper;
                    }
                };
            });
        }
    }
}

fn generate_derive(input: TokenStream, target: DeriveTarget) -> TokenStream {
    let input = parse_macro_input!(input as DeriveInput);

    set_dummy(&input, target);

    if !input.generics.params.is_empty() {
        emit_error!(input.generics, "generic arguments are not supported");
        return TokenStream::new();
    }

    match serde_query_core::generate_derive(input, target) {
        Ok(stream) => stream.into(),
        Err(diagnostics) => {
            for diagnostic in diagnostics {
                diagnostic.emit();
            }
            TokenStream::new()
        }
    }
}

#[proc_macro_error]
#[proc_macro_derive(DeserializeQuery, attributes(query))]
pub fn derive_deserialize_query(input: TokenStream) -> TokenStream {
    generate_derive(input, DeriveTarget::DeserializeQuery)
}

#[proc_macro_error]
#[proc_macro_derive(Deserialize, attributes(query))]
pub fn derive_deserialize(input: TokenStream) -> TokenStream {
    generate_derive(input, DeriveTarget::Deserialize)
}