selene-db-graph 1.2.0

In-memory property-graph storage core (ArcSwap + imbl CoW, label/typed indexes, write funnel) for selene-db.
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

use selene_core::{GraphId, db_string};

use crate::{
    ProviderError, SeleneGraph, TextIndex,
    core_provider::sections::{
        TextSchemaEntry, TextSchemaKey, decode_text_schemas, encode_text_schemas,
    },
    graph::TextIndexEntry,
};

#[test]
fn round_trip_preserves_text_index_name() {
    let label = db_string("core.tidx.label").unwrap();
    let property = db_string("core.tidx.property").unwrap();
    let name = db_string("core.tidx.index").unwrap();
    let mut graph = SeleneGraph::new(GraphId::new(9992));
    graph.text_index.insert(
        (label.clone(), property.clone()),
        TextIndexEntry::new(
            TextIndex::empty(label.clone(), property.clone()),
            Some(name.clone()),
        ),
    );

    let decoded = decode_text_schemas(&encode_text_schemas(&graph).unwrap()).unwrap();

    assert_eq!(
        decoded,
        vec![(
            TextSchemaKey { label, property },
            TextSchemaEntry { name: Some(name) }
        )]
    );
}

#[test]
fn decode_rejects_duplicate_text_registration() {
    let label = db_string("core.tidx.dup.label").unwrap();
    let property = db_string("core.tidx.dup.property").unwrap();
    let duplicate = vec![
        (
            TextSchemaKey {
                label: label.clone(),
                property: property.clone(),
            },
            TextSchemaEntry { name: None },
        ),
        (
            TextSchemaKey { label, property },
            TextSchemaEntry { name: None },
        ),
    ];
    let bytes = rkyv::to_bytes::<rkyv::rancor::Error>(&duplicate)
        .unwrap()
        .into_vec();

    let result = decode_text_schemas(&bytes);

    assert!(
        matches!(result, Err(ProviderError::InvalidPayload { reason }) if reason.contains("CORE/TIDX")),
        "duplicate CORE/TIDX key must be rejected"
    );
}