corium-transactor 0.1.63

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
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
106
107
108
109
110
111
112
113
114

//! 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, NodeError, 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(), None)
            .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]]");
}

#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
async fn expected_basis_rejects_a_stale_transaction_before_commit() {
    let mut config = NodeConfig::new(std::path::PathBuf::from("/nonexistent-mem-node"));
    config.store = StoreSpec::Memory;
    let node = TransactorNode::open(config).await.expect("open mem node");
    assert!(
        node.create_db("mbrainz", &schema(), None)
            .await
            .expect("create")
    );

    let first = node
        .transact_at("mbrainz", &tx(), Some(0))
        .await
        .expect("basis zero is current");
    assert_eq!(first.basis_t, 1);

    let stale = node
        .transact_at("mbrainz", &tx(), Some(0))
        .await
        .expect_err("stale basis must fail");
    assert!(matches!(
        stale,
        NodeError::BasisMismatch {
            expected: 0,
            actual: 1
        }
    ));
    assert_eq!(
        node.db_state("mbrainz")
            .await
            .expect("state")
            .db()
            .basis_t(),
        1
    );
}