icydb-core 0.257.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

//! Detach recursive children before dropping an owned dynamic request.
//! Cleanup visits the already-owned input, even when admission rejected early.

use crate::db::query::{
    DynamicQuery,
    expr::{FilterExpr, FilterValue},
};

pub(super) fn clear(query: &mut DynamicQuery) {
    if let Some(filter) = query.filter.take() {
        clear_filter(filter);
    }
}

fn clear_filter(filter: FilterExpr) {
    let mut pending = Vec::new();
    let mut current = Some(filter);
    while let Some(filter) = current.take().or_else(|| pending.pop()) {
        match filter {
            FilterExpr::Junction { filters, .. } => pending.extend(filters),
            FilterExpr::Not(filter) => current = Some(*filter),
            FilterExpr::Compare { value, .. } | FilterExpr::Collection { value, .. } => {
                clear_filter_value(value);
            }
            FilterExpr::Set { values, .. } => {
                for value in values {
                    clear_filter_value(value);
                }
            }
            FilterExpr::Constant(_)
            | FilterExpr::CompareFields { .. }
            | FilterExpr::State { .. } => {}
        }
    }
}

fn clear_filter_value(value: FilterValue) {
    let mut pending = Vec::new();
    let mut current = Some(value);
    while let Some(value) = current.take().or_else(|| pending.pop()) {
        if let FilterValue::List(values) = value {
            pending.extend(values);
            current = pending.pop();
        }
    }
}