Implement Fee Recipient: CLI flags and Calling Beacon API

cmd/validator/flags/BUILD.bazel

@@ -13,6 +13,7 @@ go_library(
         "//validator:__subpackages__",
     ],
     deps = [
+        "//config/fieldparams:go_default_library",
         "//io/file:go_default_library",
         "@com_github_urfave_cli_v2//:go_default_library",
     ],

cmd/validator/flags/flags.go

@@ -7,6 +7,7 @@ import (
 	"runtime"
 	"time"
 
+	field_params "github.com/prysmaticlabs/prysm/config/fieldparams"
 	"github.com/prysmaticlabs/prysm/io/file"
 	"github.com/urfave/cli/v2"
 )
@@ -322,6 +323,26 @@ var (
 		Usage: "Enables more verbose logging for counting down to duty",
 		Value: false,
 	}
+
+	// ValidatorsProposerConfigDirFlag defines the path or URL to a file with proposer config.
+	ValidatorsProposerConfigDirFlag = &cli.StringFlag{
+		Name:  "validators-proposer-config-dir",
+		Usage: "Set local directory path to proposer config(.json) for per validator mapping to an eth address to receive gas fees when proposing block (i.e. --validators-proposer-config-dir=/path/to/proposer.json). File format found in docs",
+		Value: "",
+	}
+	// ValidatorsProposerConfigFlag defines the path or URL to a file with proposer config.
+	ValidatorsProposerConfigURLFlag = &cli.StringFlag{
+		Name:  "validators-proposer-config-url",
+		Usage: "Set URL to load proposer config (.json) for per validator mapping to an eth address to receive gas fees when proposing block (i.e. --validators-proposer-config-url=https://example.com/api/getConfig). File format found in docs",
+		Value: "",
+	}
+
+	// SuggestedFeeRecipientFlag defines the address of the fee recipient.
+	SuggestedFeeRecipientFlag = &cli.StringFlag{
+		Name:  "suggested-fee-recipient",
+		Usage: "Sets ALL validators' mapping to a suggested an eth address to receive gas fees when proposing a block. Overrides the ProposerConfigFlag(s) if set",
+		Value: field_params.Eth1BurnAddressHex,
+	}
 )
 
 // DefaultValidatorDir returns OS-specific default validator directory.

cmd/validator/main.go

@@ -75,6 +75,9 @@ var appFlags = []cli.Flag{
 	// Consensys' Web3Signer flags
 	flags.Web3SignerURLFlag,
 	flags.Web3SignerPublicValidatorKeysFlag,
+	flags.ValidatorsProposerConfigDirFlag,
+	flags.ValidatorsProposerConfigURLFlag,
+	flags.SuggestedFeeRecipientFlag,
 	////////////////////
 	cmd.DisableMonitoringFlag,
 	cmd.MonitoringHostFlag,

cmd/validator/usage.go

@@ -109,6 +109,9 @@ var appHelpFlagGroups = []flagGroup{
 			flags.EnableDutyCountDown,
 			flags.Web3SignerURLFlag,
 			flags.Web3SignerPublicValidatorKeysFlag,
+			flags.ValidatorsProposerConfigDirFlag,
+			flags.ValidatorsProposerConfigURLFlag,
+			flags.SuggestedFeeRecipientFlag,
 		},
 	},
 	{

config/fieldparams/mainnet.go

@@ -5,21 +5,22 @@ package field_params
 
 const (
 	Preset                          = "mainnet"
-	BlockRootsLength                = 8192          // SLOTS_PER_HISTORICAL_ROOT
-	StateRootsLength                = 8192          // SLOTS_PER_HISTORICAL_ROOT
-	RandaoMixesLength               = 65536         // EPOCHS_PER_HISTORICAL_VECTOR
-	HistoricalRootsLength           = 16777216      // HISTORICAL_ROOTS_LIMIT
-	ValidatorRegistryLimit          = 1099511627776 // VALIDATOR_REGISTRY_LIMIT
-	Eth1DataVotesLength             = 2048          // SLOTS_PER_ETH1_VOTING_PERIOD
-	PreviousEpochAttestationsLength = 4096          // MAX_ATTESTATIONS * SLOTS_PER_EPOCH
-	CurrentEpochAttestationsLength  = 4096          // MAX_ATTESTATIONS * SLOTS_PER_EPOCH
-	SlashingsLength                 = 8192          // EPOCHS_PER_SLASHINGS_VECTOR
-	SyncCommitteeLength             = 512           // SYNC_COMMITTEE_SIZE
-	RootLength                      = 32            // RootLength defines the byte length of a Merkle root.
-	BLSSignatureLength              = 96            // BLSSignatureLength defines the byte length of a BLSSignature.
-	BLSPubkeyLength                 = 48            // BLSPubkeyLength defines the byte length of a BLSSignature.
-	MaxTxsPerPayloadLength          = 1048576       // MaxTxsPerPayloadLength defines the maximum number of transactions that can be included in a payload.
-	MaxBytesPerTxLength             = 1073741824    // MaxBytesPerTxLength defines the maximum number of bytes that can be included in a transaction.
-	FeeRecipientLength              = 20            // FeeRecipientLength defines the byte length of a fee recipient.
-	LogsBloomLength                 = 256           // LogsBloomLength defines the byte length of a logs bloom.
+	BlockRootsLength                = 8192                                         // SLOTS_PER_HISTORICAL_ROOT
+	StateRootsLength                = 8192                                         // SLOTS_PER_HISTORICAL_ROOT
+	RandaoMixesLength               = 65536                                        // EPOCHS_PER_HISTORICAL_VECTOR
+	HistoricalRootsLength           = 16777216                                     // HISTORICAL_ROOTS_LIMIT
+	ValidatorRegistryLimit          = 1099511627776                                // VALIDATOR_REGISTRY_LIMIT
+	Eth1DataVotesLength             = 2048                                         // SLOTS_PER_ETH1_VOTING_PERIOD
+	PreviousEpochAttestationsLength = 4096                                         // MAX_ATTESTATIONS * SLOTS_PER_EPOCH
+	CurrentEpochAttestationsLength  = 4096                                         // MAX_ATTESTATIONS * SLOTS_PER_EPOCH
+	SlashingsLength                 = 8192                                         // EPOCHS_PER_SLASHINGS_VECTOR
+	SyncCommitteeLength             = 512                                          // SYNC_COMMITTEE_SIZE
+	RootLength                      = 32                                           // RootLength defines the byte length of a Merkle root.
+	BLSSignatureLength              = 96                                           // BLSSignatureLength defines the byte length of a BLSSignature.
+	BLSPubkeyLength                 = 48                                           // BLSPubkeyLength defines the byte length of a BLSSignature.
+	MaxTxsPerPayloadLength          = 1048576                                      // MaxTxsPerPayloadLength defines the maximum number of transactions that can be included in a payload.
+	MaxBytesPerTxLength             = 1073741824                                   // MaxBytesPerTxLength defines the maximum number of bytes that can be included in a transaction.
+	FeeRecipientLength              = 20                                           // FeeRecipientLength defines the byte length of a fee recipient.
+	LogsBloomLength                 = 256                                          // LogsBloomLength defines the byte length of a logs bloom.
+	Eth1BurnAddressHex              = "0x0000000000000000000000000000000000000000" // Eth1BurnAddressHex defines the hex encoded address of the eth1.0 burn contract.
 )

config/fieldparams/minimal.go

@@ -5,21 +5,22 @@ package field_params
 
 const (
 	Preset                          = "minimal"
-	BlockRootsLength                = 64            // SLOTS_PER_HISTORICAL_ROOT
-	StateRootsLength                = 64            // SLOTS_PER_HISTORICAL_ROOT
-	RandaoMixesLength               = 64            // EPOCHS_PER_HISTORICAL_VECTOR
-	HistoricalRootsLength           = 16777216      // HISTORICAL_ROOTS_LIMIT
-	ValidatorRegistryLimit          = 1099511627776 // VALIDATOR_REGISTRY_LIMIT
-	Eth1DataVotesLength             = 32            // SLOTS_PER_ETH1_VOTING_PERIOD
-	PreviousEpochAttestationsLength = 1024          // MAX_ATTESTATIONS * SLOTS_PER_EPOCH
-	CurrentEpochAttestationsLength  = 1024          // MAX_ATTESTATIONS * SLOTS_PER_EPOCH
-	SlashingsLength                 = 64            // EPOCHS_PER_SLASHINGS_VECTOR
-	SyncCommitteeLength             = 32            // SYNC_COMMITTEE_SIZE
-	RootLength                      = 32            // RootLength defines the byte length of a Merkle root.
-	BLSSignatureLength              = 96            // BLSSignatureLength defines the byte length of a BLSSignature.
-	BLSPubkeyLength                 = 48            // BLSPubkeyLength defines the byte length of a BLSSignature.
-	MaxTxsPerPayloadLength          = 1048576       // MaxTxsPerPayloadLength defines the maximum number of transactions that can be included in a payload.
-	MaxBytesPerTxLength             = 1073741824    // MaxBytesPerTxLength defines the maximum number of bytes that can be included in a transaction.
-	FeeRecipientLength              = 20            // FeeRecipientLength defines the byte length of a fee recipient.
-	LogsBloomLength                 = 256           // LogsBloomLength defines the byte length of a logs bloom.
+	BlockRootsLength                = 64                                           // SLOTS_PER_HISTORICAL_ROOT
+	StateRootsLength                = 64                                           // SLOTS_PER_HISTORICAL_ROOT
+	RandaoMixesLength               = 64                                           // EPOCHS_PER_HISTORICAL_VECTOR
+	HistoricalRootsLength           = 16777216                                     // HISTORICAL_ROOTS_LIMIT
+	ValidatorRegistryLimit          = 1099511627776                                // VALIDATOR_REGISTRY_LIMIT
+	Eth1DataVotesLength             = 32                                           // SLOTS_PER_ETH1_VOTING_PERIOD
+	PreviousEpochAttestationsLength = 1024                                         // MAX_ATTESTATIONS * SLOTS_PER_EPOCH
+	CurrentEpochAttestationsLength  = 1024                                         // MAX_ATTESTATIONS * SLOTS_PER_EPOCH
+	SlashingsLength                 = 64                                           // EPOCHS_PER_SLASHINGS_VECTOR
+	SyncCommitteeLength             = 32                                           // SYNC_COMMITTEE_SIZE
+	RootLength                      = 32                                           // RootLength defines the byte length of a Merkle root.
+	BLSSignatureLength              = 96                                           // BLSSignatureLength defines the byte length of a BLSSignature.
+	BLSPubkeyLength                 = 48                                           // BLSPubkeyLength defines the byte length of a BLSSignature.
+	MaxTxsPerPayloadLength          = 1048576                                      // MaxTxsPerPayloadLength defines the maximum number of transactions that can be included in a payload.
+	MaxBytesPerTxLength             = 1073741824                                   // MaxBytesPerTxLength defines the maximum number of bytes that can be included in a transaction.
+	FeeRecipientLength              = 20                                           // FeeRecipientLength defines the byte length of a fee recipient.
+	LogsBloomLength                 = 256                                          // LogsBloomLength defines the byte length of a logs bloom.
+	Eth1BurnAddressHex              = "0x0000000000000000000000000000000000000000" // Eth1BurnAddressHex defines the hex encoded address of the eth1.0 burn contract.
 )

config/validator/service/BUILD.bazel

@@ -0,0 +1,8 @@
+load("@prysm//tools/go:def.bzl", "go_library")
+
+go_library(
+    name = "go_default_library",
+    srcs = ["prepare_beacon_proposer_config.go"],
+    importpath = "github.com/prysmaticlabs/prysm/config/validator/service",
+    visibility = ["//visibility:public"],
+)

config/validator/service/prepare_beacon_proposer_config.go

@@ -0,0 +1,10 @@
+package validator_service_config
+
+type PrepareBeaconProposalFileConfig struct {
+	ProposeConfig map[string]*ValidatorProposerOptions `json:"proposer_config"`
+	DefaultConfig *ValidatorProposerOptions            `json:"default_config"`
+}
+
+type ValidatorProposerOptions struct {
+	FeeRecipient string `json:"fee_recipient"`
+}