Merge changes from master branch

.golangci.yml

@@ -151,6 +151,7 @@ linters:
     - maligned
     - musttag
     - nosnakecase
+    - perfsprint
     - scopelint
     - structcheck
     - varcheck

CHANGELOG.md

@@ -1,4 +1,17 @@
-dev:
+0.21.0:
+  - use v3 of the endpoint to obtain proposals
+  - add bounds checking for ValidatorState
+
+0.20.0:
+  - allow delayed start of client, enabling the service even if the underlying beacon node is not ready
+  - add IsActive() and IsSynced() methods to understand the status of the service
+  - update multi clients to be aware of delayed start, only using clients that are synced
+  - use standard errors for common function issues
+  - add ProposerIndex() to VersionedSignedProposal
+  - add name to multi clients to differentiate multiple instances
+  - fully parse provided client URLs, allowing pass through of username, password, etc.
+
+0.19.10:
   - add proposer_slashing and attester_slashing events
   - add bls_to_execution_change event
 

api/proposalopts.go

@@ -1,4 +1,4 @@
-// Copyright © 2023 Attestant Limited.
+// Copyright © 2023, 2024 Attestant Limited.
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
 // You may obtain a copy of the License at
@@ -23,9 +23,13 @@ type ProposalOpts struct {
 	Slot phase0.Slot
 	// RandaoReveal is the RANDAO reveal for the proposal.
 	RandaoReveal phase0.BLSSignature
-	// Graffit is the graffiti to be included in the beacon block body.
+	// Graffiti is the graffiti to be included in the beacon block body.
 	Graffiti [32]byte
 	// SkipRandaoVerification is true if we do not want the server to verify our RANDAO reveal.
 	// If this is set then the RANDAO reveal should be passed as the point at infinity (0xc0…00)
 	SkipRandaoVerification bool
+	// BuilderBoostFactor is the relative weight of the builder payload versus a locally-produced
+	// payload, as per https://ethereum.github.io/beacon-APIs/#/Validator/produceBlockV3
+	// This is optional; if not supplied it will use the default value of 100.
+	BuilderBoostFactor *uint64
 }

api/submitblindedproposalopts.go

@@ -0,0 +1,27 @@
+// Copyright © 2024 Attestant Limited.
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package api
+
+import v2 "github.com/attestantio/go-eth2-client/api/v2"
+
+// SubmitBlindedProposalOpts are the options for submitting proposals.
+type SubmitBlindedProposalOpts struct {
+	Common CommonOpts
+
+	// Proposal is the proposal to submit.
+	Proposal *VersionedSignedBlindedProposal
+
+	// BroadcastValidation is the validation required of the consensus node before broadcasting the proposal.
+	BroadcastValidation *v2.BroadcastValidation
+}

api/submitproposalopts.go

@@ -0,0 +1,27 @@
+// Copyright © 2024 Attestant Limited.
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package api
+
+import v2 "github.com/attestantio/go-eth2-client/api/v2"
+
+// SubmitProposalOpts are the options for submitting proposals.
+type SubmitProposalOpts struct {
+	Common CommonOpts
+
+	// Proposal is the proposal to submit.
+	Proposal *VersionedSignedProposal
+
+	// BroadcastValidation is the validation required of the consensus node before broadcasting the proposal.
+	BroadcastValidation *v2.BroadcastValidation
+}

api/v1/bellatrix/blindedbeaconblockbody_json.go

@@ -1,4 +1,4 @@
-// Copyright © 2022 Attestant Limited.
+// Copyright © 2022, 2024 Attestant Limited.
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
 // You may obtain a copy of the License at
@@ -95,23 +95,48 @@ func (b *BlindedBeaconBlockBody) unpack(data *blindedBeaconBlockBodyJSON) error
 	if data.ProposerSlashings == nil {
 		return errors.New("proposer slashings missing")
 	}
+	for i := range data.ProposerSlashings {
+		if data.ProposerSlashings[i] == nil {
+			return fmt.Errorf("proposer slashings entry %d missing", i)
+		}
+	}
 	b.ProposerSlashings = data.ProposerSlashings
 	if data.AttesterSlashings == nil {
 		return errors.New("attester slashings missing")
 	}
+	for i := range data.AttesterSlashings {
+		if data.AttesterSlashings[i] == nil {
+			return fmt.Errorf("attester slashings entry %d missing", i)
+		}
+	}
 	b.AttesterSlashings = data.AttesterSlashings
 	if data.Attestations == nil {
 		return errors.New("attestations missing")
 	}
+	for i := range data.Attestations {
+		if data.Attestations[i] == nil {
+			return fmt.Errorf("attestations entry %d missing", i)
+		}
+	}
 	b.Attestations = data.Attestations
 	if data.Deposits == nil {
 		return errors.New("deposits missing")
 	}
+	for i := range data.Deposits {
+		if data.Deposits[i] == nil {
+			return fmt.Errorf("deposits entry %d missing", i)
+		}
+	}
 	b.Deposits = data.Deposits
 	if data.VoluntaryExits == nil {
 		return errors.New("voluntary exits missing")
 	}
 	b.VoluntaryExits = data.VoluntaryExits
+	for i := range data.VoluntaryExits {
+		if data.VoluntaryExits[i] == nil {
+			return fmt.Errorf("voluntary exits entry %d missing", i)
+		}
+	}
 	if data.SyncAggregate == nil {
 		return errors.New("sync aggregate missing")
 	}

api/v1/capella/blindedbeaconblockbody_json.go

@@ -1,4 +1,4 @@
-// Copyright © 2022 Attestant Limited.
+// Copyright © 2022, 2024 Attestant Limited.
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
 // You may obtain a copy of the License at
@@ -97,22 +97,47 @@ func (b *BlindedBeaconBlockBody) unpack(data *blindedBeaconBlockBodyJSON) error
 	if data.ProposerSlashings == nil {
 		return errors.New("proposer slashings missing")
 	}
+	for i := range data.ProposerSlashings {
+		if data.ProposerSlashings[i] == nil {
+			return fmt.Errorf("proposer slashings entry %d missing", i)
+		}
+	}
 	b.ProposerSlashings = data.ProposerSlashings
 	if data.AttesterSlashings == nil {
 		return errors.New("attester slashings missing")
 	}
+	for i := range data.AttesterSlashings {
+		if data.AttesterSlashings[i] == nil {
+			return fmt.Errorf("attester slashings entry %d missing", i)
+		}
+	}
 	b.AttesterSlashings = data.AttesterSlashings
 	if data.Attestations == nil {
 		return errors.New("attestations missing")
 	}
+	for i := range data.Attestations {
+		if data.Attestations[i] == nil {
+			return fmt.Errorf("attestations entry %d missing", i)
+		}
+	}
 	b.Attestations = data.Attestations
 	if data.Deposits == nil {
 		return errors.New("deposits missing")
 	}
+	for i := range data.Deposits {
+		if data.Deposits[i] == nil {
+			return fmt.Errorf("deposits entry %d missing", i)
+		}
+	}
 	b.Deposits = data.Deposits
 	if data.VoluntaryExits == nil {
 		return errors.New("voluntary exits missing")
 	}
+	for i := range data.VoluntaryExits {
+		if data.VoluntaryExits[i] == nil {
+			return fmt.Errorf("voluntary exits entry %d missing", i)
+		}
+	}
 	b.VoluntaryExits = data.VoluntaryExits
 	if data.SyncAggregate == nil {
 		return errors.New("sync aggregate missing")
@@ -125,6 +150,11 @@ func (b *BlindedBeaconBlockBody) unpack(data *blindedBeaconBlockBodyJSON) error
 	if data.BLSToExecutionChanges == nil {
 		b.BLSToExecutionChanges = make([]*capella.SignedBLSToExecutionChange, 0)
 	} else {
+		for i := range data.BLSToExecutionChanges {
+			if data.BLSToExecutionChanges[i] == nil {
+				return fmt.Errorf("bls to execution changes entry %d missing", i)
+			}
+		}
 		b.BLSToExecutionChanges = data.BLSToExecutionChanges
 	}