pipecircuit-cli 0.0.2

Command-line architectural tools for Pipecircuit programs
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

use app_core::{
    domain_primitives::{Amount, Count},
    state_machines::{Add, AddOutcome, Counter, Read},
};
use pipecircuit::{Pipe, StateMachine, StepInputOf};

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub enum Request {
    Add(Amount),
    Read,
}

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub enum Reply {
    Added(AddOutcome),
    Snapshot(Count),
}

pub struct Client;

impl Pipe for Client {
    type In<'message> = Reply;
    type Out<'message> = Request;
}

pub struct Counting;

impl Pipe for Counting {
    type In<'message> = Request;
    type Out<'message> = Reply;
}

pub struct CounterAuthority(Counter);

impl CounterAuthority {
    pub const fn new(counter: Counter) -> Self {
        Self(counter)
    }
}

impl StateMachine for CounterAuthority {}

impl StepInputOf<CounterAuthority> for Request {
    type Outcome = Reply;

    fn step(self, authority: &mut CounterAuthority) -> Reply {
        match self {
            Self::Add(amount) => Reply::Added(authority.0.step(Add { amount })),
            Self::Read => Reply::Snapshot(authority.0.step(Read)),
        }
    }
}