// Copyright 2015-2020 Parity Technologies (UK) Ltd.
// This file is part of OpenEthereum.
// OpenEthereum 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.
// OpenEthereum 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 OpenEthereum. If not, see .
//! Parity-specific rpc implementation.
use std::{collections::BTreeMap, str::FromStr, sync::Arc};
use crypto::DEFAULT_MAC;
use ethcore::{
client::{BlockChainClient, Call, StateClient},
miner::{self, MinerService},
snapshot::{RestorationStatus, SnapshotService},
state::StateInfo,
};
use ethcore_logger::RotatingLogger;
use ethereum_types::{Address, H160, H256, H512, H64, U256, U64};
use ethkey::{crypto::ecies, Brain, Generator};
use ethstore::random_phrase;
use jsonrpc_core::{futures::future, BoxFuture, Result};
use stats::PrometheusMetrics;
use sync::{ManageNetwork, SyncProvider};
use types::ids::BlockId;
use version::version_data;
use v1::{
helpers::{
self,
block_import::is_major_importing,
errors,
external_signer::{SignerService, SigningQueue},
fake_sign, verify_signature, NetworkSettings,
},
metadata::Metadata,
traits::Parity,
types::{
block_number_to_id, BlockNumber, Bytes, CallRequest, ChainStatus, Histogram,
LocalTransactionStatus, Peers, Receipt, RecoveredAccount, RichHeader, RpcSettings,
Transaction, TransactionStats,
},
};
use Host;
/// Parity implementation.
pub struct ParityClient
where
C: PrometheusMetrics,
{
client: Arc,
miner: Arc,
sync: Arc,
net: Arc,
logger: Arc,
settings: Arc,
signer: Option>,
ws_address: Option,
snapshot: Option>,
}
impl ParityClient
where
C: BlockChainClient + PrometheusMetrics,
{
/// Creates new `ParityClient`.
pub fn new(
client: Arc,
miner: Arc,
sync: Arc,
net: Arc,
logger: Arc,
settings: Arc,
signer: Option>,
ws_address: Option,
snapshot: Option>,
) -> Self {
ParityClient {
client,
miner,
sync,
net,
logger,
settings,
signer,
ws_address,
snapshot,
}
}
}
impl Parity for ParityClient
where
S: StateInfo + 'static,
C: miner::BlockChainClient
+ BlockChainClient
+ PrometheusMetrics
+ StateClient
+ Call
+ 'static,
M: MinerService + 'static,
{
type Metadata = Metadata;
fn transactions_limit(&self) -> Result {
Ok(self.miner.queue_status().limits.max_count)
}
fn min_gas_price(&self) -> Result {
Ok(self.miner.queue_status().options.minimal_gas_price)
}
fn extra_data(&self) -> Result {
Ok(Bytes::new(self.miner.authoring_params().extra_data))
}
fn gas_floor_target(&self) -> Result {
Ok(self.miner.authoring_params().gas_range_target.0)
}
fn gas_ceil_target(&self) -> Result {
Ok(self.miner.authoring_params().gas_range_target.1)
}
fn dev_logs(&self) -> Result> {
warn!("This method is deprecated and will be removed in future. See PR #10102");
let logs = self.logger.logs();
Ok(logs.as_slice().to_owned())
}
fn dev_logs_levels(&self) -> Result {
Ok(self.logger.levels().to_owned())
}
fn net_chain(&self) -> Result {
Ok(self.settings.chain.clone())
}
fn chain(&self) -> Result {
Ok(self.client.spec_name())
}
fn net_peers(&self) -> Result {
let sync_status = self.sync.status();
let num_peers_range = self.net.num_peers_range();
debug_assert!(num_peers_range.end() >= num_peers_range.start());
let peers = self.sync.peers().into_iter().map(Into::into).collect();
Ok(Peers {
active: sync_status.num_active_peers,
connected: sync_status.num_peers,
max: sync_status.current_max_peers(*num_peers_range.start(), *num_peers_range.end()),
peers,
})
}
fn net_port(&self) -> Result {
Ok(self.settings.network_port)
}
fn node_name(&self) -> Result {
Ok(self.settings.name.clone())
}
fn registry_address(&self) -> Result