*: backport bugfixes to v1.11.4

.github/actions/setup-go/action.yml

@@ -13,7 +13,7 @@ runs:
       uses: actions/setup-go@4a3601121dd01d1626a1e23e37211e3254c1c06c # v6.4.0
       with:
         check-latest: true
-        go-version: "1.26"
+        go-version: "1.27"
 
     - name: Verify setup
       shell: bash

.github/workflows/golangci-lint.yml

@@ -19,4 +19,4 @@ jobs:
       - name: golangci-lint
         uses: golangci/golangci-lint-action@1e7e51e771db61008b38414a730f564565cf7c20 # v9.2.0
         with:
-          version: v2.12.2
+          version: v2.14.0

.golangci.yml

@@ -1,6 +1,6 @@
 version: "2"
 run:
-  go: "1.26"
+  go: "1.27"
 linters:
   default: all
   disable:
@@ -9,6 +9,7 @@ linters:
     - cyclop
     - err113
     - exhaustruct
+    - exhaustruct_v5
     - forcetypeassert
     - funlen
     - funcorder
@@ -18,6 +19,7 @@ linters:
     - godot
     - godox
     - gomoddirectives
+    - gomodguard
     - inamedparam
     - interfacebloat
     - intrange
@@ -169,6 +171,12 @@ linters:
       - legacy
       - std-error-handling
     rules:
+      # golangci-lint's nolintlint falsely reports //nolint:revive directives as
+      # unused and (with fix: true) deletes them, even though revive would fire
+      # without them. Keep such directives; do not report or auto-remove them.
+      - linters:
+          - nolintlint
+        text: 'is unused for linter "revive"'
       - linters:
           - bodyclose
           - gosec

.pre-commit-config.yaml

@@ -15,7 +15,7 @@ repos:
     rev: v0.0.6
     hooks:
       - id: check-go-version
-        args: [-v=go1.26] # Only check minor version locally
+        args: [-v=go1.27] # Only check minor version locally
         pass_filenames: false
         additional_dependencies: [packaging]
       - id: check-licence-header

.pre-commit/run_linter.sh

@@ -1,6 +1,6 @@
 #!/usr/bin/env bash
 
-VERSION="2.12.2"
+VERSION="2.14.0"
 
 if ! command -v golangci-lint &>/dev/null; then
     echo "golangci-lint could not be found"

CLAUDE.md

@@ -127,7 +127,7 @@ testutil/     # Test utilities, mocks, golden files
 ## Code Style and Guidelines
 
 ### Go Version
-Requires Go 1.26 (enforced by pre-commit hooks)
+Requires Go 1.27 (enforced by pre-commit hooks)
 
 ### Core Principles (from [docs/goguidelines.md](docs/goguidelines.md))
 1. **Functions over methods**: Prefer stateless functions over stateful objects

app/app.go

@@ -957,7 +957,7 @@ func newETH2Client(ctx context.Context, conf Config, life *lifecycle.Manager, lo
 			return nil, nil, err
 		}
 
-		fb := eth2wrap.NewSimnetFallbacks(bnTimeout, [4]byte(forkVersion), beaconNodeHeaders, conf.FallbackBeaconNodeAddrs)
+		fb := eth2wrap.NewSimnetFallbacks(ctx, bnTimeout, [4]byte(forkVersion), beaconNodeHeaders, conf.FallbackBeaconNodeAddrs)
 
 		wrap, err := eth2wrap.Instrument([]eth2wrap.Client{bmock}, fb)
 		if err != nil {
@@ -1000,7 +1000,7 @@ func newETH2Client(ctx context.Context, conf Config, life *lifecycle.Manager, lo
 			return nil, nil, err
 		}
 
-		fb := eth2wrap.NewSimnetFallbacks(bnTimeout, [4]byte(forkVersion), beaconNodeHeaders, conf.FallbackBeaconNodeAddrs)
+		fb := eth2wrap.NewSimnetFallbacks(ctx, bnTimeout, [4]byte(forkVersion), beaconNodeHeaders, conf.FallbackBeaconNodeAddrs)
 
 		wrap, err := eth2wrap.Instrument([]eth2wrap.Client{bmock}, fb)
 		if err != nil {
@@ -1046,7 +1046,7 @@ func newETH2Client(ctx context.Context, conf Config, life *lifecycle.Manager, lo
 
 // configureEth2Client configures a beacon node client with the provided settings.
 func configureEth2Client(ctx context.Context, forkVersion []byte, fallbackAddrs []string, addrs []string, headers map[string]string, timeout time.Duration, syntheticBlockProposals bool) (eth2wrap.Client, error) {
-	eth2Cl, err := eth2wrap.NewMultiHTTP(timeout, [4]byte(forkVersion), headers, addrs, fallbackAddrs)
+	eth2Cl, err := eth2wrap.NewMultiHTTP(ctx, timeout, [4]byte(forkVersion), headers, addrs, fallbackAddrs)
 	if err != nil {
 		return nil, errors.Wrap(err, "new eth2 http client")
 	}

app/eth2wrap/eth2wrap.go

@@ -92,46 +92,51 @@ func WithSyntheticDuties(cl Client) Client {
 }
 
 // NewMultiHTTP returns a new instrumented multi eth2 http client.
-func NewMultiHTTP(timeout time.Duration, forkVersion [4]byte, headers map[string]string, addrs []string, fallbackAddrs []string) (Client, error) {
+// The ctx bounds the lifetime of the underlying eth2http services' background routines.
+func NewMultiHTTP(ctx context.Context, timeout time.Duration, forkVersion [4]byte, headers map[string]string, addrs []string, fallbackAddrs []string) (Client, error) {
 	return Instrument(
-		newClients(timeout, forkVersion, headers, addrs),
-		newClients(timeout, forkVersion, headers, fallbackAddrs),
+		newClients(ctx, timeout, forkVersion, headers, addrs),
+		newClients(ctx, timeout, forkVersion, headers, fallbackAddrs),
 	)
 }
 
 // NewSimnetFallbacks returns a slice of Client initialized with the provided settings. Used in Simnet setting.
-func NewSimnetFallbacks(timeout time.Duration, forkVersion [4]byte, headers map[string]string, addresses []string) []Client {
+func NewSimnetFallbacks(ctx context.Context, timeout time.Duration, forkVersion [4]byte, headers map[string]string, addresses []string) []Client {
 	var clients []Client
 	for _, address := range addresses {
-		clients = append(clients, newBeaconClient(timeout, forkVersion, headers, address))
+		clients = append(clients, newBeaconClient(ctx, timeout, forkVersion, headers, address))
 	}
 
 	return clients
 }
 
 // newClients returns a slice of Client initialized with the provided settings.
-func newClients(timeout time.Duration, forkVersion [4]byte, headers map[string]string, addresses []string) []Client {
+func newClients(ctx context.Context, timeout time.Duration, forkVersion [4]byte, headers map[string]string, addresses []string) []Client {
 	var clients []Client
 	for _, address := range addresses {
-		clients = append(clients, newBeaconClient(timeout, forkVersion, headers, address))
+		clients = append(clients, newBeaconClient(ctx, timeout, forkVersion, headers, address))
 	}
 
 	return clients
 }
 
-// newBeaconClient returns a Client with the provided settings.
-func newBeaconClient(timeout time.Duration, forkVersion [4]byte, headers map[string]string, address string) Client {
-	parameters := []eth2http.Parameter{
+// newBeaconClient returns a Client with the provided settings, extraParams override them.
+func newBeaconClient(svcCtx context.Context, timeout time.Duration, forkVersion [4]byte, headers map[string]string, address string,
+	extraParams ...eth2http.Parameter,
+) Client {
+	parameters := append([]eth2http.Parameter{
 		eth2http.WithLogLevel(zeroLogInfo),
 		eth2http.WithAddress(address),
 		eth2http.WithTimeout(timeout),
 		eth2http.WithAllowDelayedStart(true),
 		eth2http.WithEnforceJSON(featureset.Enabled(featureset.JSONRequests)),
 		eth2http.WithExtraHeaders(headers),
-	}
+	}, extraParams...)
 
 	cl := newLazy(func(ctx context.Context) (Client, error) {
-		eth2Svc, err := eth2http.New(ctx, parameters...)
+		// eth2http.New ties its background routines (static value cache clearing, connection
+		// state pings) to the ctx it is given, so use svcCtx, not the triggering request's ctx.
+		eth2Svc, err := eth2http.New(svcCtx, parameters...)
 		if err != nil {
 			return nil, wrapError(ctx, err, "new eth2 client", z.Str("address", address))
 		}