flowstate 0.8.2

Workflow runtime powered by finite state machines.
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

use std::any::type_name;

use flowstate::prelude::*;

#[derive(Workflow)]
#[flowstate(
    result = MyWorkflowResult,
    state_trait = MyWorkflowState,
)]
struct MyWorkflow<State> {
    #[state]
    state: State,
    ctx: String,
}

#[derive(State)]
struct StateA;

impl MyWorkflowState for MyWorkflow<StateA> {
    fn next(self: Box<Self>) -> StaticTransition<MyWorkflowResult> {
        self.transition(StateB)
    }
}

#[derive(State)]
#[flowstate(name = "This is state B!")]
struct StateB;

impl MyWorkflowState for MyWorkflow<StateB> {
    fn next(self: Box<Self>) -> StaticTransition<MyWorkflowResult> {
        self.transition(StateC { random_number: 32 })
    }
}

#[derive(State)]
#[flowstate(name = self.name())]
struct StateC {
    random_number: u16,
}

impl StateC {
    fn name(&self) -> String {
        format!("{}({})", type_name::<StateC>(), self.random_number)
    }
}

impl MyWorkflowState for MyWorkflow<StateC> {
    fn next(self: Box<Self>) -> StaticTransition<MyWorkflowResult> {
        self.transition(StateD)
    }
}

#[derive(State)]
struct StateD;

impl MyWorkflowState for MyWorkflow<StateD> {
    fn state_name(&self) -> String {
        format!("{} (ctx = {})", self.state.name(), self.ctx)
    }

    fn next(self: Box<Self>) -> StaticTransition<MyWorkflowResult> {
        self.transition(StateB)
    }
}

type MyWorkflowResult = ();

#[test]
fn test_state_names_1() {
    let state_a_name = MyWorkflow::new(StateA, "ctx".into()).state_name();

    assert_eq!(state_a_name, "state_names::StateA");
}

#[test]
fn test_state_names_2() {
    let state_a_name = MyWorkflow::new(StateB, "ctx".into()).state_name();

    assert_eq!(state_a_name, "This is state B!");
}

#[test]
fn test_state_names_3() {
    let state_a_name = MyWorkflow::new(StateC { random_number: 42 }, "ctx".into()).state_name();

    assert_eq!(state_a_name, "state_names::StateC(42)");
}

#[test]
fn test_state_names_4() {
    let state_a_name = MyWorkflow::new(StateD, "some context".into()).state_name();

    assert_eq!(state_a_name, "state_names::StateD (ctx = some context)");
}