harn-vm 0.10.52

Async bytecode virtual machine for the Harn programming language
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

use std::fs;

use harn_session_store::{StoreContention, StoreError};

use super::{open_store, store_error, store_path, ErrorCategory, SessionStoreDir};

#[test]
fn store_contention_maps_to_typed_transient_category() {
    let error = store_error(StoreError::Contention {
        kind: StoreContention::DatabaseBusy,
        message: "database is locked".to_string(),
    });

    assert_eq!(
        crate::value::error_to_category(&error),
        ErrorCategory::ResourceBusy
    );
    assert!(ErrorCategory::ResourceBusy.is_transient());
    assert_eq!(
        error.to_string(),
        "Error [resource_busy]: session_store: retryable backend contention (database_busy): database is locked"
    );
}

#[test]
fn incompatible_store_schema_maps_to_typed_non_retryable_category() {
    let error = store_error(StoreError::SchemaIncompatible {
        schema: "session_store".to_string(),
        stored: 5,
        supported: 2,
    });

    assert_eq!(
        crate::value::error_to_category(&error),
        ErrorCategory::SchemaIncompatible
    );
    assert!(!ErrorCategory::SchemaIncompatible.is_transient());
    assert_eq!(
        error.to_string(),
        "Error [schema_incompatible]: session_store: schema incompatible: session_store version 5 is newer than supported version 2"
    );
}

#[test]
fn canonical_store_open_preserves_newer_schema_category() {
    let root = tempfile::tempdir().expect("tempdir");
    let state_dir = SessionStoreDir::under_root(root.path());
    fs::create_dir_all(state_dir.as_path()).expect("state dir");
    drop(open_store(&state_dir).expect("initialize canonical store"));
    let connection = rusqlite::Connection::open(store_path(&state_dir)).expect("open raw sqlite");
    connection
        .execute(
            "UPDATE _harn_sqlite_schema_versions SET version = 99 WHERE name = 'session_store'",
            [],
        )
        .expect("mark future schema");
    drop(connection);

    let error = match open_store(&state_dir) {
        Ok(_) => panic!("newer canonical store must be rejected"),
        Err(error) => error,
    };
    assert_eq!(
        crate::value::error_to_category(&error),
        ErrorCategory::SchemaIncompatible
    );
    assert!(error
        .to_string()
        .contains("session_store version 99 is newer than supported version 5"));
}