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
use proc_macro2::{Span, TokenStream as TokenStream2};
use quote::{quote, ToTokens, TokenStreamExt};
use syn::{
parse::{Parse, ParseStream},
DeriveInput, Ident, ItemEnum, ItemStruct,
};
#[derive(Debug, Clone)]
pub struct PostgresOrd {
pub name: Ident,
}
impl PostgresOrd {
pub fn new(name: Ident) -> Self {
Self { name }
}
pub fn from_derive_input(derive_input: DeriveInput) -> Result<Self, syn::Error> {
Ok(Self::new(derive_input.ident))
}
}
impl Parse for PostgresOrd {
fn parse(input: ParseStream) -> Result<Self, syn::Error> {
let parsed_enum: Result<ItemEnum, syn::Error> = input.parse();
let parsed_struct: Result<ItemStruct, syn::Error> = input.parse();
let ident = parsed_enum
.map(|x| x.ident)
.or_else(|_| parsed_struct.map(|x| x.ident))
.map_err(|_| syn::Error::new(input.span(), "expected enum or struct"))?;
Ok(Self::new(ident))
}
}
impl ToTokens for PostgresOrd {
fn to_tokens(&self, tokens: &mut TokenStream2) {
let name = &self.name;
let sql_graph_entity_fn_name = syn::Ident::new(
&format!("__pgx_internals_ord_{}", self.name),
Span::call_site(),
);
let inv = quote! {
#[no_mangle]
pub extern "C" fn #sql_graph_entity_fn_name() -> pgx::datum::sql_entity_graph::SqlGraphEntity {
use core::any::TypeId;
let submission = pgx::datum::sql_entity_graph::PostgresOrdEntity {
name: stringify!(#name),
file: file!(),
line: line!(),
full_path: core::any::type_name::<#name>(),
module_path: module_path!(),
id: TypeId::of::<#name>(),
};
pgx::datum::sql_entity_graph::SqlGraphEntity::Ord(submission)
}
};
tokens.append_all(inv);
}
}