Gloas support (with dynamic-ssz)

.github/workflows/http-tests.yml

@@ -0,0 +1,35 @@
+name: http-tests
+
+on:
+  pull_request:
+  workflow_dispatch:
+
+jobs:
+  test:
+    runs-on: ubuntu-24.04
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v4
+
+      - name: Setup Go
+        uses: actions/setup-go@v5
+        with:
+          go-version: '1.25.2'
+
+      - name: Validate required variables
+        run: |
+          if [ -z "${{ vars.HTTP_ADDRESS }}" ]; then
+            echo "Error: HTTP_ADDRESS variable is not set in repository variables"
+            exit 1
+          fi
+          if [ -z "${{ vars.HTTP_TEST_CONCURRENCY }}" ]; then
+            echo "Error: HTTP_TEST_CONCURRENCY variable is not set in repository variables"
+            exit 1
+          fi
+
+      - name: Run HTTP tests
+        env:
+          HTTP_ADDRESS: ${{ vars.HTTP_ADDRESS }}
+          HTTP_TEST_CONCURRENCY: ${{ vars.HTTP_TEST_CONCURRENCY }}
+          HTTP_BEARER_TOKEN: ${{ secrets.HTTP_BEARER_TOKEN }}
+        run: go test -v -timeout=10m ./http/...

.golangci.yml

@@ -112,6 +112,8 @@ linters:
           disabled: true
         - name: package-directory-mismatch
           disabled: true
+        - name: package-naming
+          disabled: true
         - name: var-naming
           disabled: true
         # Configure specific rules

CHANGELOG.md

@@ -1,3 +1,7 @@
+0.28.1:
+  - update to HTTP tests
+  - add beacon committee selections endpoint for distributed validators
+
 0.28.0:
   - update dependency for go-bitfield to get from offchain instead of prysmatic org
 

api/beaconcommitteeselectionsopts.go

@@ -0,0 +1,24 @@
+// Copyright © 2025 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 apiv1 "github.com/attestantio/go-eth2-client/api/v1"
+
+// BeaconCommitteeSelectionsOpts are the options for obtaining beacon committee selections.
+type BeaconCommitteeSelectionsOpts struct {
+	Common CommonOpts
+
+	// Beacon Committee Selections are the selections which the DV should resolve.
+	Selections []*apiv1.BeaconCommitteeSelection
+}

api/blobsidecars.go

@@ -15,33 +15,50 @@ package api
 
 import (
 	"github.com/attestantio/go-eth2-client/spec/deneb"
-	ssz "github.com/ferranbt/fastssz"
+	dynssz "github.com/pk910/dynamic-ssz"
 )
 
 // BlobSidecars is an API construct to allow decoding an array of blob sidecars.
 type BlobSidecars struct {
-	Sidecars []*deneb.BlobSidecar `ssz-max:"72"`
+	Sidecars []*deneb.BlobSidecar
 }
 
+// blobSidecarsSSZ is the SSZ wrapper for the BlobSidecars object.
+type blobSidecarsSSZ = dynssz.TypeWrapper[struct {
+	Sidecars []*deneb.BlobSidecar `ssz-max:"72"`
+}, []*deneb.BlobSidecar]
+
 // UnmarshalSSZ ssz unmarshals the BlobSidecars object.
-// This is a hand-crafted function, as automatic generation does not support immediate arrays.
 func (b *BlobSidecars) UnmarshalSSZ(buf []byte) error {
-	num, err := ssz.DivideInt2(len(buf), 131928, 72)
-	if err != nil {
+	blobs := blobSidecarsSSZ{}
+	if err := dynssz.GetGlobalDynSsz().UnmarshalSSZ(&blobs, buf); err != nil {
 		return err
 	}
 
-	b.Sidecars = make([]*deneb.BlobSidecar, num)
-	for ii := range num {
-		if b.Sidecars[ii] == nil {
-			b.Sidecars[ii] = new(deneb.BlobSidecar)
-		}
-
-		err = b.Sidecars[ii].UnmarshalSSZ(buf[ii*131928 : (ii+1)*131928])
-		if err != nil {
-			return err
-		}
-	}
+	b.Sidecars = blobs.Data
 
 	return nil
 }
+
+// MarshalSSZ ssz marshals the BlobSidecars object.
+func (b *BlobSidecars) MarshalSSZ() ([]byte, error) {
+	return dynssz.GetGlobalDynSsz().MarshalSSZ(&blobSidecarsSSZ{
+		Data: b.Sidecars,
+	})
+}
+
+// SizeSSZ returns the size of the BlobSidecars object.
+func (b *BlobSidecars) SizeSSZ() int {
+	size, _ := dynssz.GetGlobalDynSsz().SizeSSZ(&blobSidecarsSSZ{
+		Data: b.Sidecars,
+	})
+
+	return size
+}
+
+// HashTreeRoot ssz hashes the BlobSidecars object.
+func (b *BlobSidecars) HashTreeRoot() ([32]byte, error) {
+	return dynssz.GetGlobalDynSsz().HashTreeRoot(&blobSidecarsSSZ{
+		Data: b.Sidecars,
+	})
+}

api/generate.go

@@ -13,8 +13,5 @@
 
 package api
 
-//nolint:revive
-// Need to `go install github.com/ferranbt/fastssz/sszgen@latest` for this to work.
-//go:generate rm -f versionedblindedbeaconblock_ssz.go versionedsignedblindedbeaconblock_ssz.go versionedsignedvalidatorregistration_ssz.go
-//go:generate sszgen -suffix=ssz -path . -include ../spec,../spec/phase0,../spec/altair,../spec/bellatrix,../spec/capella,../spec/deneb,v1,v1/bellatrix,v1/capella,v1/deneb -exclude-objs DataVersion -objs VersionedBlindedBeaconBlock,VersionedSignedBlindedBeaconBlock,VersionedSignedValidatorRegistration
-//go:generate goimports -w versionedblindedbeaconblock_ssz.go versionedsignedblindedbeaconblock_ssz.go versionedsignedvalidatorregistration_ssz.go
+//go:generate rm -f *_ssz.go
+//go:generate go tool dynssz-gen -config generate.yaml

api/generate.yaml

@@ -0,0 +1,11 @@
+package: .
+legacy: true
+without-dynamic-expressions: true
+
+types:
+  - name: VersionedBlindedBeaconBlock
+    output: versionedblindedbeaconblock_ssz.go
+  - name: VersionedSignedBlindedBeaconBlock
+    output: versionedsignedblindedbeaconblock_ssz.go
+  - name: VersionedSignedValidatorRegistration
+    output: versionedsignedvalidatorregistration_ssz.go

api/signedexecutionpayloadenvelopeopts.go

@@ -0,0 +1,22 @@
+// Copyright © 2025 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
+
+// SignedExecutionPayloadEnvelopeOpts are the options for obtaining signed execution payload envelopes.
+type SignedExecutionPayloadEnvelopeOpts struct {
+	Common CommonOpts
+
+	// Block is the ID of the block which the data is obtained.
+	Block string
+}

api/v1/attesterduty_test.go

@@ -18,8 +18,8 @@ import (
 	"testing"
 
 	api "github.com/attestantio/go-eth2-client/api/v1"
-	require "github.com/stretchr/testify/require"
 	"github.com/stretchr/testify/assert"
+	require "github.com/stretchr/testify/require"
 )
 
 func TestAttesterDutyJSON(t *testing.T) {

api/v1/beaconblockheader_test.go

@@ -18,8 +18,8 @@ import (
 	"testing"
 
 	api "github.com/attestantio/go-eth2-client/api/v1"
-	require "github.com/stretchr/testify/require"
 	"github.com/stretchr/testify/assert"
+	require "github.com/stretchr/testify/require"
 )
 
 func TestBeaconBlockHeaderJSON(t *testing.T) {

api/v1/beaconcommittee_test.go

@@ -18,8 +18,8 @@ import (
 	"testing"
 
 	api "github.com/attestantio/go-eth2-client/api/v1"
-	require "github.com/stretchr/testify/require"
 	"github.com/stretchr/testify/assert"
+	require "github.com/stretchr/testify/require"
 )
 
 func TestBeaconCommitteeJSON(t *testing.T) {

api/v1/beaconcommitteeselection.go

@@ -0,0 +1,100 @@
+// Copyright © 2025 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 v1
+
+import (
+	"encoding/hex"
+	"encoding/json"
+	"fmt"
+	"strconv"
+	"strings"
+
+	"github.com/attestantio/go-eth2-client/spec/phase0"
+	"github.com/pkg/errors"
+)
+
+// BeaconCommitteeSelection is the data required for a beacon committee selection.
+type BeaconCommitteeSelection struct {
+	// ValidatorIndex is the index of the validator making the selection request.
+	ValidatorIndex phase0.ValidatorIndex
+	// Slot is the slot for which the validator is attesting.
+	Slot phase0.Slot
+	// SelectionProof is the proof of the validator being selected for beacon committee aggregation.
+	SelectionProof phase0.BLSSignature
+}
+
+// beaconCommitteeSelectionJSON is the spec representation of the struct.
+type beaconCommitteeSelectionJSON struct {
+	ValidatorIndex string `json:"validator_index"`
+	Slot           string `json:"slot"`
+	SelectionProof string `json:"selection_proof"`
+}
+
+// MarshalJSON implements json.Marshaler.
+func (b *BeaconCommitteeSelection) MarshalJSON() ([]byte, error) {
+	return json.Marshal(&beaconCommitteeSelectionJSON{
+		ValidatorIndex: fmt.Sprintf("%d", b.ValidatorIndex),
+		Slot:           fmt.Sprintf("%d", b.Slot),
+		SelectionProof: fmt.Sprintf("%#x", b.SelectionProof),
+	})
+}
+
+// UnmarshalJSON implements json.Unmarshaler.
+func (b *BeaconCommitteeSelection) UnmarshalJSON(input []byte) error {
+	var err error
+
+	var beaconCommitteeSelectionJSON beaconCommitteeSelectionJSON
+	if err = json.Unmarshal(input, &beaconCommitteeSelectionJSON); err != nil {
+		return errors.Wrap(err, "invalid JSON")
+	}
+	if beaconCommitteeSelectionJSON.ValidatorIndex == "" {
+		return errors.New("validator index missing")
+	}
+	validatorIndex, err := strconv.ParseUint(beaconCommitteeSelectionJSON.ValidatorIndex, 10, 64)
+	if err != nil {
+		return errors.Wrap(err, "invalid value for validator index")
+	}
+	b.ValidatorIndex = phase0.ValidatorIndex(validatorIndex)
+	if beaconCommitteeSelectionJSON.Slot == "" {
+		return errors.New("slot missing")
+	}
+	slot, err := strconv.ParseUint(beaconCommitteeSelectionJSON.Slot, 10, 64)
+	if err != nil {
+		return errors.Wrap(err, "invalid value for slot")
+	}
+	b.Slot = phase0.Slot(slot)
+	if beaconCommitteeSelectionJSON.SelectionProof == "" {
+		return errors.New("selection proof missing")
+	}
+	selectionProof, err := hex.DecodeString(strings.TrimPrefix(beaconCommitteeSelectionJSON.SelectionProof, "0x"))
+	if err != nil {
+		return errors.Wrap(err, "invalid value for selection proof")
+	}
+	if len(selectionProof) != phase0.SignatureLength {
+		return errors.New("incorrect length for selection proof")
+	}
+	copy(b.SelectionProof[:], selectionProof)
+
+	return nil
+}
+
+// String returns a string version of the structure.
+func (b *BeaconCommitteeSelection) String() string {
+	data, err := json.Marshal(b)
+	if err != nil {
+		return fmt.Sprintf("ERR: %v", err)
+	}
+
+	return string(data)
+}