icydb-core 0.261.18

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

//! Module: index::plan::error
//! Responsibility: construct accepted unique-constraint diagnostics for index planning.
//! Does not own: commit materialization or executor behavior.
//! Boundary: attach accepted identity to the canonical internal error.

use crate::{
    db::commit::CommitSchemaFingerprint,
    error::{AcceptedConstraintFactContext, InternalError, MutationDiagnosticContext},
};

/// Build one accepted unique-constraint violation with catalog identity.
#[must_use]
pub(super) fn unique_violation(
    accepted_schema_fingerprint: CommitSchemaFingerprint,
    mutation: Option<MutationDiagnosticContext>,
    constraint_id: u32,
    entity_tag: u64,
) -> InternalError {
    InternalError::mutation_constraint_violation(AcceptedConstraintFactContext::write_admission(
        crate::db::schema::accepted_schema_cache_fingerprint_method_version(),
        accepted_schema_fingerprint,
        entity_tag,
        constraint_id,
        icydb_diagnostic_code::DiagnosticConstraintKind::Unique,
        mutation,
        None,
    ))
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn unique_violation_preserves_only_compact_accepted_identity() {
        let error = unique_violation(
            [0xAB; 16],
            Some(MutationDiagnosticContext::new(
                crate::db::schema::accepted_schema_cache_fingerprint_method_version(),
                [0xAB; 16],
                23,
                icydb_diagnostic_code::DiagnosticMutationOperation::Replace,
                4,
            )),
            17,
            23,
        );
        assert_eq!(error.origin(), crate::error::ErrorOrigin::Executor);
        assert_eq!(
            error.diagnostic().error_code(),
            icydb_diagnostic_code::ErrorCode::RUNTIME_BOUNDARY_CONSTRAINT_VIOLATION,
        );
        let facts = error.diagnostic_facts();
        assert!(facts.contains(&(icydb_diagnostic_code::DiagnosticFactTag::EntityTag, 23)));
        assert!(facts.contains(&(icydb_diagnostic_code::DiagnosticFactTag::ConstraintId, 17)));
        assert!(facts.contains(&(
            icydb_diagnostic_code::DiagnosticFactTag::ConstraintKind,
            icydb_diagnostic_code::DiagnosticConstraintKind::Unique.raw()
        )));
        assert!(facts.contains(&(
            icydb_diagnostic_code::DiagnosticFactTag::MutationOperation,
            icydb_diagnostic_code::DiagnosticMutationOperation::Replace.raw(),
        )));
        assert!(facts.contains(&(icydb_diagnostic_code::DiagnosticFactTag::BatchPosition, 4,)));
        assert_eq!(facts.len(), 9);
    }
}