add mocked test for eth_sendRawTransaction
This commit is contained in:
parent
be1ec93271
commit
89659606dd
@ -59,22 +59,14 @@ fn dispatch_transaction<C, M>(client: &C, miner: &M, signed_transaction: SignedT
|
|||||||
where C: BlockChainClient, M: MinerService {
|
where C: BlockChainClient, M: MinerService {
|
||||||
let hash = signed_transaction.hash();
|
let hash = signed_transaction.hash();
|
||||||
|
|
||||||
let import = {
|
let import = miner.import_own_transaction(client, signed_transaction, |a: &Address| {
|
||||||
miner.import_own_transaction(client, signed_transaction, |a: &Address| {
|
AccountDetails {
|
||||||
AccountDetails {
|
nonce: client.latest_nonce(&a),
|
||||||
nonce: client.latest_nonce(&a),
|
balance: client.latest_balance(&a),
|
||||||
balance: client.latest_balance(&a),
|
|
||||||
}
|
|
||||||
})
|
|
||||||
};
|
|
||||||
|
|
||||||
match import {
|
|
||||||
Ok(_) => to_value(&hash),
|
|
||||||
Err(e) => {
|
|
||||||
warn!("Error sending transaction: {:?}", e);
|
|
||||||
to_value(&H256::zero())
|
|
||||||
}
|
}
|
||||||
}
|
});
|
||||||
|
|
||||||
|
to_value(&import.map(|_| hash).unwrap_or(H256::zero()))
|
||||||
}
|
}
|
||||||
|
|
||||||
fn sign_and_dispatch<C, M>(client: &Weak<C>, miner: &Weak<M>, request: TransactionRequest, secret: H256) -> Result<Value, Error>
|
fn sign_and_dispatch<C, M>(client: &Weak<C>, miner: &Weak<M>, request: TransactionRequest, secret: H256) -> Result<Value, Error>
|
||||||
|
@ -28,6 +28,7 @@ use ethcore::transaction::{Transaction, Action};
|
|||||||
use ethminer::ExternalMiner;
|
use ethminer::ExternalMiner;
|
||||||
use v1::{Eth, EthClient};
|
use v1::{Eth, EthClient};
|
||||||
use v1::tests::helpers::{TestSyncProvider, Config, TestMinerService};
|
use v1::tests::helpers::{TestSyncProvider, Config, TestMinerService};
|
||||||
|
use rustc_serialize::hex::ToHex;
|
||||||
|
|
||||||
fn blockchain_client() -> Arc<TestBlockChainClient> {
|
fn blockchain_client() -> Arc<TestBlockChainClient> {
|
||||||
let client = TestBlockChainClient::new();
|
let client = TestBlockChainClient::new();
|
||||||
@ -215,18 +216,22 @@ fn rpc_eth_balance() {
|
|||||||
assert_eq!(tester.io.handle_request(request), Some(response.to_owned()));
|
assert_eq!(tester.io.handle_request(request), Some(response.to_owned()));
|
||||||
}
|
}
|
||||||
|
|
||||||
#[ignore] //TODO: propert test
|
|
||||||
#[test]
|
#[test]
|
||||||
fn rpc_eth_balance_pending() {
|
fn rpc_eth_balance_pending() {
|
||||||
let tester = EthTester::default();
|
let tester = EthTester::default();
|
||||||
|
tester.client.set_balance(Address::from(1), U256::from(5));
|
||||||
|
|
||||||
let request = r#"{
|
let request = r#"{
|
||||||
"jsonrpc": "2.0",
|
"jsonrpc": "2.0",
|
||||||
"method": "eth_getBalance",
|
"method": "eth_getBalance",
|
||||||
"params": ["0x0000000000000000000000000000000000000001", "latest"],
|
"params": ["0x0000000000000000000000000000000000000001", "pending"],
|
||||||
"id": 1
|
"id": 1
|
||||||
}"#;
|
}"#;
|
||||||
let response = r#"{"jsonrpc":"2.0","result":"0x","id":1}"#;
|
|
||||||
|
// the TestMinerService doesn't communicate with the the TestBlockChainClient in any way.
|
||||||
|
// if this returns zero, we know that the "pending" call is being properly forwarded to the
|
||||||
|
// miner.
|
||||||
|
let response = r#"{"jsonrpc":"2.0","result":"0x00","id":1}"#;
|
||||||
|
|
||||||
assert_eq!(tester.io.handle_request(request), Some(response.to_owned()));
|
assert_eq!(tester.io.handle_request(request), Some(response.to_owned()));
|
||||||
}
|
}
|
||||||
@ -525,7 +530,7 @@ fn rpc_eth_send_transaction() {
|
|||||||
|
|
||||||
let response = r#"{"jsonrpc":"2.0","result":""#.to_owned() + format!("0x{:?}", t.hash()).as_ref() + r#"","id":1}"#;
|
let response = r#"{"jsonrpc":"2.0","result":""#.to_owned() + format!("0x{:?}", t.hash()).as_ref() + r#"","id":1}"#;
|
||||||
|
|
||||||
assert_eq!(tester.io.handle_request(request.as_ref()), Some(response));
|
assert_eq!(tester.io.handle_request(&request), Some(response));
|
||||||
|
|
||||||
tester.miner.last_nonces.write().unwrap().insert(address.clone(), U256::zero());
|
tester.miner.last_nonces.write().unwrap().insert(address.clone(), U256::zero());
|
||||||
|
|
||||||
@ -540,13 +545,38 @@ fn rpc_eth_send_transaction() {
|
|||||||
|
|
||||||
let response = r#"{"jsonrpc":"2.0","result":""#.to_owned() + format!("0x{:?}", t.hash()).as_ref() + r#"","id":1}"#;
|
let response = r#"{"jsonrpc":"2.0","result":""#.to_owned() + format!("0x{:?}", t.hash()).as_ref() + r#"","id":1}"#;
|
||||||
|
|
||||||
assert_eq!(tester.io.handle_request(request.as_ref()), Some(response));
|
assert_eq!(tester.io.handle_request(&request), Some(response));
|
||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
#[ignore]
|
|
||||||
fn rpc_eth_send_raw_transaction() {
|
fn rpc_eth_send_raw_transaction() {
|
||||||
unimplemented!()
|
let tester = EthTester::default();
|
||||||
|
let address = tester.accounts_provider.new_account("abcd").unwrap();
|
||||||
|
let secret = tester.accounts_provider.account_secret(&address).unwrap();
|
||||||
|
|
||||||
|
let t = Transaction {
|
||||||
|
nonce: U256::zero(),
|
||||||
|
gas_price: U256::from(0x9184e72a000u64),
|
||||||
|
gas: U256::from(0x76c0),
|
||||||
|
action: Action::Call(Address::from_str("d46e8dd67c5d32be8058bb8eb970870f07244567").unwrap()),
|
||||||
|
value: U256::from(0x9184e72au64),
|
||||||
|
data: vec![]
|
||||||
|
}.sign(&secret);
|
||||||
|
|
||||||
|
let rlp = ::util::rlp::encode(&t).to_vec().to_hex();
|
||||||
|
|
||||||
|
let req = r#"{
|
||||||
|
"jsonrpc": "2.0",
|
||||||
|
"method": "eth_sendRawTransaction",
|
||||||
|
"params": [
|
||||||
|
"0x"#.to_owned() + &rlp + r#""
|
||||||
|
],
|
||||||
|
"id": 1
|
||||||
|
}"#;
|
||||||
|
|
||||||
|
let res = r#"{"jsonrpc":"2.0","result":""#.to_owned() + &format!("0x{:?}", t.hash()) + r#"","id":1}"#;
|
||||||
|
|
||||||
|
assert_eq!(tester.io.handle_request(&req), Some(res));
|
||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
|
Loading…
Reference in New Issue
Block a user