hydracache-db 0.59.0

Database-neutral query result cache adapter for HydraCache.
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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105

use hydracache_db::{
    CustomProfile, DimensionAllow, DimensionAllowError, DimensionProfile, DimensionRequirement,
    ProfileValidation, QueryCachePolicy,
};

#[test]
fn profile_passes_when_linked() {
    let policy = QueryCachePolicy::named("search-users")
        .key("tenant:7:permission:abc:q:ada:page:1:sort:name")
        .with_key_dimension_labels(["tenant", "permission", "q", "page", "sort"])
        .with_tag_dimension_labels(["tenant", "permission", "q", "page", "sort"])
        .with_dimension_profile(DimensionProfile::TenantPermissionSearch);

    assert_eq!(policy.validate_dimension_profile(), ProfileValidation::Pass);
}

#[test]
fn fails_when_tenant_missing() {
    let policy = QueryCachePolicy::named("search-users")
        .key("permission:abc:q:ada:page:1:sort:name")
        .with_key_dimension_labels(["permission", "q", "page", "sort"])
        .with_tag_dimension_labels(["permission", "q", "page", "sort"])
        .with_dimension_profile(DimensionProfile::TenantPermissionSearch);

    assert_eq!(
        policy.validate_dimension_profile(),
        ProfileValidation::MissingDimensions(vec!["tenant".to_owned()])
    );
}

#[test]
fn fails_when_permission_missing() {
    let policy = QueryCachePolicy::named("search-users")
        .key("tenant:7:q:ada:page:1:sort:name")
        .with_key_dimension_labels(["tenant", "q", "page", "sort"])
        .with_tag_dimension_labels(["tenant", "q", "page", "sort"])
        .with_dimension_profile(DimensionProfile::TenantPermissionSearch);

    assert_eq!(
        policy.validate_dimension_profile(),
        ProfileValidation::MissingDimensions(vec!["permission".to_owned()])
    );
}

#[test]
fn fails_when_page_or_cursor_missing() {
    let paged = QueryCachePolicy::named("search")
        .key("q:ada:sort:name")
        .with_key_dimension_labels(["q", "sort"])
        .with_tag_dimension_labels(["q", "sort"])
        .with_dimension_profile(DimensionProfile::PagedSearch);
    let cursor = QueryCachePolicy::named("list")
        .key("users")
        .with_key_dimension_labels(["tenant"])
        .with_tag_dimension_labels(["tenant"])
        .with_dimension_profile(DimensionProfile::CursorList);

    assert_eq!(
        paged.validate_dimension_profile(),
        ProfileValidation::MissingDimensions(vec!["page".to_owned()])
    );
    assert_eq!(
        cursor.validate_dimension_profile(),
        ProfileValidation::MissingDimensions(vec!["cursor".to_owned()])
    );
}

#[test]
fn unlinked_label_is_rejected() {
    let policy = QueryCachePolicy::named("tenant-users")
        .key("tenant:7:users")
        .with_key_dimension_labels(["tenant"])
        .with_tag_dimension_labels(["users"])
        .with_dimension_profile(DimensionProfile::TenantScoped);

    assert_eq!(
        policy.validate_dimension_profile(),
        ProfileValidation::UnlinkedDimensions(vec!["tenant".to_owned()])
    );
}

#[test]
fn custom_profile_reused() {
    let profile = CustomProfile::new(
        "tenant-locale",
        [
            DimensionRequirement::linked("tenant"),
            DimensionRequirement::key_only("locale"),
        ],
    );
    let policy = QueryCachePolicy::named("localized")
        .key("tenant:7:locale:en")
        .with_key_dimension_labels(["tenant", "locale"])
        .with_tag_dimension_labels(["tenant"])
        .with_dimension_profile(DimensionProfile::Custom(profile));

    assert_eq!(policy.validate_dimension_profile(), ProfileValidation::Pass);
}

#[test]
fn allowlist_requires_reason_text() {
    let error = DimensionAllow::new("tenant", "").unwrap_err();

    assert_eq!(error, DimensionAllowError::EmptyReason);
}