first local chain test

This commit is contained in:
Nikolay Volf 2016-02-04 22:03:14 +03:00
parent c0776b75b6
commit ab131b134b
3 changed files with 27 additions and 9 deletions

View File

@ -1016,4 +1016,22 @@ impl ChainSync {
#[cfg(test)] #[cfg(test)]
mod tests { mod tests {
use tests::helpers::*;
use super::*;
use util::*;
#[test]
fn return_receipts() {
let mut client = TestBlockChainClient::new();
let mut queue:VecDeque<TestPacket> = VecDeque::new();
let mut io = TestIo::new(& mut client, & mut queue, None);
let sync = ChainSync::new();
let data = vec![0xc0];
let rlp = UntrustedRlp::new(&data);
let result = sync.return_receipts(& mut io, &rlp);
assert!(result.is_ok());
}
} }

View File

@ -5,7 +5,7 @@ use chain::{SyncState};
use super::helpers::*; use super::helpers::*;
#[test] #[test]
fn chain_two_peers() { fn two_peers() {
::env_logger::init().ok(); ::env_logger::init().ok();
let mut net = TestNet::new(3); let mut net = TestNet::new(3);
net.peer_mut(1).chain.add_blocks(1000, false); net.peer_mut(1).chain.add_blocks(1000, false);
@ -16,7 +16,7 @@ fn chain_two_peers() {
} }
#[test] #[test]
fn chain_status_after_sync() { fn status_after_sync() {
::env_logger::init().ok(); ::env_logger::init().ok();
let mut net = TestNet::new(3); let mut net = TestNet::new(3);
net.peer_mut(1).chain.add_blocks(1000, false); net.peer_mut(1).chain.add_blocks(1000, false);
@ -27,7 +27,7 @@ fn chain_status_after_sync() {
} }
#[test] #[test]
fn chain_takes_few_steps() { fn takes_few_steps() {
let mut net = TestNet::new(3); let mut net = TestNet::new(3);
net.peer_mut(1).chain.add_blocks(100, false); net.peer_mut(1).chain.add_blocks(100, false);
net.peer_mut(2).chain.add_blocks(100, false); net.peer_mut(2).chain.add_blocks(100, false);
@ -36,7 +36,7 @@ fn chain_takes_few_steps() {
} }
#[test] #[test]
fn chain_empty_blocks() { fn empty_blocks() {
::env_logger::init().ok(); ::env_logger::init().ok();
let mut net = TestNet::new(3); let mut net = TestNet::new(3);
for n in 0..200 { for n in 0..200 {
@ -49,7 +49,7 @@ fn chain_empty_blocks() {
} }
#[test] #[test]
fn chain_forked() { fn forked() {
::env_logger::init().ok(); ::env_logger::init().ok();
let mut net = TestNet::new(3); let mut net = TestNet::new(3);
net.peer_mut(0).chain.add_blocks(300, false); net.peer_mut(0).chain.add_blocks(300, false);
@ -69,7 +69,7 @@ fn chain_forked() {
} }
#[test] #[test]
fn chain_restart() { fn restart() {
let mut net = TestNet::new(3); let mut net = TestNet::new(3);
net.peer_mut(1).chain.add_blocks(1000, false); net.peer_mut(1).chain.add_blocks(1000, false);
net.peer_mut(2).chain.add_blocks(1000, false); net.peer_mut(2).chain.add_blocks(1000, false);
@ -85,7 +85,7 @@ fn chain_restart() {
} }
#[test] #[test]
fn chain_status_empty() { fn status_empty() {
let net = TestNet::new(2); let net = TestNet::new(2);
assert_eq!(net.peer(0).sync.status().state, SyncState::NotSynced); assert_eq!(net.peer(0).sync.status().state, SyncState::NotSynced);
} }

View File

@ -15,7 +15,7 @@ pub struct TestBlockChainClient {
} }
impl TestBlockChainClient { impl TestBlockChainClient {
fn new() -> TestBlockChainClient { pub fn new() -> TestBlockChainClient {
let mut client = TestBlockChainClient { let mut client = TestBlockChainClient {
blocks: RwLock::new(HashMap::new()), blocks: RwLock::new(HashMap::new()),
@ -196,7 +196,7 @@ pub struct TestIo<'p> {
} }
impl<'p> TestIo<'p> { impl<'p> TestIo<'p> {
fn new(chain: &'p mut TestBlockChainClient, queue: &'p mut VecDeque<TestPacket>, sender: Option<PeerId>) -> TestIo<'p> { pub fn new(chain: &'p mut TestBlockChainClient, queue: &'p mut VecDeque<TestPacket>, sender: Option<PeerId>) -> TestIo<'p> {
TestIo { TestIo {
chain: chain, chain: chain,
queue: queue, queue: queue,