haematite-cli 0.21.8

The haematite command: serve a store, its door and Studio, answer MCP, query with jq, and host the store's assistant seat
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

use haematite::branch::history::{Error as HistoryError, Key};
use haematite::branch::{CommitError, RefError};
use haematite::db::branches::ForkKeptError;
use haematite::tree::Hash;

use super::fork_kept_failure;

#[test]
fn kept_source_errors_keep_their_names_and_full_reasons() {
    let key = Key {
        branch: Hash::of(b"source"),
        generation: 10,
        sequence: 2,
    };
    let cases = [
        (
            ForkKeptError::ServiceBindingStale {
                source: CommitError::UnnamedBranch,
            },
            "kept_service_binding_stale",
        ),
        (
            ForkKeptError::ServiceInvalid {
                name: "source".to_owned(),
            },
            "kept_service_invalid",
        ),
        (
            ForkKeptError::ShardSetIncomplete { service: true },
            "kept_shard_set_incomplete",
        ),
        (
            ForkKeptError::ShardSetIncomplete { service: false },
            "kept_shard_set_incomplete",
        ),
        (ForkKeptError::RowMissing { key }, "kept_row_missing"),
        (
            ForkKeptError::RowInvalid {
                key,
                source: HistoryError::ValueTruncated,
            },
            "kept_row_invalid",
        ),
        (
            ForkKeptError::RowRead {
                shard_id: 0,
                reason: "node read failed".to_owned(),
            },
            "kept_row_read",
        ),
        (
            ForkKeptError::RootUnavailable {
                shard_id: 1,
                root: Hash::of(b"missing"),
                reason: "root missing in owning store".to_owned(),
            },
            "kept_root_unavailable",
        ),
    ];
    for (error, code) in cases {
        let message = error.to_string();
        let failure = fork_kept_failure(&error, false);
        assert_eq!(failure.code, code);
        assert_eq!(failure.message, message);
        assert!(failure.path.is_none());
    }
}

#[test]
fn publication_errors_preserve_the_destination_install_boundary() {
    for (installed, code) in [(false, "write_refused"), (true, "durability_unknown")] {
        let error = ForkKeptError::Fork(CommitError::Ref(RefError::Io(std::io::Error::other(
            "destination reference fence failed",
        ))));
        let message = error.to_string();
        let failure = fork_kept_failure(&error, installed);
        assert_eq!(failure.code, code);
        assert_eq!(failure.message, message);
    }
}