nautilus-orm-schema 0.1.5

Schema parsing and validation for Nautilus ORM
Documentation 
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
104
105
106
107
108
109
110
111
112
113
114

use super::*;

impl SchemaValidator {
    pub(super) fn collect_names(&mut self) {
        for decl in &self.schema.declarations {
            match decl {
                Declaration::Model(model) => {
                    let name = model.name.value.clone();
                    if let Some(existing_span) = self.models.get(&name) {
                        self.errors.push_back(SchemaError::Validation(
                            format!(
                                "Duplicate model name '{}' (first defined at {})",
                                name, existing_span
                            ),
                            model.name.span,
                        ));
                    } else if self
                        .enums
                        .get(&name)
                        .or(self.composite_types.get(&name))
                        .is_some()
                    {
                        self.errors.push_back(SchemaError::Validation(
                            format!("Name '{}' is already used by an enum or type", name),
                            model.name.span,
                        ));
                    } else {
                        self.models.insert(name, model.name.span);
                    }
                }
                Declaration::Enum(enum_decl) => {
                    let name = enum_decl.name.value.clone();
                    if let Some(existing_span) = self.enums.get(&name) {
                        self.errors.push_back(SchemaError::Validation(
                            format!(
                                "Duplicate enum name '{}' (first defined at {})",
                                name, existing_span
                            ),
                            enum_decl.name.span,
                        ));
                    } else if self
                        .models
                        .get(&name)
                        .or(self.composite_types.get(&name))
                        .is_some()
                    {
                        self.errors.push_back(SchemaError::Validation(
                            format!("Name '{}' is already used by a model or type", name),
                            enum_decl.name.span,
                        ));
                    } else {
                        self.enums.insert(name, enum_decl.name.span);
                    }
                }
                Declaration::Type(type_decl) => {
                    let name = type_decl.name.value.clone();
                    if let Some(existing_span) = self.composite_types.get(&name) {
                        self.errors.push_back(SchemaError::Validation(
                            format!(
                                "Duplicate type name '{}' (first defined at {})",
                                name, existing_span
                            ),
                            type_decl.name.span,
                        ));
                    } else if self.models.get(&name).or(self.enums.get(&name)).is_some() {
                        self.errors.push_back(SchemaError::Validation(
                            format!("Name '{}' is already used by a model or enum", name),
                            type_decl.name.span,
                        ));
                    } else {
                        self.composite_types.insert(name, type_decl.name.span);
                    }
                }
                _ => {}
            }
        }
    }

    pub(super) fn check_physical_name_collisions(&mut self) {
        let mut table_names: HashMap<String, (String, Span)> = HashMap::new();
        for decl in &self.schema.declarations {
            if let Declaration::Model(model) = decl {
                let table_name = model.table_name().to_string();
                if let Some((existing_model, existing_span)) = table_names.get(&table_name) {
                    self.errors.push_back(SchemaError::Validation(
                        format!(
                            "Physical table name '{}' is used by both model '{}' and '{}' (first defined at {})",
                            table_name, model.name.value, existing_model, existing_span
                        ),
                        model.span,
                    ));
                } else {
                    table_names.insert(table_name, (model.name.value.clone(), model.span));
                }

                let mut column_names: HashMap<String, (String, Span)> = HashMap::new();
                for field in &model.fields {
                    let column_name = field.column_name().to_string();
                    if let Some((existing_field, existing_span)) = column_names.get(&column_name) {
                        self.errors.push_back(SchemaError::Validation(
                            format!(
                                "Physical column name '{}' in model '{}' is used by both field '{}' and '{}' (first defined at {})",
                                column_name, model.name.value, field.name.value, existing_field, existing_span
                            ),
                            field.span,
                        ));
                    } else {
                        column_names.insert(column_name, (field.name.value.clone(), field.span));
                    }
                }
            }
        }
    }
}