icydb-core 0.145.3

IcyDB — A schema-first typed query engine and persistence runtime for Internet Computer canisters
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

//! Module: predicate::membership
//! Responsibility: shared construction of canonical membership compare predicates.
//! Does not own: expression lowering or predicate tree normalization.
//! Boundary: callers provide already-admitted compare leaves; this module owns
//! the same-field and same-coercion membership assembly rule.

use crate::{
    db::predicate::{CoercionId, CompareOp, ComparePredicate},
    value::{Value, canonicalize_value_set},
};

///
/// MembershipCompareLeaf
///
/// One admitted equality-family compare leaf used to collapse expanded
/// membership forms back into a compact `IN` or `NOT IN` predicate. It exists
/// so expression lowering and predicate normalization can share the same
/// same-field/same-coercion assembly rule without sharing their AST traversal.
///

pub(in crate::db) struct MembershipCompareLeaf<'a> {
    field: &'a str,
    value: Value,
    coercion: CoercionId,
}

impl<'a> MembershipCompareLeaf<'a> {
    /// Construct one admitted membership leaf.
    #[must_use]
    pub(in crate::db) const fn new(field: &'a str, value: Value, coercion: CoercionId) -> Self {
        Self {
            field,
            value,
            coercion,
        }
    }
}

/// Collapse admitted same-field compare leaves into one membership predicate.
pub(in crate::db) fn collapse_membership_compare_leaves<'a>(
    leaves: impl IntoIterator<Item = MembershipCompareLeaf<'a>>,
    target_op: CompareOp,
) -> Option<ComparePredicate> {
    let mut field = None;
    let mut coercion = None;
    let mut values = Vec::new();

    for leaf in leaves {
        if let Some(current) = field {
            if current != leaf.field {
                return None;
            }
        } else {
            field = Some(leaf.field);
        }
        if let Some(current) = coercion {
            if current != leaf.coercion {
                return None;
            }
        } else {
            coercion = Some(leaf.coercion);
        }

        values.push(leaf.value);
    }

    if values.len() < 2 {
        return None;
    }

    canonicalize_value_set(&mut values);

    Some(ComparePredicate::with_coercion(
        field?,
        target_op,
        Value::List(values),
        coercion?,
    ))
}