*: feerecipient cmd, wip

Author: pinebit

app/obolapi/feerecipient.go

@@ -0,0 +1,105 @@
+// Copyright © 2022-2026 Obol Labs Inc. Licensed under the terms of a Business Source License 1.1
+
+package obolapi
+
+import (
+	"context"
+	"encoding/hex"
+	"encoding/json"
+	"net/url"
+	"strconv"
+	"strings"
+
+	"github.com/obolnetwork/charon/app/errors"
+)
+
+const (
+	submitPartialFeeRecipientTmpl = "/fee_recipient/partial/" + lockHashPath + "/" + shareIndexPath
+	fetchPartialFeeRecipientTmpl  = "/fee_recipient/" + lockHashPath + "/" + valPubkeyPath
+)
+
+// submitPartialFeeRecipientURL returns the partial fee recipient Obol API URL for a given lock hash.
+func submitPartialFeeRecipientURL(lockHash string, shareIndex uint64) string {
+	return strings.NewReplacer(
+		lockHashPath,
+		lockHash,
+		shareIndexPath,
+		strconv.FormatUint(shareIndex, 10),
+	).Replace(submitPartialFeeRecipientTmpl)
+}
+
+// fetchPartialFeeRecipientURL returns the partial fee recipient Obol API URL for a given validator public key.
+func fetchPartialFeeRecipientURL(valPubkey, lockHash string) string {
+	return strings.NewReplacer(
+		valPubkeyPath,
+		valPubkey,
+		lockHashPath,
+		lockHash,
+	).Replace(fetchPartialFeeRecipientTmpl)
+}
+
+// PostPartialFeeRecipients POSTs partial fee recipient registrations to the Obol API.
+// It respects the timeout specified in the Client instance.
+func (c Client) PostPartialFeeRecipients(ctx context.Context, lockHash []byte, shareIndex uint64, partialRegs []PartialRegistration) error {
+	lockHashStr := "0x" + hex.EncodeToString(lockHash)
+
+	path := submitPartialFeeRecipientURL(lockHashStr, shareIndex)
+
+	u, err := url.ParseRequestURI(c.baseURL)
+	if err != nil {
+		return errors.Wrap(err, "bad Obol API url")
+	}
+
+	u.Path = path
+
+	req := PartialFeeRecipientRequest{PartialRegistrations: partialRegs}
+
+	data, err := json.Marshal(req)
+	if err != nil {
+		return errors.Wrap(err, "json marshal error")
+	}
+
+	ctx, cancel := context.WithTimeout(ctx, c.reqTimeout)
+	defer cancel()
+
+	err = httpPost(ctx, u, data, nil)
+	if err != nil {
+		return errors.Wrap(err, "http Obol API POST request")
+	}
+
+	return nil
+}
+
+// GetPartialFeeRecipients fetches partial fee recipient registrations from the Obol API.
+// It respects the timeout specified in the Client instance.
+func (c Client) GetPartialFeeRecipients(ctx context.Context, valPubkey string, lockHash []byte, _ int) (PartialFeeRecipientResponse, error) {
+	path := fetchPartialFeeRecipientURL(valPubkey, "0x"+hex.EncodeToString(lockHash))
+
+	u, err := url.ParseRequestURI(c.baseURL)
+	if err != nil {
+		return PartialFeeRecipientResponse{}, errors.Wrap(err, "bad Obol API url")
+	}
+
+	u.Path = path
+
+	ctx, cancel := context.WithTimeout(ctx, c.reqTimeout)
+	defer cancel()
+
+	respBody, err := httpGet(ctx, u, map[string]string{})
+	if err != nil {
+		return PartialFeeRecipientResponse{}, errors.Wrap(err, "http Obol API GET request")
+	}
+
+	defer respBody.Close()
+
+	var resp PartialFeeRecipientResponse
+	if err := json.NewDecoder(respBody).Decode(&resp); err != nil {
+		return PartialFeeRecipientResponse{}, errors.Wrap(err, "unmarshal response")
+	}
+
+	if len(resp.Partials) == 0 {
+		return PartialFeeRecipientResponse{}, ErrNoValue
+	}
+
+	return resp, nil
+}

app/obolapi/feerecipient_model.go

@@ -0,0 +1,32 @@
+// Copyright © 2022-2026 Obol Labs Inc. Licensed under the terms of a Business Source License 1.1
+
+package obolapi
+
+import (
+	eth2v1 "github.com/attestantio/go-eth2-client/api/v1"
+
+	"github.com/obolnetwork/charon/tbls"
+)
+
+// PartialRegistration represents a partial builder registration with a partial BLS signature.
+type PartialRegistration struct {
+	Message   *eth2v1.ValidatorRegistration `json:"message"`
+	Signature tbls.Signature                `json:"signature"`
+}
+
+// PartialFeeRecipientRequest represents the request body for posting partial fee recipient registrations.
+type PartialFeeRecipientRequest struct {
+	PartialRegistrations []PartialRegistration `json:"partial_registrations"`
+}
+
+// PartialFeeRecipientResponsePartial represents a single partial registration in the response.
+type PartialFeeRecipientResponsePartial struct {
+	ShareIdx  int                           `json:"share_index"`
+	Message   *eth2v1.ValidatorRegistration `json:"message"`
+	Signature []byte                        `json:"signature"`
+}
+
+// PartialFeeRecipientResponse represents the response body when fetching partial fee recipient registrations.
+type PartialFeeRecipientResponse struct {
+	Partials []PartialFeeRecipientResponsePartial `json:"partial_registrations"`
+}

cmd/cmd.go

@@ -74,6 +74,10 @@ func New() *cobra.Command {
 			newDepositSignCmd(runDepositSign),
 			newDepositFetchCmd(runDepositFetch),
 		),
+		newFeeRecipientCmd(
+			newFeeRecipientSignCmd(runFeeRecipientSign),
+			newFeeRecipientFetchCmd(runFeeRecipientFetch),
+		),
 		newUnsafeCmd(newRunCmd(app.Run, true)),
 	)
 }

cmd/feerecipient.go

@@ -0,0 +1,42 @@
+// Copyright © 2022-2026 Obol Labs Inc. Licensed under the terms of a Business Source License 1.1
+
+package cmd
+
+import (
+	"time"
+
+	"github.com/spf13/cobra"
+
+	"github.com/obolnetwork/charon/app/log"
+)
+
+type feerecipientConfig struct {
+	ValidatorPublicKeys []string
+	PrivateKeyPath      string
+	LockFilePath        string
+	ValidatorKeysDir    string
+	PublishAddress      string
+	PublishTimeout      time.Duration
+	Log                 log.Config
+}
+
+func newFeeRecipientCmd(cmds ...*cobra.Command) *cobra.Command {
+	root := &cobra.Command{
+		Use:   "feerecipient",
+		Short: "Sign and fetch updated fee recipient registrations.",
+		Long:  "Sign and fetch updated builder registration messages with new fee recipients using a remote API, enabling the modification of fee recipient addresses without cluster restart.",
+	}
+
+	root.AddCommand(cmds...)
+
+	return root
+}
+
+func bindFeeRecipientFlags(cmd *cobra.Command, config *feerecipientConfig) {
+	cmd.Flags().StringSliceVar(&config.ValidatorPublicKeys, "validator-public-keys", []string{}, "Comma-separated list of validator public keys to update (required for the sign subcommand).")
+	cmd.Flags().StringVar(&config.PrivateKeyPath, privateKeyPath.String(), ".charon/charon-enr-private-key", "Path to the charon enr private key file.")
+	cmd.Flags().StringVar(&config.ValidatorKeysDir, validatorKeysDir.String(), ".charon/validator_keys", "Path to the directory containing the validator private key share files and passwords.")
+	cmd.Flags().StringVar(&config.LockFilePath, lockFilePath.String(), ".charon/cluster-lock.json", "Path to the cluster lock file defining the distributed validator cluster.")
+	cmd.Flags().StringVar(&config.PublishAddress, publishAddress.String(), "https://api.obol.tech/v1", "The URL of the remote API.")
+	cmd.Flags().DurationVar(&config.PublishTimeout, publishTimeout.String(), 5*time.Minute, "Timeout for publishing to the publish-address API.")
+}