Implement beacon committee selections (#13503)

* implement beacon committee selections * fix build * fix lint * fix lint * Update beacon-chain/rpc/eth/shared/structs.go Co-authored-by: Radosław Kapka <[email protected]> * Update validator/client/beacon-api/beacon_committee_selections.go Co-authored-by: Radosław Kapka <[email protected]> * Update validator/client/beacon-api/beacon_committee_selections.go Co-authored-by: Radosław Kapka <[email protected]> * Update validator/client/beacon-api/beacon_committee_selections.go Co-authored-by: Radosław Kapka <[email protected]> * move beacon committee selection structs to validator module * fix bazel build files * add support for POST and GET endpoints for get state validators query * add a handler to return error from beacon node * move beacon committee selection to validator top-level module * fix bazel * re-arrange fields to fix lint * fix TestServer_InitializeRoutes * fix build and lint * fix build and lint * fix TestSubmitAggregateAndProof_Distributed --------- Co-authored-by: Radosław Kapka <[email protected]>
prysmaticlabs · Feb 5, 2024 · 55a29a4 · 55a29a4
1 parent e2e7e84
commit 55a29a4
Show file tree

Hide file tree

Showing 32 changed files with 925 additions and 108 deletions.
diff --git a/beacon-chain/rpc/eth/validator/handlers.go b/beacon-chain/rpc/eth/validator/handlers.go
@@ -1086,6 +1086,12 @@ func (s *Server) GetLiveness(w http.ResponseWriter, r *http.Request) {
 	httputil.WriteJson(w, resp)
 }
 
+// BeaconCommitteeSelections responds with appropriate message and status code according the spec:
+// https://ethereum.github.io/beacon-APIs/#/Validator/submitBeaconCommitteeSelections.
+func (s *Server) BeaconCommitteeSelections(w http.ResponseWriter, _ *http.Request) {
+	httputil.HandleError(w, "Endpoint not implemented", 501)
+}
+
 // attestationDependentRoot is get_block_root_at_slot(state, compute_start_slot_at_epoch(epoch - 1) - 1)
 // or the genesis block root in the case of underflow.
 func attestationDependentRoot(s state.BeaconState, epoch primitives.Epoch) ([]byte, error) {

diff --git a/beacon-chain/rpc/service.go b/beacon-chain/rpc/service.go
@@ -228,6 +228,7 @@ func (s *Service) initializeValidatorServerRoutes(validatorServer *validator.Ser
 	s.cfg.Router.HandleFunc("/eth/v2/validator/blocks/{slot}", validatorServer.ProduceBlockV2).Methods(http.MethodGet)
 	s.cfg.Router.HandleFunc("/eth/v1/validator/blinded_blocks/{slot}", validatorServer.ProduceBlindedBlock).Methods(http.MethodGet)
 	s.cfg.Router.HandleFunc("/eth/v3/validator/blocks/{slot}", validatorServer.ProduceBlockV3).Methods(http.MethodGet)
+	s.cfg.Router.HandleFunc("/eth/v1/validator/beacon_committee_selections", validatorServer.BeaconCommitteeSelections).Methods(http.MethodPost)
 }
 
 func (s *Service) initializeNodeServerRoutes(nodeServer *node.Server) {

diff --git a/beacon-chain/rpc/service_test.go b/beacon-chain/rpc/service_test.go
@@ -152,8 +152,8 @@ func TestServer_InitializeRoutes(t *testing.T) {
 		"/eth/v1/validator/aggregate_and_proofs":           {http.MethodPost},
 		"/eth/v1/validator/beacon_committee_subscriptions": {http.MethodPost},
 		"/eth/v1/validator/sync_committee_subscriptions":   {http.MethodPost},
-		//"/eth/v1/validator/beacon_committee_selections":   {http.MethodPost}, // not implemented
-		"/eth/v1/validator/sync_committee_contribution": {http.MethodGet},
+		"/eth/v1/validator/beacon_committee_selections":    {http.MethodPost},
+		"/eth/v1/validator/sync_committee_contribution":    {http.MethodGet},
 		//"/eth/v1/validator/sync_committee_selections":  {http.MethodPost}, // not implemented
 		"/eth/v1/validator/contribution_and_proofs": {http.MethodPost},
 		"/eth/v1/validator/prepare_beacon_proposer": {http.MethodPost},

diff --git a/cmd/validator/flags/flags.go b/cmd/validator/flags/flags.go
@@ -377,6 +377,13 @@ var (
 		Usage: "Sets the maximum size for one batch of validator registrations. Use a non-positive value to disable batching.",
 		Value: 0,
 	}
+
+	// EnableDistributed enables the usage of prysm validator client in a Distributed Validator Cluster.
+	EnableDistributed = &cli.BoolFlag{
+		Name:  "distributed",
+		Usage: "To enable the use of prysm validator client in Distributed Validator Cluster",
+		Value: false,
+	}
 )
 
 // DefaultValidatorDir returns OS-specific default validator directory.

diff --git a/cmd/validator/main.go b/cmd/validator/main.go
@@ -74,6 +74,7 @@ var appFlags = []cli.Flag{
 	flags.WalletDirFlag,
 	flags.EnableWebFlag,
 	flags.GraffitiFileFlag,
+	flags.EnableDistributed,
 	// Consensys' Web3Signer flags
 	flags.Web3SignerURLFlag,
 	flags.Web3SignerPublicValidatorKeysFlag,

diff --git a/cmd/validator/usage.go b/cmd/validator/usage.go
@@ -122,6 +122,7 @@ var appHelpFlagGroups = []flagGroup{
 			flags.EnableBuilderFlag,
 			flags.BuilderGasLimitFlag,
 			flags.ValidatorsRegistrationBatchSizeFlag,
+			flags.EnableDistributed,
 		},
 	},
 	{

diff --git a/crypto/bls/common/mock/interface_mock.go b/crypto/bls/common/mock/interface_mock.go