async-abci 0.1.0

A async abci server.
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

use async_abci::Server;
use std::{io, time::Duration};
use tm_abci::{Consensus, Mempool, Snapshot, Query};
use tm_protos::abci::{
    CheckTxType, RequestDeliverTx,
    ResponseDeliverTx,
};
use tokio::time::sleep;

struct App {}

#[async_trait::async_trait]
impl Consensus for App {
    async fn deliver_tx(&self, _request: RequestDeliverTx) -> ResponseDeliverTx {
        sleep(Duration::from_secs(10)).await;

        Default::default()
    }
}

#[async_trait::async_trait]
impl Mempool for App {
    async fn check_tx(
        &self,
        _request: tm_protos::abci::RequestCheckTx,
    ) -> tm_protos::abci::ResponseCheckTx {
        if CheckTxType::from_i32(_request.r#type).unwrap() == CheckTxType::New {
            sleep(Duration::from_secs(2)).await;
        }

        Default::default()
    }
}

impl Snapshot for App {}

impl Query for App {}

#[tokio::main]
async fn main() -> io::Result<()> {
    env_logger::init();

    let app = App {};

    Server::new(app)
        .bind("127.0.0.1:26658")
        .await
        .unwrap()
        .run()
        .await
        .unwrap();
    Ok(())
}