openethereum/rpc/src/v1/impls/eth.rs

518 lines
17 KiB
Rust
Raw Normal View History

2016-02-05 13:40:41 +01:00
// Copyright 2015, 2016 Ethcore (UK) Ltd.
// This file is part of Parity.
// Parity is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
// Parity is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
// You should have received a copy of the GNU General Public License
// along with Parity. If not, see <http://www.gnu.org/licenses/>.
//! Eth rpc implementation.
use std::collections::HashSet;
use std::sync::{Arc, Weak, Mutex};
use std::ops::Deref;
use ethsync::{SyncProvider, SyncState};
use ethminer::{MinerService};
2016-01-26 19:24:33 +01:00
use jsonrpc_core::*;
2016-02-29 22:21:15 +01:00
use util::numbers::*;
2016-01-27 12:31:54 +01:00
use util::sha3::*;
use util::rlp::encode;
2016-01-21 01:19:29 +01:00
use ethcore::client::*;
use ethcore::block::IsBlock;
2016-01-27 12:31:54 +01:00
use ethcore::views::*;
2016-02-29 19:30:13 +01:00
use ethcore::ethereum::Ethash;
use ethcore::ethereum::denominations::shannon;
use ethcore::transaction::Transaction as EthTransaction;
use v1::traits::{Eth, EthFilter};
2016-03-04 18:10:07 +01:00
use v1::types::{Block, BlockTransactions, BlockNumber, Bytes, SyncStatus, SyncInfo, Transaction, TransactionRequest, OptionalValue, Index, Filter, Log};
use v1::helpers::{PollFilter, PollManager, ExternalMinerService, ExternalMiner};
2016-03-10 17:18:01 +01:00
use util::keys::store::AccountProvider;
2016-01-21 01:19:29 +01:00
/// Eth rpc implementation.
pub struct EthClient<C, S, A, M, EM = ExternalMiner>
where C: BlockChainClient,
S: SyncProvider,
A: AccountProvider,
M: MinerService,
EM: ExternalMinerService {
client: Weak<C>,
sync: Weak<S>,
2016-03-10 17:18:01 +01:00
accounts: Weak<A>,
miner: Weak<M>,
external_miner: EM,
2016-01-21 01:19:29 +01:00
}
impl<C, S, A, M> EthClient<C, S, A, M, ExternalMiner>
where C: BlockChainClient,
S: SyncProvider,
A: AccountProvider,
M: MinerService {
/// Creates new EthClient.
2016-03-11 14:48:30 +01:00
pub fn new(client: &Arc<C>, sync: &Arc<S>, accounts: &Arc<A>, miner: &Arc<M>) -> Self {
EthClient::new_with_external_miner(client, sync, accounts, miner, ExternalMiner::default())
}
}
impl<C, S, A, M, EM> EthClient<C, S, A, M, EM>
where C: BlockChainClient,
S: SyncProvider,
A: AccountProvider,
M: MinerService,
EM: ExternalMinerService {
/// Creates new EthClient with custom external miner.
pub fn new_with_external_miner(client: &Arc<C>, sync: &Arc<S>, accounts: &Arc<A>, miner: &Arc<M>, em: EM)
-> EthClient<C, S, A, M, EM> {
2016-01-21 01:19:29 +01:00
EthClient {
2016-02-29 11:58:33 +01:00
client: Arc::downgrade(client),
2016-03-01 01:52:22 +01:00
sync: Arc::downgrade(sync),
miner: Arc::downgrade(miner),
2016-03-10 17:18:01 +01:00
accounts: Arc::downgrade(accounts),
external_miner: em,
2016-01-21 01:19:29 +01:00
}
}
2016-02-10 22:54:12 +01:00
fn block(&self, id: BlockId, include_txs: bool) -> Result<Value, Error> {
2016-02-29 11:58:33 +01:00
let client = take_weak!(self.client);
match (client.block(id.clone()), client.block_total_difficulty(id)) {
2016-02-10 22:54:12 +01:00
(Some(bytes), Some(total_difficulty)) => {
let block_view = BlockView::new(&bytes);
let view = block_view.header_view();
let block = Block {
hash: OptionalValue::Value(view.sha3()),
parent_hash: view.parent_hash(),
uncles_hash: view.uncles_hash(),
author: view.author(),
miner: view.author(),
state_root: view.state_root(),
transactions_root: view.transactions_root(),
receipts_root: view.receipts_root(),
number: OptionalValue::Value(U256::from(view.number())),
gas_used: view.gas_used(),
gas_limit: view.gas_limit(),
logs_bloom: view.log_bloom(),
timestamp: U256::from(view.timestamp()),
difficulty: view.difficulty(),
total_difficulty: total_difficulty,
uncles: vec![],
transactions: {
if include_txs {
BlockTransactions::Full(block_view.localized_transactions().into_iter().map(From::from).collect())
} else {
BlockTransactions::Hashes(block_view.transaction_hashes())
}
},
extra_data: Bytes::default()
};
to_value(&block)
},
_ => Ok(Value::Null)
}
}
2016-02-29 11:58:33 +01:00
2016-02-10 22:54:12 +01:00
fn transaction(&self, id: TransactionId) -> Result<Value, Error> {
2016-02-29 11:58:33 +01:00
match take_weak!(self.client).transaction(id) {
2016-02-10 22:54:12 +01:00
Some(t) => to_value(&Transaction::from(t)),
None => Ok(Value::Null)
}
}
2016-03-14 17:01:10 +01:00
fn uncle(&self, _block: BlockId, _index: usize) -> Result<Value, Error> {
// TODO: implement!
Ok(Value::Null)
}
2016-01-21 01:19:29 +01:00
}
impl<C, S, A, M, EM> Eth for EthClient<C, S, A, M, EM>
where C: BlockChainClient + 'static,
S: SyncProvider + 'static,
A: AccountProvider + 'static,
M: MinerService + 'static,
EM: ExternalMinerService + 'static {
2016-01-21 01:19:29 +01:00
fn protocol_version(&self, params: Params) -> Result<Value, Error> {
match params {
Params::None => Ok(Value::String(format!("{}", take_weak!(self.sync).status().protocol_version).to_owned())),
2016-01-21 01:19:29 +01:00
_ => Err(Error::invalid_params())
}
}
2016-02-05 13:21:34 +01:00
fn syncing(&self, params: Params) -> Result<Value, Error> {
match params {
2016-02-10 16:28:59 +01:00
Params::None => {
2016-02-29 11:58:33 +01:00
let status = take_weak!(self.sync).status();
2016-02-10 16:28:59 +01:00
let res = match status.state {
SyncState::NotSynced | SyncState::Idle => SyncStatus::None,
SyncState::Waiting | SyncState::Blocks | SyncState::NewBlocks => SyncStatus::Info(SyncInfo {
starting_block: U256::from(status.start_block_number),
2016-02-29 11:58:33 +01:00
current_block: U256::from(take_weak!(self.client).chain_info().best_block_number),
2016-02-10 16:28:59 +01:00
highest_block: U256::from(status.highest_block_number.unwrap_or(status.start_block_number))
})
};
to_value(&res)
}
2016-02-05 13:21:34 +01:00
_ => Err(Error::invalid_params())
}
}
// TODO: do not hardcode author.
2016-01-21 01:19:29 +01:00
fn author(&self, params: Params) -> Result<Value, Error> {
match params {
Params::None => to_value(&Address::new()),
2016-01-21 01:19:29 +01:00
_ => Err(Error::invalid_params())
}
}
2016-02-05 13:21:34 +01:00
// TODO: return real value of mining once it's implemented.
fn is_mining(&self, params: Params) -> Result<Value, Error> {
2016-01-21 11:25:39 +01:00
match params {
Params::None => to_value(&self.external_miner.is_mining()),
2016-01-21 11:25:39 +01:00
_ => Err(Error::invalid_params())
}
}
2016-02-05 13:21:34 +01:00
// TODO: return real hashrate once we have mining
fn hashrate(&self, params: Params) -> Result<Value, Error> {
2016-01-21 01:19:29 +01:00
match params {
Params::None => to_value(&self.external_miner.hashrate()),
2016-01-21 01:19:29 +01:00
_ => Err(Error::invalid_params())
}
}
2016-02-05 13:21:34 +01:00
fn gas_price(&self, params: Params) -> Result<Value, Error> {
2016-01-21 01:19:29 +01:00
match params {
Params::None => to_value(&(shannon() * U256::from(50))),
2016-01-21 01:19:29 +01:00
_ => Err(Error::invalid_params())
}
}
2016-01-21 11:25:39 +01:00
fn accounts(&self, _: Params) -> Result<Value, Error> {
let store = take_weak!(self.accounts);
match store.accounts() {
Ok(account_list) => to_value(&account_list),
Err(_) => Err(Error::internal_error())
}
}
2016-02-05 13:21:34 +01:00
fn block_number(&self, params: Params) -> Result<Value, Error> {
2016-01-21 11:25:39 +01:00
match params {
2016-02-29 11:58:33 +01:00
Params::None => to_value(&U256::from(take_weak!(self.client).chain_info().best_block_number)),
2016-01-21 11:25:39 +01:00
_ => Err(Error::invalid_params())
}
}
2016-01-26 00:42:07 +01:00
fn balance(&self, params: Params) -> Result<Value, Error> {
from_params::<(Address, BlockNumber)>(params)
.and_then(|(address, _block_number)| to_value(&take_weak!(self.client).balance(&address)))
}
fn storage_at(&self, params: Params) -> Result<Value, Error> {
from_params::<(Address, U256, BlockNumber)>(params)
.and_then(|(address, position, _block_number)|
to_value(&U256::from(take_weak!(self.client).storage_at(&address, &H256::from(position)))))
}
fn transaction_count(&self, params: Params) -> Result<Value, Error> {
from_params::<(Address, BlockNumber)>(params)
.and_then(|(address, _block_number)| to_value(&take_weak!(self.client).nonce(&address)))
}
fn block_transaction_count_by_hash(&self, params: Params) -> Result<Value, Error> {
2016-02-10 10:12:56 +01:00
from_params::<(H256,)>(params)
.and_then(|(hash,)| // match
to_value(&take_weak!(self.client).block(BlockId::Hash(hash))
.map_or_else(U256::zero, |bytes| U256::from(BlockView::new(&bytes).transactions_count()))))
2016-02-05 13:21:34 +01:00
}
fn block_transaction_count_by_number(&self, params: Params) -> Result<Value, Error> {
from_params::<(BlockNumber,)>(params)
.and_then(|(block_number,)| match block_number {
BlockNumber::Pending => to_value(&U256::from(take_weak!(self.miner).status().transaction_queue_pending)),
_ => to_value(&take_weak!(self.client).block(block_number.into())
.map_or_else(U256::zero, |bytes| U256::from(BlockView::new(&bytes).transactions_count())))
})
}
fn block_uncles_count_by_hash(&self, params: Params) -> Result<Value, Error> {
2016-02-10 10:12:56 +01:00
from_params::<(H256,)>(params)
.and_then(|(hash,)|
to_value(&take_weak!(self.client).block(BlockId::Hash(hash))
.map_or_else(U256::zero, |bytes| U256::from(BlockView::new(&bytes).uncles_count()))))
}
fn block_uncles_count_by_number(&self, params: Params) -> Result<Value, Error> {
from_params::<(BlockNumber,)>(params)
.and_then(|(block_number,)| match block_number {
BlockNumber::Pending => to_value(&U256::from(0)),
_ => to_value(&take_weak!(self.client).block(block_number.into())
.map_or_else(U256::zero, |bytes| U256::from(BlockView::new(&bytes).uncles_count())))
2016-02-10 10:12:56 +01:00
})
2016-01-26 00:42:07 +01:00
}
2016-01-26 11:37:24 +01:00
2016-02-08 10:58:08 +01:00
// TODO: do not ignore block number param
fn code_at(&self, params: Params) -> Result<Value, Error> {
2016-02-10 10:12:56 +01:00
from_params::<(Address, BlockNumber)>(params)
.and_then(|(address, _block_number)|
to_value(&take_weak!(self.client).code(&address).map_or_else(Bytes::default, Bytes::new)))
2016-02-08 10:58:08 +01:00
}
2016-02-10 22:54:12 +01:00
fn block_by_hash(&self, params: Params) -> Result<Value, Error> {
2016-02-10 10:12:56 +01:00
from_params::<(H256, bool)>(params)
2016-02-10 22:54:12 +01:00
.and_then(|(hash, include_txs)| self.block(BlockId::Hash(hash), include_txs))
}
fn block_by_number(&self, params: Params) -> Result<Value, Error> {
from_params::<(BlockNumber, bool)>(params)
.and_then(|(number, include_txs)| self.block(number.into(), include_txs))
2016-01-26 11:37:24 +01:00
}
2016-02-09 13:17:44 +01:00
2016-02-10 10:12:56 +01:00
fn transaction_by_hash(&self, params: Params) -> Result<Value, Error> {
from_params::<(H256,)>(params)
2016-02-10 22:54:12 +01:00
.and_then(|(hash,)| self.transaction(TransactionId::Hash(hash)))
}
fn transaction_by_block_hash_and_index(&self, params: Params) -> Result<Value, Error> {
from_params::<(H256, Index)>(params)
2016-02-10 22:54:12 +01:00
.and_then(|(hash, index)| self.transaction(TransactionId::Location(BlockId::Hash(hash), index.value())))
}
2016-02-10 22:36:59 +01:00
fn transaction_by_block_number_and_index(&self, params: Params) -> Result<Value, Error> {
from_params::<(BlockNumber, Index)>(params)
2016-02-10 22:54:12 +01:00
.and_then(|(number, index)| self.transaction(TransactionId::Location(number.into(), index.value())))
2016-02-09 13:17:44 +01:00
}
2016-02-15 13:18:26 +01:00
2016-03-14 17:01:10 +01:00
fn uncle_by_block_hash_and_index(&self, params: Params) -> Result<Value, Error> {
from_params::<(H256, Index)>(params)
.and_then(|(hash, index)| self.uncle(BlockId::Hash(hash), index.value()))
}
fn uncle_by_block_number_and_index(&self, params: Params) -> Result<Value, Error> {
from_params::<(BlockNumber, Index)>(params)
.and_then(|(number, index)| self.uncle(number.into(), index.value()))
}
2016-03-13 15:02:46 +01:00
fn compilers(&self, params: Params) -> Result<Value, Error> {
match params {
Params::None => to_value(&vec![] as &Vec<String>),
_ => Err(Error::invalid_params())
}
}
2016-02-15 13:18:26 +01:00
fn logs(&self, params: Params) -> Result<Value, Error> {
from_params::<(Filter,)>(params)
.and_then(|(filter,)| {
2016-02-29 11:58:33 +01:00
let logs = take_weak!(self.client).logs(filter.into())
2016-02-15 13:39:58 +01:00
.into_iter()
.map(From::from)
.collect::<Vec<Log>>();
to_value(&logs)
2016-02-15 13:18:26 +01:00
})
}
2016-02-29 19:30:13 +01:00
fn work(&self, params: Params) -> Result<Value, Error> {
match params {
Params::None => {
2016-03-15 17:56:35 +01:00
// check if we're still syncing and return empty strings int that case
2016-03-15 17:13:44 +01:00
{
let sync = take_weak!(self.sync);
if sync.status().state != SyncState::Idle {
return to_value(&(String::new(), String::new(), String::new()));
}
}
let miner = take_weak!(self.miner);
let client = take_weak!(self.client);
let u = miner.sealing_block(client.deref()).lock().unwrap();
2016-02-29 19:30:13 +01:00
match *u {
Some(ref b) => {
let pow_hash = b.hash();
2016-02-29 19:30:13 +01:00
let target = Ethash::difficulty_to_boundary(b.block().header().difficulty());
2016-03-01 01:15:00 +01:00
let seed_hash = Ethash::get_seedhash(b.block().header().number());
to_value(&(pow_hash, seed_hash, target))
2016-02-29 19:30:13 +01:00
}
_ => Err(Error::invalid_params())
}
},
_ => Err(Error::invalid_params())
}
}
fn submit_work(&self, params: Params) -> Result<Value, Error> {
from_params::<(H64, H256, H256)>(params).and_then(|(nonce, pow_hash, mix_hash)| {
// trace!("Decoded: nonce={}, pow_hash={}, mix_hash={}", nonce, pow_hash, mix_hash);
let miner = take_weak!(self.miner);
let client = take_weak!(self.client);
let seal = vec![encode(&mix_hash).to_vec(), encode(&nonce).to_vec()];
let r = miner.submit_seal(client.deref(), pow_hash, seal);
to_value(&r.is_ok())
})
}
2016-02-29 19:30:13 +01:00
2016-03-01 01:15:00 +01:00
fn submit_hashrate(&self, params: Params) -> Result<Value, Error> {
2016-03-01 01:52:22 +01:00
// TODO: Index should be U256.
from_params::<(U256, H256)>(params).and_then(|(rate, id)| {
self.external_miner.submit_hashrate(rate, id);
2016-03-01 01:15:00 +01:00
to_value(&true)
})
}
2016-03-04 18:10:07 +01:00
fn send_transaction(&self, params: Params) -> Result<Value, Error> {
from_params::<(TransactionRequest, )>(params)
.and_then(|(transaction_request, )| {
2016-03-10 17:18:01 +01:00
let accounts = take_weak!(self.accounts);
match accounts.account_secret(&transaction_request.from) {
2016-03-05 16:29:01 +01:00
Ok(secret) => {
2016-03-11 14:48:30 +01:00
let miner = take_weak!(self.miner);
let client = take_weak!(self.client);
let transaction: EthTransaction = transaction_request.into();
2016-03-05 16:29:01 +01:00
let signed_transaction = transaction.sign(&secret);
let hash = signed_transaction.hash();
2016-03-11 14:48:30 +01:00
let import = miner.import_transactions(vec![signed_transaction], |a: &Address| client.nonce(a));
match import {
Ok(_) => to_value(&hash),
Err(e) => {
warn!("Error sending transaction: {:?}", e);
to_value(&U256::zero())
}
}
2016-03-04 18:10:07 +01:00
},
2016-03-05 16:29:01 +01:00
Err(_) => { to_value(&U256::zero()) }
2016-03-04 18:10:07 +01:00
}
})
}
2016-01-21 11:25:39 +01:00
}
/// Eth filter rpc implementation.
pub struct EthFilterClient<C, M>
where C: BlockChainClient,
M: MinerService {
client: Weak<C>,
miner: Weak<M>,
2016-03-02 05:46:38 +01:00
polls: Mutex<PollManager<PollFilter>>,
2016-01-21 11:25:39 +01:00
}
impl<C, M> EthFilterClient<C, M>
where C: BlockChainClient,
M: MinerService {
/// Creates new Eth filter client.
pub fn new(client: &Arc<C>, miner: &Arc<M>) -> Self {
2016-01-21 11:25:39 +01:00
EthFilterClient {
client: Arc::downgrade(client),
2016-03-10 16:00:55 +01:00
miner: Arc::downgrade(miner),
polls: Mutex::new(PollManager::new()),
2016-01-21 11:25:39 +01:00
}
}
}
impl<C, M> EthFilter for EthFilterClient<C, M>
where C: BlockChainClient + 'static,
M: MinerService + 'static {
2016-02-23 18:51:29 +01:00
fn new_filter(&self, params: Params) -> Result<Value, Error> {
from_params::<(Filter,)>(params)
.and_then(|(filter,)| {
let mut polls = self.polls.lock().unwrap();
let block_number = take_weak!(self.client).chain_info().best_block_number;
let id = polls.create_poll(PollFilter::Logs(block_number, filter.into()));
2016-02-23 18:51:29 +01:00
to_value(&U256::from(id))
})
}
fn new_block_filter(&self, params: Params) -> Result<Value, Error> {
match params {
Params::None => {
let mut polls = self.polls.lock().unwrap();
let id = polls.create_poll(PollFilter::Block(take_weak!(self.client).chain_info().best_block_number));
2016-02-23 18:51:29 +01:00
to_value(&U256::from(id))
},
_ => Err(Error::invalid_params())
}
2016-01-21 11:25:39 +01:00
}
2016-02-23 18:51:29 +01:00
fn new_pending_transaction_filter(&self, params: Params) -> Result<Value, Error> {
match params {
Params::None => {
let mut polls = self.polls.lock().unwrap();
2016-03-10 16:00:55 +01:00
let pending_transactions = take_weak!(self.miner).pending_transactions_hashes();
let id = polls.create_poll(PollFilter::PendingTransaction(pending_transactions));
2016-03-10 16:00:55 +01:00
2016-02-23 18:51:29 +01:00
to_value(&U256::from(id))
},
_ => Err(Error::invalid_params())
}
2016-01-21 11:25:39 +01:00
}
2016-02-23 18:51:29 +01:00
fn filter_changes(&self, params: Params) -> Result<Value, Error> {
let client = take_weak!(self.client);
2016-02-23 18:51:29 +01:00
from_params::<(Index,)>(params)
.and_then(|(index,)| {
let mut polls = self.polls.lock().unwrap();
match polls.poll_mut(&index.value()) {
2016-02-23 18:51:29 +01:00
None => Ok(Value::Array(vec![] as Vec<Value>)),
Some(filter) => match *filter {
PollFilter::Block(ref mut block_number) => {
// + 1, cause we want to return hashes including current block hash.
let current_number = client.chain_info().best_block_number + 1;
let hashes = (*block_number..current_number).into_iter()
.map(BlockId::Number)
.filter_map(|id| client.block_hash(id))
.collect::<Vec<H256>>();
*block_number = current_number;
to_value(&hashes)
2016-02-23 18:51:29 +01:00
},
PollFilter::PendingTransaction(ref mut previous_hashes) => {
2016-03-10 16:00:55 +01:00
let current_hashes = take_weak!(self.miner).pending_transactions_hashes();
// calculate diff
let previous_hashes_set = previous_hashes.into_iter().map(|h| h.clone()).collect::<HashSet<H256>>();
2016-03-10 16:00:55 +01:00
let diff = current_hashes
.iter()
2016-03-10 16:00:55 +01:00
.filter(|hash| previous_hashes_set.contains(&hash))
.cloned()
2016-03-10 16:00:55 +01:00
.collect::<Vec<H256>>();
*previous_hashes = current_hashes;
2016-03-10 16:00:55 +01:00
to_value(&diff)
2016-02-23 18:51:29 +01:00
},
PollFilter::Logs(ref mut block_number, ref mut filter) => {
filter.from_block = BlockId::Number(*block_number);
2016-02-23 18:51:29 +01:00
filter.to_block = BlockId::Latest;
let logs = client.logs(filter.clone())
2016-02-23 18:51:29 +01:00
.into_iter()
.map(From::from)
.collect::<Vec<Log>>();
let current_number = client.chain_info().best_block_number;
2016-02-23 18:51:29 +01:00
*block_number = current_number;
2016-02-23 18:51:29 +01:00
to_value(&logs)
}
}
}
})
2016-01-21 11:25:39 +01:00
}
fn uninstall_filter(&self, params: Params) -> Result<Value, Error> {
from_params::<(Index,)>(params)
.and_then(|(index,)| {
self.polls.lock().unwrap().remove_poll(&index.value());
to_value(&true)
})
}
2016-01-21 01:19:29 +01:00
}