57 lines
1.8 KiB
Rust
57 lines
1.8 KiB
Rust
use ethers::{
|
|
providers::{Http, Middleware, Provider},
|
|
types::TransactionRequest,
|
|
utils::Geth,
|
|
};
|
|
use std::convert::TryFrom;
|
|
|
|
#[tokio::test]
|
|
async fn txpool() {
|
|
let geth = Geth::new().block_time(20u64).spawn();
|
|
let provider = Provider::<Http>::try_from(geth.endpoint()).unwrap();
|
|
|
|
let account = provider.get_accounts().await.unwrap()[0].clone();
|
|
let value: u64 = 42;
|
|
let gas_price = ethers::types::U256::from_dec_str("221435145689").unwrap();
|
|
let mut tx = TransactionRequest::new()
|
|
.to(account)
|
|
.from(account)
|
|
.value(value)
|
|
.gas_price(gas_price);
|
|
|
|
// send a few transactions
|
|
let mut txs = Vec::new();
|
|
for _ in 0..10 {
|
|
let tx_hash = provider.send_transaction(tx.clone(), None).await.unwrap();
|
|
txs.push(tx_hash);
|
|
}
|
|
|
|
// we gave a 20s block time, should be plenty for us to get the txpool's content
|
|
let status = provider.txpool_status().await.unwrap();
|
|
assert_eq!(status.pending.as_u64(), 10);
|
|
assert_eq!(status.queued.as_u64(), 0);
|
|
|
|
let inspect = provider.txpool_inspect().await.unwrap();
|
|
assert!(inspect.queued.is_empty());
|
|
let summary = inspect.pending.get(&account).unwrap();
|
|
for i in 0..10 {
|
|
let tx_summary = summary.get(&i.to_string()).unwrap();
|
|
assert_eq!(tx_summary.gas_price, gas_price);
|
|
assert_eq!(tx_summary.value, value.into());
|
|
assert_eq!(tx_summary.gas, 21000.into());
|
|
assert_eq!(tx_summary.to.unwrap(), account);
|
|
}
|
|
|
|
let content = provider.txpool_content().await.unwrap();
|
|
assert!(content.queued.is_empty());
|
|
let content = content.pending.get(&account).unwrap();
|
|
|
|
// the txs get their gas and nonce auto-set upon mempool entry
|
|
tx = tx.gas(21000);
|
|
for i in 0..10 {
|
|
tx = tx.nonce(i);
|
|
let req = content.get(&i.to_string()).unwrap();
|
|
assert_eq!(req, &tx);
|
|
}
|
|
}
|