uqa-execution 0.4.6

Volcano physical operators with row-batch pipelines
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

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

use super::*;

fn schemas(names: &[&str]) -> BTreeMap<String, BoundSchemaSecurity> {
    names
        .iter()
        .map(|name| ((*name).into(), BoundSchemaSecurity::bootstrap(name)))
        .collect()
}

#[test]
fn private_schema_authority_preserves_deletions_and_uses_fresh_unmodified_records() {
    let mut current = schemas(&["private", "changed", "untouched"]);
    current.get_mut("changed").unwrap().acl = Some(Vec::new());
    let committed = Arc::new(schemas(&["changed", "removed", "peer"]));
    let roles = BTreeMap::from([("uqa".into(), RoleDefinition::bootstrap())]);
    let merged = merge_private_records(&current, committed.clone(), &roles, |name| {
        Ok(matches!(name, "private" | "changed" | "removed"))
    })
    .unwrap();
    assert_eq!(
        merged.keys().map(String::as_str).collect::<Vec<_>>(),
        ["changed", "peer", "private"]
    );
    assert_eq!(merged["changed"].acl, Some(Vec::new()));
    assert_eq!(committed["changed"].acl, None);
    assert!(committed.contains_key("removed"));
}

#[test]
fn private_schema_authority_validates_role_incarnations_and_provenance_errors() {
    let roles = BTreeMap::from([("uqa".into(), RoleDefinition::bootstrap())]);
    let mut current = schemas(&["private"]);
    current.get_mut("private").unwrap().role_owner.object_id = [9; 16];
    let committed = Arc::new(schemas(&["peer"]));
    assert!(merge_private_records(&current, committed.clone(), &roles, |_| Ok(true)).is_err());
    assert!(
        merge_private_records(&current, committed.clone(), &roles, |_| {
            Err(StorageBackendError::Other("provenance unavailable".into()))
        })
        .unwrap_err()
        .to_string()
        .contains("provenance unavailable")
    );
    let merged = merge_private_records(&current, committed.clone(), &roles, |_| Ok(false)).unwrap();
    assert!(Arc::ptr_eq(&merged, &committed));
}