orga 0.1.10

State machine engine
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

use orga::abci::{Application, ABCIStateMachine, MemStore};
use orga::encoding::Decode;
use orga::state::Value;
use orga::store::Store;
use orga::Result;
use orga::macros::state;
use abci2::messages::abci::*;
use failure::bail;

struct CounterApp;

#[state]
struct CounterState<S: Store> {
    count: Value<u32>
}

impl CounterApp {
    fn run<S: Store>(&self, store: S, tx: &[u8]) -> Result<()> {
        if tx.len() != 4 {
            bail!("Transaction must be exactly 4 bytes");
        }
        let n = u32::decode(tx)?;

        let mut state: CounterState<_> = store.wrap()?;
        let count = state.count.get_or_default()?;

        if n != count {
            bail!("Incorrect count");
        }

        state.count.set(count + 1)?;

        Ok(())
    }
}

impl Application for CounterApp {
    fn deliver_tx<S: Store>(&self, store: S, req: RequestDeliverTx) -> Result<ResponseDeliverTx> {
        let bytes = req.get_tx();
        self.run(store, bytes)?;
        Ok(Default::default())
    }

    fn check_tx<S: Store>(&self, store: S, req: RequestCheckTx) -> Result<ResponseCheckTx> {
        let bytes = req.get_tx();
        self.run(store, bytes)?;
        Ok(Default::default())
    }
}

pub fn main() {
    let store = MemStore::new();
    ABCIStateMachine::new(CounterApp, store)
        .listen("localhost:26658")
        .unwrap();
}