harmos-runtime 0.1.2

Harmos runtime: managed state, undo, recovery, background work and typed streams.
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

/* ***
 *
 * Harmos
 *
 * SPDX-License-Identifier: Apache-2.0
 *
 * ***
 */

/* === Modules === */

/* === Re-Exports === */

/* === Imports === */

// Standard Library Imports

// Third Party Imports
use support::{Change, HOUSE, balance, deposit, runtime};
// Local Imports
use crate::state::support;
use harmos_runtime::{state::Entry, state::Position, state::RequestKey};

/* === Constants === */

/* === Macros === */

/* === Type Aliases === */

/* === Structs === */

/* === Enums === */

/* === Traits === */

/* === Implementations === */

/* === Public Functions === */

/* === Private Functions === */

#[tokio::test]
async fn keyed_retry_dedupes() {
    let runtime = runtime().await;
    let key = RequestKey::new("transfer-9");

    let first = runtime.state.commit_keyed(key.clone(), deposit(25)).await.expect("accepted");
    let retry = runtime.state.commit_keyed(key.clone(), deposit(25)).await.expect("the retry answers with what the first attempt got");

    assert_eq!(retry, first);
    assert_eq!(runtime.state.applied(), first.position, "the retry minted nothing");
    assert_eq!(balance(&runtime, HOUSE).await, 25, "the retry applied nothing");

    let history = history(&runtime).await;
    assert_eq!(history.len(), 1, "the retry appended nothing");
    assert_eq!(history[0].metadata.request, Some(key));
}

#[tokio::test]
async fn distinct_keys_commit() {
    let runtime = runtime().await;

    let first = runtime.state.commit_keyed(RequestKey::new("one"), deposit(25)).await.expect("accepted");
    let second = runtime.state.commit_keyed(RequestKey::new("two"), deposit(25)).await.expect("accepted");

    assert_eq!(first.position, Position(1));
    assert_eq!(second.position, Position(2));
    assert_eq!(balance(&runtime, HOUSE).await, 50);
}

async fn history(runtime: &harmos_runtime::Runtime<support::Bank>) -> Vec<Entry<Change>> {
    runtime.state.query::<Change>(Position::ORIGIN).await.map(|entry| entry.expect("the tail holds the whole history")).collect()
}

/* === Tests === */