icydb-core 0.261.0

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

//! Continuation identity over the planner's canonical inputs.
//! Diagnostic DTOs are not identity sources.

use crate::db::query::{
    construction::ConstructionBudget,
    fingerprint::hash_sections::{
        CONTINUATION_SECTION_ACCESS_TAG, CONTINUATION_SECTION_DISTINCT_TAG,
        CONTINUATION_SECTION_ENTITY_PATH_TAG, CONTINUATION_SECTION_GROUPING_SHAPE_TAG,
        CONTINUATION_SECTION_MODE_TAG, CONTINUATION_SECTION_ORDER_TAG,
        CONTINUATION_SECTION_PREDICATE_TAG, CONTINUATION_SECTION_PROJECTION_SPEC_TAG,
        access::hash_access_plan,
        grouping::{hash_grouping_shape, hash_projection_spec},
        hash_distinct, hash_mode, hash_order_spec, hash_scalar_semantic_filter, write_str,
        write_tag,
    },
    plan::{AccessPlannedQuery, expr::ProjectionSpec},
};
use crate::error::InternalError;
use sha2::Sha256;

/// Preserve the canonical section order and framing used by cursor identity.
pub(in crate::db::query) fn hash_continuation_with_projection(
    hasher: &mut Sha256,
    plan: &AccessPlannedQuery,
    entity_path: &str,
    projection: &ProjectionSpec,
    budget: &dyn ConstructionBudget,
) -> Result<(), InternalError> {
    let scalar = plan.scalar_plan();
    write_tag(hasher, CONTINUATION_SECTION_ENTITY_PATH_TAG);
    write_str(hasher, entity_path);
    write_tag(hasher, CONTINUATION_SECTION_MODE_TAG);
    hash_mode(hasher, scalar.mode);
    write_tag(hasher, CONTINUATION_SECTION_ACCESS_TAG);
    hash_access_plan(hasher, &plan.access, budget)?;
    write_tag(hasher, CONTINUATION_SECTION_PREDICATE_TAG);
    hash_scalar_semantic_filter(
        hasher,
        scalar.filter_expr.as_ref(),
        scalar.predicate.as_ref(),
        budget,
    )?;
    write_tag(hasher, CONTINUATION_SECTION_ORDER_TAG);
    hash_order_spec(hasher, scalar.order.as_ref(), budget)?;
    write_tag(hasher, CONTINUATION_SECTION_DISTINCT_TAG);
    hash_distinct(hasher, scalar.distinct);
    write_tag(hasher, CONTINUATION_SECTION_GROUPING_SHAPE_TAG);
    hash_grouping_shape(hasher, plan, budget)?;
    write_tag(hasher, CONTINUATION_SECTION_PROJECTION_SPEC_TAG);
    hash_projection_spec(hasher, projection, plan, budget)?;
    Ok(())
}