angzarr-client 0.2.0

Ergonomic Rust client for Angzarr CQRS/ES framework
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
115
116
117
118
119
120
121
122
123
124
125
126
127

//! Cucumber feature tests for the angzarr-client library.
//!
//! These tests verify client library behavior using Gherkin scenarios.
//! Run with:
//!
//! ```bash
//! cargo test --test features
//! ```

mod steps;

use cucumber::World;
use steps::aggregate_client::AggregateClientWorld;
use steps::command_builder::CommandBuilderWorld;
use steps::compensation::CompensationWorld;
use steps::connection::ConnectionWorld;
use steps::domain_client::DomainClientWorld;
use steps::error_handling::ErrorHandlingWorld;
use steps::event_decoding::EventDecodingWorld;
use steps::fact_flow::FactFlowWorld;
use steps::merge_strategy::MergeStrategyWorld;
use steps::query_builder::QueryBuilderWorld;
use steps::query_client::QueryClientWorld;
use steps::router::RouterWorld;
use steps::speculative_client::SpeculativeClientWorld;
use steps::state_building::StateBuildingWorld;

#[tokio::main]
async fn main() {
    // Run Connection tests
    println!("\n=== Running Connection Tests ===\n");
    ConnectionWorld::cucumber()
        .fail_on_skipped()
        .run("../features/connection.feature")
        .await;

    // Run DomainClient tests
    println!("\n=== Running DomainClient Tests ===\n");
    DomainClientWorld::cucumber()
        .fail_on_skipped()
        .run("../features/domain-client.feature")
        .await;

    // Run AggregateClient tests
    println!("\n=== Running AggregateClient Tests ===\n");
    AggregateClientWorld::cucumber()
        .fail_on_skipped()
        .run("../features/aggregate_client.feature")
        .await;

    // Run QueryClient tests
    println!("\n=== Running QueryClient Tests ===\n");
    QueryClientWorld::cucumber()
        .fail_on_skipped()
        .run("../features/query_client.feature")
        .await;

    // Run SpeculativeClient tests
    println!("\n=== Running SpeculativeClient Tests ===\n");
    SpeculativeClientWorld::cucumber()
        .fail_on_skipped()
        .run("../features/speculative_client.feature")
        .await;

    // Run FactFlow tests
    println!("\n=== Running FactFlow Tests ===\n");
    FactFlowWorld::cucumber()
        .fail_on_skipped()
        .run("../features/fact_flow.feature")
        .await;

    // Run MergeStrategy tests
    println!("\n=== Running MergeStrategy Tests ===\n");
    MergeStrategyWorld::cucumber()
        .fail_on_skipped()
        .run("../features/merge_strategy.feature")
        .await;

    // Run CommandBuilder tests
    println!("\n=== Running CommandBuilder Tests ===\n");
    CommandBuilderWorld::cucumber()
        .fail_on_skipped()
        .run("../features/command_builder.feature")
        .await;

    // Run QueryBuilder tests
    println!("\n=== Running QueryBuilder Tests ===\n");
    QueryBuilderWorld::cucumber()
        .fail_on_skipped()
        .run("../features/query_builder.feature")
        .await;

    // Run ErrorHandling tests
    println!("\n=== Running ErrorHandling Tests ===\n");
    ErrorHandlingWorld::cucumber()
        .fail_on_skipped()
        .run("../features/error_handling.feature")
        .await;

    // Run Router tests
    println!("\n=== Running Router Tests ===\n");
    RouterWorld::cucumber()
        .fail_on_skipped()
        .run("../features/router.feature")
        .await;

    // Run StateBuildingWorld tests
    println!("\n=== Running StateBuilding Tests ===\n");
    StateBuildingWorld::cucumber()
        .fail_on_skipped()
        .run("../features/state_building.feature")
        .await;

    // Run EventDecoding tests
    println!("\n=== Running EventDecoding Tests ===\n");
    EventDecodingWorld::cucumber()
        .fail_on_skipped()
        .run("../features/event_decoding.feature")
        .await;

    // Run Compensation tests
    println!("\n=== Running Compensation Tests ===\n");
    CompensationWorld::cucumber()
        .fail_on_skipped()
        .run("../features/compensation.feature")
        .await;
}