icydb_schema/build/
mod.rs

1pub mod reserved;
2pub mod validate;
3
4use crate::{
5    Error, ThisError,
6    node::{Schema, VisitableNode},
7    prelude::*,
8    visit::ValidateVisitor,
9};
10use std::sync::{LazyLock, OnceLock, RwLock, RwLockReadGuard, RwLockWriteGuard};
11
12///
13/// BuildError
14///
15
16#[derive(Debug, ThisError)]
17pub enum BuildError {
18    #[error("validation failed: {0}")]
19    Validation(ErrorTree),
20}
21
22///
23/// SCHEMA
24/// the static data structure
25///
26
27static SCHEMA: LazyLock<RwLock<Schema>> = LazyLock::new(|| RwLock::new(Schema::new()));
28
29static SCHEMA_VALIDATED: OnceLock<bool> = OnceLock::new();
30
31// schema_write
32pub fn schema_write() -> RwLockWriteGuard<'static, Schema> {
33    SCHEMA
34        .write()
35        .expect("schema RwLock poisoned while acquiring write lock")
36}
37
38// schema_read
39// just reads the schema directly without validation
40pub(crate) fn schema_read() -> RwLockReadGuard<'static, Schema> {
41    SCHEMA
42        .read()
43        .expect("schema RwLock poisoned while acquiring read lock")
44}
45
46// get_schema
47// validate will only be done once
48pub fn get_schema() -> Result<RwLockReadGuard<'static, Schema>, Error> {
49    let schema = schema_read();
50    validate(&schema).map_err(BuildError::Validation)?;
51
52    Ok(schema)
53}
54
55// validate
56fn validate(schema: &Schema) -> Result<(), ErrorTree> {
57    if *SCHEMA_VALIDATED.get_or_init(|| false) {
58        return Ok(());
59    }
60
61    // validate
62    let mut visitor = ValidateVisitor::new();
63    schema.accept(&mut visitor);
64    visitor.errors.result()?;
65
66    SCHEMA_VALIDATED.set(true).ok();
67
68    Ok(())
69}
icydb_schema/build/mod.rs

icydb_schema/build/
mod.rs
