mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2025-01-20 08:31:11 +00:00
3d8bb73f15
* initial validator attesthead rewrite based on proposer rewrite * proceed with fetching committees and tree hashing the canonical head at assigned attester slot * complete filling the properties of attestation data and all associated root hashes * add when to attest todo * finish entire attester client logic * tests with mocks checked in * tests passing in client * stubbed out server implementation * fixed build due to old property * regen mocks with new mockgen version * fixed broken tests * complete bazel build fix * address some review comments * deep proto test * server implementation logic * attestation info tests * completed passing tests, tree hash still blocked by error with nil fields unfortunately * fix todo failure * gazelle rerun and master merge * testing full behavior of attestation info server * finished all required server tests and implementation * break loop * fix tests due to genesis slot updates
141 lines
3.6 KiB
Protocol Buffer
141 lines
3.6 KiB
Protocol Buffer
syntax = "proto3";
|
|
|
|
package ethereum.beacon.rpc.v1;
|
|
|
|
import "proto/beacon/p2p/v1/types.proto";
|
|
import "google/protobuf/empty.proto";
|
|
import "google/protobuf/timestamp.proto";
|
|
|
|
service BeaconService {
|
|
rpc WaitForChainStart(google.protobuf.Empty) returns (stream ChainStartResponse);
|
|
// CanonicalHead can be called on demand to fetch the current, head block of a beacon node.
|
|
rpc CanonicalHead(google.protobuf.Empty) returns (ethereum.beacon.p2p.v1.BeaconBlock);
|
|
// LatestAttestation streams the latest aggregated attestation to connected validator clients.
|
|
rpc LatestAttestation(google.protobuf.Empty) returns (stream ethereum.beacon.p2p.v1.Attestation);
|
|
rpc PendingDeposits(google.protobuf.Empty) returns (PendingDepositsResponse);
|
|
rpc Eth1Data(google.protobuf.Empty) returns (Eth1DataResponse);
|
|
}
|
|
|
|
service AttesterService {
|
|
rpc AttestHead(ethereum.beacon.p2p.v1.Attestation) returns (AttestResponse);
|
|
rpc AttestationInfoAtSlot(AttestationInfoRequest) returns (AttestationInfoResponse);
|
|
}
|
|
|
|
service ProposerService {
|
|
rpc ProposerIndex(ProposerIndexRequest) returns (ProposerIndexResponse);
|
|
rpc ProposeBlock(ethereum.beacon.p2p.v1.BeaconBlock) returns (ProposeResponse);
|
|
rpc ComputeStateRoot(ethereum.beacon.p2p.v1.BeaconBlock) returns (StateRootResponse);
|
|
}
|
|
|
|
service ValidatorService {
|
|
rpc ValidatorIndex(ValidatorIndexRequest) returns (ValidatorIndexResponse);
|
|
rpc ValidatorEpochAssignments(ValidatorEpochAssignmentsRequest) returns (ValidatorEpochAssignmentsResponse);
|
|
rpc ValidatorCommitteeAtSlot(CommitteeRequest) returns (CommitteeResponse);
|
|
}
|
|
|
|
message CommitteeRequest {
|
|
uint64 slot = 1;
|
|
uint64 validator_index = 2;
|
|
}
|
|
|
|
message CommitteeResponse {
|
|
repeated uint64 committee = 1;
|
|
uint64 shard = 2;
|
|
}
|
|
|
|
message AttestationInfoRequest {
|
|
uint64 slot = 1;
|
|
uint64 shard = 2;
|
|
}
|
|
|
|
message AttestationInfoResponse {
|
|
bytes beacon_block_root_hash32 = 1;
|
|
bytes epoch_boundary_root_hash32 = 2;
|
|
uint64 justified_epoch = 3;
|
|
bytes justified_block_root_hash32 = 4;
|
|
ethereum.beacon.p2p.v1.Crosslink latest_crosslink = 5;
|
|
}
|
|
|
|
message CrosslinkCommitteeRequest {
|
|
uint64 slot = 1;
|
|
}
|
|
|
|
message CrosslinkCommitteeResponse {
|
|
repeated uint64 committee = 1;
|
|
uint64 shard = 2;
|
|
}
|
|
|
|
message ChainStartResponse {
|
|
bool started = 1;
|
|
uint64 genesis_time = 2;
|
|
}
|
|
|
|
message ProposeRequest {
|
|
bytes parent_hash = 1;
|
|
uint64 slot_number = 2;
|
|
bytes randao_reveal_hash32 = 3;
|
|
bytes attestation_bitmask = 4;
|
|
repeated uint64 attestation_aggregate_sig = 5;
|
|
google.protobuf.Timestamp timestamp = 6;
|
|
}
|
|
|
|
message ProposeResponse {
|
|
bytes block_hash = 1;
|
|
}
|
|
|
|
message ProposerIndexRequest {
|
|
uint64 slot_number = 1;
|
|
}
|
|
|
|
message ProposerIndexResponse {
|
|
uint64 index = 1;
|
|
}
|
|
|
|
message StateRootResponse {
|
|
bytes state_root = 1;
|
|
}
|
|
|
|
message AttestResponse {
|
|
bytes attestation_hash = 1;
|
|
}
|
|
|
|
enum ValidatorRole {
|
|
UNKNOWN = 0;
|
|
ATTESTER = 1;
|
|
PROPOSER = 2;
|
|
}
|
|
|
|
// Assignment defines a validator's assignment responsibilities.
|
|
message Assignment {
|
|
bytes public_key = 1;
|
|
uint64 shard = 2;
|
|
uint64 attester_slot = 3;
|
|
uint64 proposer_slot = 4;
|
|
}
|
|
|
|
message ValidatorIndexRequest {
|
|
bytes public_key = 1;
|
|
}
|
|
|
|
message ValidatorIndexResponse {
|
|
uint64 index = 1;
|
|
}
|
|
|
|
message ValidatorEpochAssignmentsRequest {
|
|
uint64 epoch_start = 1;
|
|
bytes public_key = 2;
|
|
}
|
|
|
|
message ValidatorEpochAssignmentsResponse {
|
|
Assignment assignment = 2;
|
|
}
|
|
|
|
message PendingDepositsResponse {
|
|
repeated ethereum.beacon.p2p.v1.Deposit pending_deposits = 1;
|
|
}
|
|
|
|
message Eth1DataResponse {
|
|
ethereum.beacon.p2p.v1.Eth1Data eth1_data = 1;
|
|
}
|
|
|