cerc-io/lighthouse
16
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Modify RPC duties endpoint

Browse Source
This commit is contained in:
Paul Hauner 2019-08-30 01:51:18 +10:00
parent 8060cd8f5c
commit 31bbb0f573
No known key found for this signature in database
GPG Key ID: 303E4494BB28068C
1 changed files with 3 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
beacon_node/rpc/src/validator.rs
View File

@ -28,18 +28,9 @@ impl<T: BeaconChainTypes> ValidatorService for ValidatorServiceInstance<T> {
let validators = req.get_validators(); let validators = req.get_validators();
trace!(self.log, "RPC request"; "endpoint" => "GetValidatorDuties", "epoch" => req.get_epoch()); trace!(self.log, "RPC request"; "endpoint" => "GetValidatorDuties", "epoch" => req.get_epoch());
let slot = if let Ok(slot) = self.chain.slot() { let epoch = Epoch::from(req.get_epoch());
slot let slot = epoch.start_slot(T::EthSpec::slots_per_epoch());
} else {
let log_clone = self.log.clone();
let f = sink
.fail(RpcStatus::new(
RpcStatusCode::FailedPrecondition,
Some("No slot for chain".to_string()),
))
.map_err(move |e| warn!(log_clone, "failed to reply {:?}: {:?}", req, e));
return ctx.spawn(f);
};
let mut state = if let Ok(state) = self.chain.state_at_slot(slot) { let mut state = if let Ok(state) = self.chain.state_at_slot(slot) {
state.as_ref().clone() state.as_ref().clone()
} else { } else {
@ -55,7 +46,6 @@ impl<T: BeaconChainTypes> ValidatorService for ValidatorServiceInstance<T> {
let _ = state.build_all_caches(&self.chain.spec); let _ = state.build_all_caches(&self.chain.spec);
let epoch = Epoch::from(req.get_epoch());
let mut resp = GetDutiesResponse::new(); let mut resp = GetDutiesResponse::new();
let resp_validators = resp.mut_active_validators(); let resp_validators = resp.mut_active_validators();