otx-pool 0.1.0

The open transaction pool service core
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

mod r#impl;

use super::pool::OtxPool;

use otx_format::{jsonrpc_types::OpenTransaction, types::OpenTxStatus};

use ckb_types::H256;
use jsonrpc_core::Result as RpcResult;
use jsonrpc_derive::rpc;

use std::sync::Arc;

#[rpc(server)]
pub trait OtxPoolRpc {
    #[rpc(name = "submit_otx")]
    fn submit_otx(&self, otx: OpenTransaction) -> RpcResult<H256>;

    #[rpc(name = "query_otx_status_by_id")]
    fn query_otx_status_by_id(&self, id: H256) -> RpcResult<Option<OpenTxStatus>>;
}

pub struct OtxPoolRpcImpl {
    otx_pool: Arc<OtxPool>,
}

impl OtxPoolRpcImpl {
    pub fn new(otx_pool: Arc<OtxPool>) -> Self {
        OtxPoolRpcImpl { otx_pool }
    }
}