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

use cfx_rpc_eth_types::{
    TxpoolContent, TxpoolContentFrom, TxpoolInspect, TxpoolStatus,
};
use cfx_types::Address;
use jsonrpsee::{core::RpcResult, proc_macros::rpc};

/// Txpool rpc interface.
#[rpc(server, namespace = "txpool")]
pub trait TxPoolApi {
    /// Returns the number of transactions currently pending for inclusion in
    /// the next block(s), as well as the ones that are being scheduled for
    /// future execution only.
    ///
    /// See [here](https://geth.ethereum.org/docs/rpc/ns-txpool#txpool_status) for more details
    #[method(name = "status")]
    async fn txpool_status(&self) -> RpcResult<TxpoolStatus>;

    /// Returns a summary of all the transactions currently pending for
    /// inclusion in the next block(s), as well as the ones that are being
    /// scheduled for future execution only.
    ///
    /// See [here](https://geth.ethereum.org/docs/rpc/ns-txpool#txpool_inspect) for more details
    #[method(name = "inspect")]
    async fn txpool_inspect(&self) -> RpcResult<TxpoolInspect>;

    /// Retrieves the transactions contained within the txpool, returning
    /// pending as well as queued transactions of this address, grouped by
    /// nonce.
    ///
    /// See [here](https://geth.ethereum.org/docs/rpc/ns-txpool#txpool_contentFrom) for more details
    #[method(name = "contentFrom")]
    async fn txpool_content_from(
        &self, from: Address,
    ) -> RpcResult<TxpoolContentFrom>;

    /// Returns the details of all transactions currently pending for inclusion
    /// in the next block(s), as well as the ones that are being scheduled
    /// for future execution only.
    ///
    /// See [here](https://geth.ethereum.org/docs/rpc/ns-txpool#txpool_content) for more details
    #[method(name = "content")]
    async fn txpool_content(&self) -> RpcResult<TxpoolContent>;
}