ic_web3_rs/api/
txpool.rs

1//! `Txpool` namespace
2
3use crate::{
4    api::Namespace,
5    helpers::CallFuture,
6    transports::ic_http_client::CallOptions,
7    types::{TxpoolContentInfo, TxpoolInspectInfo, TxpoolStatus},
8    Transport,
9};
10
11/// `Txpool` namespace
12#[derive(Debug, Clone)]
13pub struct Txpool<T> {
14    transport: T,
15}
16
17impl<T: Transport> Namespace<T> for Txpool<T> {
18    fn new(transport: T) -> Self
19    where
20        Self: Sized,
21    {
22        Txpool { transport }
23    }
24
25    fn transport(&self) -> &T {
26        &self.transport
27    }
28}
29
30impl<T: Transport> Txpool<T> {
31    /// returns txpool content info
32    pub fn content(&self, options: CallOptions) -> CallFuture<TxpoolContentInfo, T::Out> {
33        CallFuture::new(self.transport.execute("txpool_content", vec![], options))
34    }
35
36    /// returns txpool inspect info
37    pub fn inspect(&self, options: CallOptions) -> CallFuture<TxpoolInspectInfo, T::Out> {
38        CallFuture::new(self.transport.execute("txpool_inspect", vec![], options))
39    }
40
41    /// returns txpool status
42    pub fn status(&self, options: CallOptions) -> CallFuture<TxpoolStatus, T::Out> {
43        CallFuture::new(self.transport.execute("txpool_status", vec![], options))
44    }
45}
46
47#[cfg(test)]
48mod tests {
49    use serde_json::Value;
50
51    use super::Txpool;
52    use crate::{
53        api::Namespace,
54        transports::ic_http_client::CallOptions,
55        types::{TxpoolContentInfo, TxpoolInspectInfo, TxpoolStatus},
56    };
57
58    const EXAMPLE_CONTENT_INFO: &str = r#"{
59        "pending": {
60            "0x0216d5032f356960cd3749c31ab34eeff21b3395": {
61              "806": {
62                "blockHash": "0x0000000000000000000000000000000000000000000000000000000000000000",
63                "blockNumber": null,
64                "from": "0x0216d5032f356960cd3749c31ab34eeff21b3395",
65                "gas": "0x5208",
66                "gasPrice": "0xba43b7400",
67                "hash": "0xaf953a2d01f55cfe080c0c94150a60105e8ac3d51153058a1f03dd239dd08586",
68                "input": "0x",
69                "nonce": "0x326",
70                "to": "0x7f69a91a3cf4be60020fb58b893b7cbb65376db8",
71                "transactionIndex": null,
72                "value": "0x19a99f0cf456000"
73              }
74            },
75            "0x24d407e5a0b506e1cb2fae163100b5de01f5193c": {
76              "34": {
77                "blockHash": "0x0000000000000000000000000000000000000000000000000000000000000000",
78                "blockNumber": null,
79                "from": "0x24d407e5a0b506e1cb2fae163100b5de01f5193c",
80                "gas": "0x44c72",
81                "gasPrice": "0x4a817c800",
82                "hash": "0xb5b8b853af32226755a65ba0602f7ed0e8be2211516153b75e9ed640a7d359fe",
83                "input": "0xb61d27f600000000000000000000000024d407e5a0b506e1cb2fae163100b5de01f5193c00000000000000000000000000000000000000000000000053444835ec580000000000000000000000000000000000000000000000000000000000000000006000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000",
84                "nonce": "0x22",
85                "to": "0x7320785200f74861b69c49e4ab32399a71b34f1a",
86                "transactionIndex": null,
87                "value": "0x0"
88              }
89            }
90          },
91          "queued": {
92            "0x976a3fc5d6f7d259ebfb4cc2ae75115475e9867c": {
93              "3": {
94                "blockHash": "0x0000000000000000000000000000000000000000000000000000000000000000",
95                "blockNumber": null,
96                "from": "0x976a3fc5d6f7d259ebfb4cc2ae75115475e9867c",
97                "gas": "0x15f90",
98                "gasPrice": "0x4a817c800",
99                "hash": "0x57b30c59fc39a50e1cba90e3099286dfa5aaf60294a629240b5bbec6e2e66576",
100                "input": "0x",
101                "nonce": "0x3",
102                "to": "0x346fb27de7e7370008f5da379f74dd49f5f2f80f",
103                "transactionIndex": null,
104                "value": "0x1f161421c8e0000"
105              }
106            },
107            "0x9b11bf0459b0c4b2f87f8cebca4cfc26f294b63a": {
108              "2": {
109                "blockHash": "0x0000000000000000000000000000000000000000000000000000000000000000",
110                "blockNumber": null,
111                "from": "0x9b11bf0459b0c4b2f87f8cebca4cfc26f294b63a",
112                "gas": "0x15f90",
113                "gasPrice": "0xba43b7400",
114                "hash": "0x3a3c0698552eec2455ed3190eac3996feccc806970a4a056106deaf6ceb1e5e3",
115                "input": "0x",
116                "nonce": "0x2",
117                "to": "0x24a461f25ee6a318bdef7f33de634a67bb67ac9d",
118                "transactionIndex": null,
119                "value": "0xebec21ee1da40000"
120              },
121              "6": {
122                "blockHash": "0x0000000000000000000000000000000000000000000000000000000000000000",
123                "blockNumber": null,
124                "from": "0x9b11bf0459b0c4b2f87f8cebca4cfc26f294b63a",
125                "gas": "0x15f90",
126                "gasPrice": "0x4a817c800",
127                "hash": "0xbbcd1e45eae3b859203a04be7d6e1d7b03b222ec1d66dfcc8011dd39794b147e",
128                "input": "0x",
129                "nonce": "0x6",
130                "to": "0x6368f3f8c2b42435d6c136757382e4a59436a681",
131                "transactionIndex": null,
132                "value": "0xf9a951af55470000"
133              }
134            }
135          }
136        }"#;
137
138    const EXAMPLE_INSPECT_INFO: &str = r#"{
139        "pending": {
140          "0x26588a9301b0428d95e6fc3a5024fce8bec12d51": {
141            "31813": "0x3375ee30428b2a71c428afa5e89e427905f95f7e: 0 wei + 500000 × 20000000000 gas"
142          },
143          "0x2a65aca4d5fc5b5c859090a6c34d164135398226": {
144            "563662": "0x958c1fa64b34db746925c6f8a3dd81128e40355e: 1051546810000000000 wei + 90000 × 20000000000 gas",
145            "563663": "0x77517b1491a0299a44d668473411676f94e97e34: 1051190740000000000 wei + 90000 × 20000000000 gas",
146            "563664": "0x3e2a7fe169c8f8eee251bb00d9fb6d304ce07d3a: 1050828950000000000 wei + 90000 × 20000000000 gas",
147            "563665": "0xaf6c4695da477f8c663ea2d8b768ad82cb6a8522: 1050544770000000000 wei + 90000 × 20000000000 gas",
148            "563666": "0x139b148094c50f4d20b01caf21b85edb711574db: 1048598530000000000 wei + 90000 × 20000000000 gas",
149            "563667": "0x48b3bd66770b0d1eecefce090dafee36257538ae: 1048367260000000000 wei + 90000 × 20000000000 gas",
150            "563668": "0x468569500925d53e06dd0993014ad166fd7dd381: 1048126690000000000 wei + 90000 × 20000000000 gas",
151            "563669": "0x3dcb4c90477a4b8ff7190b79b524773cbe3be661: 1047965690000000000 wei + 90000 × 20000000000 gas",
152            "563670": "0x6dfef5bc94b031407ffe71ae8076ca0fbf190963: 1047859050000000000 wei + 90000 × 20000000000 gas"
153          },
154          "0x9174e688d7de157c5c0583df424eaab2676ac162": {
155            "3": "0xbb9bc244d798123fde783fcc1c72d3bb8c189413: 30000000000000000000 wei + 85000 × 21000000000 gas"
156          },
157          "0xb18f9d01323e150096650ab989cfecd39d757aec": {
158            "777": "0xcd79c72690750f079ae6ab6ccd7e7aedc03c7720: 0 wei + 1000000 × 20000000000 gas"
159          },
160          "0xb2916c870cf66967b6510b76c07e9d13a5d23514": {
161            "2": "0x576f25199d60982a8f31a8dff4da8acb982e6aba: 26000000000000000000 wei + 90000 × 20000000000 gas"
162          },
163          "0xbc0ca4f217e052753614d6b019948824d0d8688b": {
164            "0": "0x2910543af39aba0cd09dbb2d50200b3e800a63d2: 1000000000000000000 wei + 50000 × 1171602790622 gas"
165          },
166          "0xea674fdde714fd979de3edf0f56aa9716b898ec8": {
167            "70148": "0xe39c55ead9f997f7fa20ebe40fb4649943d7db66: 1000767667434026200 wei + 90000 × 20000000000 gas"
168          }
169        },
170        "queued": {
171          "0x0f6000de1578619320aba5e392706b131fb1de6f": {
172            "6": "0x8383534d0bcd0186d326c993031311c0ac0d9b2d: 9000000000000000000 wei + 21000 × 20000000000 gas"
173          },
174          "0x5b30608c678e1ac464a8994c3b33e5cdf3497112": {
175            "6": "0x9773547e27f8303c87089dc42d9288aa2b9d8f06: 50000000000000000000 wei + 90000 × 50000000000 gas"
176          },
177          "0x976a3fc5d6f7d259ebfb4cc2ae75115475e9867c": {
178            "3": "0x346fb27de7e7370008f5da379f74dd49f5f2f80f: 140000000000000000 wei + 90000 × 20000000000 gas"
179          },
180          "0x9b11bf0459b0c4b2f87f8cebca4cfc26f294b63a": {
181            "2": "0x24a461f25ee6a318bdef7f33de634a67bb67ac9d: 17000000000000000000 wei + 90000 × 50000000000 gas",
182            "6": "0x6368f3f8c2b42435d6c136757382e4a59436a681: 17990000000000000000 wei + 90000 × 20000000000 gas",
183            "7": "0x6368f3f8c2b42435d6c136757382e4a59436a681: 17900000000000000000 wei + 90000 × 20000000000 gas"
184          }
185        }
186      }"#;
187
188    const EXAMPLE_STATUS: &str = r#"{
189        "pending": "0xa",
190        "queued": "0x7"
191    }"#;
192
193    rpc_test! (
194      Txpool:content,CallOptions::default() => "txpool_content",Vec::<String>::new();
195      ::serde_json::from_str(EXAMPLE_CONTENT_INFO).unwrap()
196      => ::serde_json::from_str::<TxpoolContentInfo>(EXAMPLE_CONTENT_INFO).unwrap()
197    );
198
199    rpc_test! (
200      Txpool:inspect,CallOptions::default() => "txpool_inspect",Vec::<String>::new();
201      ::serde_json::from_str(EXAMPLE_INSPECT_INFO).unwrap()
202      => ::serde_json::from_str::<TxpoolInspectInfo>(EXAMPLE_INSPECT_INFO).unwrap()
203    );
204
205    rpc_test! (
206      Txpool:status,CallOptions::default() => "txpool_status",Vec::<String>::new();
207      ::serde_json::from_str(EXAMPLE_STATUS).unwrap()
208      => ::serde_json::from_str::<TxpoolStatus>(EXAMPLE_STATUS).unwrap()
209    );
210}
ic_web3_rs/api/txpool.rs

ic_web3_rs/api/
txpool.rs
