gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-07-05 13:54:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Implement BeaconBlockHeaders RPC method

Browse Source
This commit is contained in:
Age Manning
2019-03-21 11:05:26 +11:00
parent 766a79adfa
commit 56cd77ead8
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
beacon_node/eth2-libp2p/src/rpc/protocol.rs
View File

@@ -90,6 +90,11 @@ fn decode(packet: Vec<u8>) -> Result<RPCEvent, DecodeError> {
BeaconBlockRootsRequest::ssz_decode(&packet, index)?; BeaconBlockRootsRequest::ssz_decode(&packet, index)?;
RPCRequest::BeaconBlockRoots(block_roots_request) RPCRequest::BeaconBlockRoots(block_roots_request)
} }
RPCMethod::BeaconBlockHeaders => {
let (block_headers_request, _index) =
BeaconBlockHeadersRequest::ssz_decode(&packet, index)?;
RPCRequest::BeaconBlockHeaders(block_headers_request)
}
RPCMethod::Unknown | _ => return Err(DecodeError::UnknownRPCMethod), RPCMethod::Unknown | _ => return Err(DecodeError::UnknownRPCMethod),
}; };
@@ -111,6 +116,10 @@ fn decode(packet: Vec<u8>) -> Result<RPCEvent, DecodeError> {
let (body, _index) = BeaconBlockRootsResponse::ssz_decode(&packet, index)?; let (body, _index) = BeaconBlockRootsResponse::ssz_decode(&packet, index)?;
RPCResponse::BeaconBlockRoots(body) RPCResponse::BeaconBlockRoots(body)
} }
RPCMethod::BeaconBlockHeaders => {
let (body, _index) = BeaconBlockHeadersResponse::ssz_decode(&packet, index)?;
RPCResponse::BeaconBlockHeaders(body)
}
RPCMethod::Unknown | _ => return Err(DecodeError::UnknownRPCMethod), RPCMethod::Unknown | _ => return Err(DecodeError::UnknownRPCMethod),
}; };
Ok(RPCEvent::Response { Ok(RPCEvent::Response {