corium-transactor 0.1.33

Corium transactor
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

//! End-to-end coverage for the selectable storage backends: a mem-backed
//! node runs the whole create/transact/read path with no filesystem state.

use corium_protocol::codec::encode_edn;
use corium_query::edn::Edn;
use corium_query::{QInput, q};
use corium_transactor::StoreSpec;
use corium_transactor::node::{NodeConfig, TransactorNode};

fn schema() -> Vec<u8> {
    encode_edn(&Edn::Vector(vec![
        Edn::Map(vec![
            (Edn::keyword("db/ident"), Edn::keyword("artist/name")),
            (Edn::keyword("db/valueType"), Edn::keyword("db.type/string")),
            (
                Edn::keyword("db/cardinality"),
                Edn::keyword("db.cardinality/one"),
            ),
            (
                Edn::keyword("db/unique"),
                Edn::keyword("db.unique/identity"),
            ),
        ]),
        Edn::Map(vec![
            (Edn::keyword("db/ident"), Edn::keyword("artist/year")),
            (Edn::keyword("db/valueType"), Edn::keyword("db.type/long")),
            (
                Edn::keyword("db/cardinality"),
                Edn::keyword("db.cardinality/one"),
            ),
        ]),
    ]))
}

fn tx() -> Vec<u8> {
    encode_edn(&Edn::Vector(vec![Edn::Map(vec![
        (Edn::keyword("db/id"), Edn::Str("artist".into())),
        (Edn::keyword("artist/name"), Edn::Str("Portishead".into())),
        (Edn::keyword("artist/year"), Edn::Long(1991)),
    ])]))
}

#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
async fn mem_backend_runs_the_full_create_transact_read_path() {
    let mut config = NodeConfig::new(std::path::PathBuf::from("/nonexistent-mem-node"));
    config.store = StoreSpec::Memory;
    // A mem node touches no filesystem, so a bogus data_dir is harmless.
    let node = TransactorNode::open(config).await.expect("open mem node");

    assert!(node.create_db("mbrainz", &schema()).await.expect("create"));
    let response = node.transact("mbrainz", &tx()).await.expect("transact");
    assert!(response.basis_t > response.basis_before);

    let db = node.db_state("mbrainz").await.expect("db state").db();
    let query = Edn::Vector(vec![
        Edn::keyword("find"),
        Edn::symbol("?year"),
        Edn::keyword("where"),
        Edn::Vector(vec![
            Edn::symbol("?e"),
            Edn::keyword("artist/name"),
            Edn::Str("Portishead".into()),
        ]),
        Edn::Vector(vec![
            Edn::symbol("?e"),
            Edn::keyword("artist/year"),
            Edn::symbol("?year"),
        ]),
    ]);
    let result = q(&query, &[QInput::Db(&db)]).expect("query");
    assert_eq!(result.to_string(), "[[1991]]");
}