uqa-sql 0.3.0

PostgreSQL-compatible SQL compiler built on libpg_query
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

//
// Unified Query Algebra
//
// Copyright (c) 2023-2026 Cognica, Inc.
//

//! Durable event-catalog envelopes and persistence selection over live relation metadata.
use super::{RuleCatalog, StoredRule, StoredTrigger, TriggerCatalog};
use crate::ast::RelationPersistence;
use serde::{Deserialize, Serialize};
use uqa_core::RelationIdentity;
pub const RULE_CATALOG_FORMAT_VERSION: u32 = 3;
pub trait EventRelationPersistence {
    fn rule_relation_is_temporary(&self, relation: &RelationIdentity) -> bool;
    fn trigger_relation_persistence(
        &self,
        relation: &RelationIdentity,
    ) -> Option<RelationPersistence>;
}
#[derive(Default, Serialize, Deserialize)]
pub struct StoredTriggerCatalog {
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub triggers: Vec<StoredTrigger>,
}

#[derive(Default, Serialize, Deserialize)]
pub struct StoredRuleCatalog {
    #[serde(default)]
    pub format_version: u32,
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub rules: Vec<StoredRule>,
}

pub fn stored_rules_snapshot(
    rules: &RuleCatalog,
    relations: &dyn EventRelationPersistence,
) -> StoredRuleCatalog {
    StoredRuleCatalog {
        format_version: RULE_CATALOG_FORMAT_VERSION,
        rules: rules
            .iter()
            .filter(|(relation, _)| !relations.rule_relation_is_temporary(relation))
            .flat_map(|(_, entries)| entries.values().cloned())
            .collect(),
    }
}

pub fn stored_triggers_snapshot(
    triggers: &TriggerCatalog,
    relations: &dyn EventRelationPersistence,
) -> StoredTriggerCatalog {
    StoredTriggerCatalog {
        triggers: triggers
            .iter()
            .filter(|(relation, _)| {
                relations
                    .trigger_relation_persistence(relation)
                    .is_some_and(|persistence| persistence != RelationPersistence::Temporary)
            })
            .flat_map(|(_, entries)| entries.values().cloned())
            .collect(),
    }
}

pub fn rule_catalog_requires_migration(
    format_version: u32,
    allows_migration: bool,
) -> Result<bool, String> {
    if format_version > RULE_CATALOG_FORMAT_VERSION {
        return Err(format!(
            "rule catalog format {format_version} is newer than supported format {RULE_CATALOG_FORMAT_VERSION}"
        ));
    }
    let migrating_catalog = format_version < RULE_CATALOG_FORMAT_VERSION;
    if migrating_catalog && !allows_migration {
        return Err("rule catalog requires an initial-open format migration".into());
    }

    Ok(migrating_catalog)
}

#[cfg(test)]
mod tests;