1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
use std::io;
use hash::H256;
use ser::{Stream, Reader};
use {Payload, MessageResult};
pub const GETHEADERS_MAX_RESPONSE_HEADERS: usize = 2_000;
#[derive(Debug, PartialEq)]
pub struct GetHeaders {
pub version: u32,
pub block_locator_hashes: Vec<H256>,
pub hash_stop: H256,
}
impl GetHeaders {
pub fn with_block_locator_hashes(block_locator_hashes: Vec<H256>) -> Self {
GetHeaders {
version: 0,
block_locator_hashes: block_locator_hashes,
hash_stop: H256::default(),
}
}
}
impl Payload for GetHeaders {
fn version() -> u32 {
0
}
fn command() -> &'static str {
"getheaders"
}
fn deserialize_payload<T>(reader: &mut Reader<T>, _version: u32) -> MessageResult<Self> where T: io::Read {
let get_blocks = GetHeaders {
version: try!(reader.read()),
block_locator_hashes: try!(reader.read_list_max(2000)),
hash_stop: try!(reader.read()),
};
Ok(get_blocks)
}
fn serialize_payload(&self, stream: &mut Stream, _version: u32) -> MessageResult<()> {
stream
.append(&self.version)
.append_list(&self.block_locator_hashes)
.append(&self.hash_stop);
Ok(())
}
}