cc44ae9cb5
* `duration_ns: u64 -> duration: Duration` (#8457) * duration_ns: u64 -> duration: Duration * format on millis {:.2} -> {} * Keep all enacted blocks notify in order (#8524) * Keep all enacted blocks notify in order * Collect is unnecessary * Update ChainNotify to use ChainRouteType * Fix all ethcore fn defs * Wrap the type within ChainRoute * Fix private-tx and sync api * Fix secret_store API * Fix updater API * Fix rpc api * Fix informant api * Eagerly cache enacted/retracted and remove contain_enacted/retracted * Fix indent * tests: should use full expr form for struct constructor * Use into_enacted_retracted to further avoid copy * typo: not a function * rpc/tests: ChainRoute -> ChainRoute::new * Handle removed logs in filter changes and add geth compatibility field (#8796) * Add removed geth compatibility field in log * Fix mocked tests * Add field block hash in PollFilter * Store last block hash info for log filters * Implement canon route * Use canon logs for fetching reorg logs Light client removed logs fetching is disabled. It looks expensive. * Make sure removed flag is set * Address grumbles * Fixed AuthorityRound deadlock on shutdown, closes #8088 (#8803) * CI: Fix docker tags (#8822) * scripts: enable docker builds for beta and stable * scripts: docker latest should be beta not master * scripts: docker latest is master * ethcore: fix ancient block error msg handling (#8832) * Disable parallel verification and skip verifiying already imported txs. (#8834) * Reject transactions that are already in pool without verifying them. * Avoid verifying already imported transactions. * Fix concurrent access to signer queue (#8854) * Fix concurrent access to signer queue * Put request back to the queue if confirmation failed * typo: fix docs and rename functions to be more specific `request_notify` does not need to be public, and it's renamed to `notify_result`. `notify` is renamed to `notify_message`. * Change trace info "Transaction" -> "Request" * Don't allocate in expect_valid_rlp unless necessary (#8867) * don't allocate via format! in case there's no error * fix test? * fixed ipc leak, closes #8774 (#8876) * Add new ovh bootnodes and fix port for foundation bootnode 3.2 (#8886) * Add new ovh bootnodes and fix port for foundation bootnode 3.2 * Remove old bootnodes. * Remove duplicate 1118980bf48b0a3640bdba04e0fe78b1add18e1cd99bf22d53daac1fd9972ad650df52176e7c7d89d1114cfef2bc23a2959aa54998a46afcf7d91809f0855082 * Block 0 is valid in queries (#8891) Early exit for block nr 0 leads to spurious error about pruning: `…your node is running with state pruning…`. Fixes #7547, #8762 * Add ETC Cooperative-run load balanced parity node (#8892) * Minor fix in chain supplier and light provider (#8906) * fix chain supplier increment * fix light provider block_headers * Check whether we need resealing in miner and unwrap has_account in account_provider (#8853) * Remove unused Result wrap in has_account * Check whether we need to reseal for external transactions * Fix reference to has_account interface * typo: missing ) * Refactor duplicates to prepare_and_update_sealing * Fix build * Allow disabling local-by-default for transactions with new config entry (#8882) * Add tx_queue_allow_unknown_local config option - Previous commit messages: dispatcher checks if we have the sender account Add `tx_queue_allow_unknown_local` to MinerOptions Add `tx_queue_allow_unknown_local` to config fix order in MinerOptions to match Configuration add cli flag for tx_queue_allow_unknown_local Update refs to `tx_queue_allow_unknown_local` Add tx_queue_allow_unknown_local to config test revert changes to dispatcher Move tx_queue_allow_unknown_local to `import_own_transaction` Fix var name if statement should return the values derp de derp derp derp semicolons Reset dispatch file to how it was before fix compile issues + change from FLAG to ARG add test and use `into` import MinerOptions, clone the secret Fix tests? Compiler/linter issues fixed Fix linter msg - case of constants IT LIVES refactor to omit yucky explict return update comments Fix based on diff AccountProvider.has_account method * Refactor flag name + don't change import_own_tx behaviour fix arg name Note: force commit to try and get gitlab tests working again 😠 * Add fn to TestMinerService * Avoid race condition from trusted sources - refactor the miner tests a bit to cut down on code reuse - add `trusted` param to dispatch_transaction and import_claimed_local_transaction Add param to `import_claimed_local_transaction` Fix fn sig in tests
225 lines
14 KiB
Rust
225 lines
14 KiB
Rust
// Copyright 2015-2017 Parity Technologies (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/>.
|
|
|
|
use std::sync::Arc;
|
|
|
|
use jsonrpc_core::MetaIoHandler;
|
|
use jsonrpc_core::futures::{self, Stream, Future};
|
|
use jsonrpc_pubsub::Session;
|
|
|
|
use std::time::Duration;
|
|
|
|
use v1::{EthPubSub, EthPubSubClient, Metadata};
|
|
|
|
use ethcore::client::{TestBlockChainClient, EachBlockWith, ChainNotify, ChainRoute, ChainRouteType};
|
|
use parity_reactor::EventLoop;
|
|
|
|
const DURATION_ZERO: Duration = Duration::from_millis(0);
|
|
|
|
#[test]
|
|
fn should_subscribe_to_new_heads() {
|
|
// given
|
|
let el = EventLoop::spawn();
|
|
let mut client = TestBlockChainClient::new();
|
|
// Insert some blocks
|
|
client.add_blocks(3, EachBlockWith::Nothing);
|
|
let h3 = client.block_hash_delta_minus(1);
|
|
let h2 = client.block_hash_delta_minus(2);
|
|
let h1 = client.block_hash_delta_minus(3);
|
|
|
|
let pubsub = EthPubSubClient::new_test(Arc::new(client), el.remote());
|
|
let handler = pubsub.handler().upgrade().unwrap();
|
|
let pubsub = pubsub.to_delegate();
|
|
|
|
let mut io = MetaIoHandler::default();
|
|
io.extend_with(pubsub);
|
|
|
|
let mut metadata = Metadata::default();
|
|
let (sender, receiver) = futures::sync::mpsc::channel(8);
|
|
metadata.session = Some(Arc::new(Session::new(sender)));
|
|
|
|
// Subscribe
|
|
let request = r#"{"jsonrpc": "2.0", "method": "eth_subscribe", "params": ["newHeads"], "id": 1}"#;
|
|
let response = r#"{"jsonrpc":"2.0","result":"0x416d77337e24399d","id":1}"#;
|
|
assert_eq!(io.handle_request_sync(request, metadata.clone()), Some(response.to_owned()));
|
|
|
|
// Check notifications
|
|
handler.new_blocks(vec![], vec![], ChainRoute::new(vec![(h1, ChainRouteType::Enacted)]), vec![], vec![], DURATION_ZERO);
|
|
let (res, receiver) = receiver.into_future().wait().unwrap();
|
|
let response = r#"{"jsonrpc":"2.0","method":"eth_subscription","params":{"result":{"author":"0x0000000000000000000000000000000000000000","difficulty":"0x1","extraData":"0x","gasLimit":"0xf4240","gasUsed":"0x0","hash":"0x3457d2fa2e3dd33c78ac681cf542e429becf718859053448748383af67e23218","logsBloom":"0x00000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000","miner":"0x0000000000000000000000000000000000000000","number":"0x1","parentHash":"0x0cd786a2425d16f152c658316c423e6ce1181e15c3295826d7c9904cba9ce303","receiptsRoot":"0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421","sealFields":[],"sha3Uncles":"0x1dcc4de8dec75d7aab85b567b6ccd41ad312451b948a7413f0a142fd40d49347","size":"0x1c9","stateRoot":"0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421","timestamp":"0x0","transactionsRoot":"0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421"},"subscription":"0x416d77337e24399d"}}"#;
|
|
assert_eq!(res, Some(response.into()));
|
|
|
|
// Notify about two blocks
|
|
handler.new_blocks(vec![], vec![], ChainRoute::new(vec![(h2, ChainRouteType::Enacted), (h3, ChainRouteType::Enacted)]), vec![], vec![], DURATION_ZERO);
|
|
|
|
// Receive both
|
|
let (res, receiver) = receiver.into_future().wait().unwrap();
|
|
let response = r#"{"jsonrpc":"2.0","method":"eth_subscription","params":{"result":{"author":"0x0000000000000000000000000000000000000000","difficulty":"0x2","extraData":"0x","gasLimit":"0xf4240","gasUsed":"0x0","hash":"0x44e5ecf454ea99af9d8a8f2ca0daba96964c90de05db7a78f59b84ae9e749706","logsBloom":"0x00000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000","miner":"0x0000000000000000000000000000000000000000","number":"0x2","parentHash":"0x3457d2fa2e3dd33c78ac681cf542e429becf718859053448748383af67e23218","receiptsRoot":"0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421","sealFields":[],"sha3Uncles":"0x1dcc4de8dec75d7aab85b567b6ccd41ad312451b948a7413f0a142fd40d49347","size":"0x1c9","stateRoot":"0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421","timestamp":"0x0","transactionsRoot":"0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421"},"subscription":"0x416d77337e24399d"}}"#;
|
|
assert_eq!(res, Some(response.into()));
|
|
let (res, receiver) = receiver.into_future().wait().unwrap();
|
|
let response = r#"{"jsonrpc":"2.0","method":"eth_subscription","params":{"result":{"author":"0x0000000000000000000000000000000000000000","difficulty":"0x3","extraData":"0x","gasLimit":"0xf4240","gasUsed":"0x0","hash":"0xdf04a98bb0c6fa8441bd429822f65a46d0cb553f6bcef602b973e65c81497f8e","logsBloom":"0x00000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000","miner":"0x0000000000000000000000000000000000000000","number":"0x3","parentHash":"0x44e5ecf454ea99af9d8a8f2ca0daba96964c90de05db7a78f59b84ae9e749706","receiptsRoot":"0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421","sealFields":[],"sha3Uncles":"0x1dcc4de8dec75d7aab85b567b6ccd41ad312451b948a7413f0a142fd40d49347","size":"0x1c9","stateRoot":"0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421","timestamp":"0x0","transactionsRoot":"0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421"},"subscription":"0x416d77337e24399d"}}"#;
|
|
assert_eq!(res, Some(response.into()));
|
|
|
|
// And unsubscribe
|
|
let request = r#"{"jsonrpc": "2.0", "method": "eth_unsubscribe", "params": ["0x416d77337e24399d"], "id": 1}"#;
|
|
let response = r#"{"jsonrpc":"2.0","result":true,"id":1}"#;
|
|
assert_eq!(io.handle_request_sync(request, metadata), Some(response.to_owned()));
|
|
|
|
let (res, _receiver) = receiver.into_future().wait().unwrap();
|
|
assert_eq!(res, None);
|
|
}
|
|
|
|
#[test]
|
|
fn should_subscribe_to_logs() {
|
|
use ethcore::log_entry::{LocalizedLogEntry, LogEntry};
|
|
use ethcore::ids::BlockId;
|
|
use ethcore::client::BlockInfo;
|
|
|
|
// given
|
|
let el = EventLoop::spawn();
|
|
let mut client = TestBlockChainClient::new();
|
|
// Insert some blocks
|
|
client.add_blocks(1, EachBlockWith::Transaction);
|
|
let h1 = client.block_hash_delta_minus(1);
|
|
let block = client.block(BlockId::Hash(h1)).unwrap();
|
|
let tx_hash = block.transactions()[0].hash();
|
|
client.set_logs(vec![
|
|
LocalizedLogEntry {
|
|
entry: LogEntry {
|
|
address: 5.into(),
|
|
topics: vec![1.into(), 2.into(), 0.into(), 0.into()],
|
|
data: vec![],
|
|
},
|
|
block_hash: h1,
|
|
block_number: block.header().number(),
|
|
transaction_hash: tx_hash,
|
|
transaction_index: 0,
|
|
log_index: 0,
|
|
transaction_log_index: 0,
|
|
}
|
|
]);
|
|
|
|
let pubsub = EthPubSubClient::new_test(Arc::new(client), el.remote());
|
|
let handler = pubsub.handler().upgrade().unwrap();
|
|
let pubsub = pubsub.to_delegate();
|
|
|
|
let mut io = MetaIoHandler::default();
|
|
io.extend_with(pubsub);
|
|
|
|
let mut metadata = Metadata::default();
|
|
let (sender, receiver) = futures::sync::mpsc::channel(8);
|
|
metadata.session = Some(Arc::new(Session::new(sender)));
|
|
|
|
// Subscribe
|
|
let request = r#"{"jsonrpc": "2.0", "method": "eth_subscribe", "params": ["logs", {}], "id": 1}"#;
|
|
let response = r#"{"jsonrpc":"2.0","result":"0x416d77337e24399d","id":1}"#;
|
|
assert_eq!(io.handle_request_sync(request, metadata.clone()), Some(response.to_owned()));
|
|
|
|
// Check notifications (enacted)
|
|
handler.new_blocks(vec![], vec![], ChainRoute::new(vec![(h1, ChainRouteType::Enacted)]), vec![], vec![], DURATION_ZERO);
|
|
let (res, receiver) = receiver.into_future().wait().unwrap();
|
|
let response = r#"{"jsonrpc":"2.0","method":"eth_subscription","params":{"result":{"address":"0x0000000000000000000000000000000000000005","blockHash":"0x3457d2fa2e3dd33c78ac681cf542e429becf718859053448748383af67e23218","blockNumber":"0x1","data":"0x","logIndex":"0x0","removed":false,"topics":["0x0000000000000000000000000000000000000000000000000000000000000001","0x0000000000000000000000000000000000000000000000000000000000000002","0x0000000000000000000000000000000000000000000000000000000000000000","0x0000000000000000000000000000000000000000000000000000000000000000"],"transactionHash":""#.to_owned()
|
|
+ &format!("0x{:x}", tx_hash)
|
|
+ r#"","transactionIndex":"0x0","transactionLogIndex":"0x0","type":"mined"},"subscription":"0x416d77337e24399d"}}"#;
|
|
assert_eq!(res, Some(response.into()));
|
|
|
|
// Check notifications (retracted)
|
|
handler.new_blocks(vec![], vec![], ChainRoute::new(vec![(h1, ChainRouteType::Retracted)]), vec![], vec![], DURATION_ZERO);
|
|
let (res, receiver) = receiver.into_future().wait().unwrap();
|
|
let response = r#"{"jsonrpc":"2.0","method":"eth_subscription","params":{"result":{"address":"0x0000000000000000000000000000000000000005","blockHash":"0x3457d2fa2e3dd33c78ac681cf542e429becf718859053448748383af67e23218","blockNumber":"0x1","data":"0x","logIndex":"0x0","removed":true,"topics":["0x0000000000000000000000000000000000000000000000000000000000000001","0x0000000000000000000000000000000000000000000000000000000000000002","0x0000000000000000000000000000000000000000000000000000000000000000","0x0000000000000000000000000000000000000000000000000000000000000000"],"transactionHash":""#.to_owned()
|
|
+ &format!("0x{:x}", tx_hash)
|
|
+ r#"","transactionIndex":"0x0","transactionLogIndex":"0x0","type":"removed"},"subscription":"0x416d77337e24399d"}}"#;
|
|
assert_eq!(res, Some(response.into()));
|
|
|
|
|
|
// And unsubscribe
|
|
let request = r#"{"jsonrpc": "2.0", "method": "eth_unsubscribe", "params": ["0x416d77337e24399d"], "id": 1}"#;
|
|
let response = r#"{"jsonrpc":"2.0","result":true,"id":1}"#;
|
|
assert_eq!(io.handle_request_sync(request, metadata), Some(response.to_owned()));
|
|
|
|
let (res, _receiver) = receiver.into_future().wait().unwrap();
|
|
assert_eq!(res, None);
|
|
}
|
|
|
|
|
|
#[test]
|
|
fn should_subscribe_to_pending_transactions() {
|
|
// given
|
|
let el = EventLoop::spawn();
|
|
let client = TestBlockChainClient::new();
|
|
|
|
let pubsub = EthPubSubClient::new_test(Arc::new(client), el.remote());
|
|
let handler = pubsub.handler().upgrade().unwrap();
|
|
let pubsub = pubsub.to_delegate();
|
|
|
|
let mut io = MetaIoHandler::default();
|
|
io.extend_with(pubsub);
|
|
|
|
let mut metadata = Metadata::default();
|
|
let (sender, receiver) = futures::sync::mpsc::channel(8);
|
|
metadata.session = Some(Arc::new(Session::new(sender)));
|
|
|
|
// Fail if params are provided
|
|
let request = r#"{"jsonrpc": "2.0", "method": "eth_subscribe", "params": ["newPendingTransactions", {}], "id": 1}"#;
|
|
let response = r#"{"jsonrpc":"2.0","error":{"code":-32602,"message":"Couldn't parse parameters: newPendingTransactions","data":"\"Expected no parameters.\""},"id":1}"#;
|
|
assert_eq!(io.handle_request_sync(request, metadata.clone()), Some(response.to_owned()));
|
|
|
|
// Subscribe
|
|
let request = r#"{"jsonrpc": "2.0", "method": "eth_subscribe", "params": ["newPendingTransactions"], "id": 1}"#;
|
|
let response = r#"{"jsonrpc":"2.0","result":"0x416d77337e24399d","id":1}"#;
|
|
assert_eq!(io.handle_request_sync(request, metadata.clone()), Some(response.to_owned()));
|
|
|
|
// Send new transactions
|
|
handler.new_transactions(&[5.into(), 7.into()]);
|
|
|
|
let (res, receiver) = receiver.into_future().wait().unwrap();
|
|
let response = r#"{"jsonrpc":"2.0","method":"eth_subscription","params":{"result":"0x0000000000000000000000000000000000000000000000000000000000000005","subscription":"0x416d77337e24399d"}}"#;
|
|
assert_eq!(res, Some(response.into()));
|
|
|
|
let (res, receiver) = receiver.into_future().wait().unwrap();
|
|
let response = r#"{"jsonrpc":"2.0","method":"eth_subscription","params":{"result":"0x0000000000000000000000000000000000000000000000000000000000000007","subscription":"0x416d77337e24399d"}}"#;
|
|
assert_eq!(res, Some(response.into()));
|
|
|
|
// And unsubscribe
|
|
let request = r#"{"jsonrpc": "2.0", "method": "eth_unsubscribe", "params": ["0x416d77337e24399d"], "id": 1}"#;
|
|
let response = r#"{"jsonrpc":"2.0","result":true,"id":1}"#;
|
|
assert_eq!(io.handle_request_sync(request, metadata), Some(response.to_owned()));
|
|
|
|
let (res, _receiver) = receiver.into_future().wait().unwrap();
|
|
assert_eq!(res, None);
|
|
}
|
|
|
|
#[test]
|
|
fn should_return_unimplemented() {
|
|
// given
|
|
let el = EventLoop::spawn();
|
|
let client = TestBlockChainClient::new();
|
|
let pubsub = EthPubSubClient::new_test(Arc::new(client), el.remote());
|
|
let pubsub = pubsub.to_delegate();
|
|
|
|
let mut io = MetaIoHandler::default();
|
|
io.extend_with(pubsub);
|
|
|
|
let mut metadata = Metadata::default();
|
|
let (sender, _receiver) = futures::sync::mpsc::channel(8);
|
|
metadata.session = Some(Arc::new(Session::new(sender)));
|
|
|
|
// Subscribe
|
|
let response = r#"{"jsonrpc":"2.0","error":{"code":-32000,"message":"This request is not implemented yet. Please create an issue on Github repo."},"id":1}"#;
|
|
let request = r#"{"jsonrpc": "2.0", "method": "eth_subscribe", "params": ["syncing"], "id": 1}"#;
|
|
assert_eq!(io.handle_request_sync(request, metadata.clone()), Some(response.to_owned()));
|
|
}
|