blobber

README

Beacon Chain DevP2P Blob Testing Proxy

!! WARNING !!

Running some of the actions included in this tool will get a validator SLASHED.

Please exercise caution when using this tool and never use it on Mainnet!

Description

Testing tool that sits as a proxy between the beacon and validator clients in order to intercept proposals, and then modify, delay, conceal or corrupt the blobs included in the proposal, which are then relayed to all the beacon clients via the DevP2P network.

    graph LR;
        subgraph identifier[" "]
            beaconClient(Beacon Client)
            validatorClient(Validator Client)
            proxy(Blobber)
            BeaconDevP2P(Beacon DevP2P Network)
        end

        validatorClient -->|Attestations Request| proxy
        proxy -->|Attestations Request| beaconClient
        beaconClient -->|Attestations Response| proxy
        proxy -->|Attestations Response| validatorClient

        validatorClient -->|Proposal Request| proxy
        proxy -->|Proposal Request| beaconClient
        beaconClient -->|Proposal Response| proxy
        proxy -.->|Modified/Signed Proposal Response| BeaconDevP2P

        linkStyle 0,1 stroke-width:3px,fill:none,stroke:darkgreen;
        linkStyle 2,3 stroke-width:3px,fill:none,stroke:green;
        linkStyle 4,5 stroke-width:3px,fill:none,stroke:blue;
        linkStyle 6,7 stroke-width:3px,fill:none,stroke:darkblue;

Installation

git clone https://github.com/marioevz/blobber.git
cd blobber
go build -o blobber ./cmd
./blobber --help

Use with Docker

docker run -it ethpandaops/blobber:latest --help

Configuration

Beacon Node Configuration

The blobber requires at least one consensus client in Beacon Node + Validator Client configuration, and the --cl flag must be provided to point to the Beacon Node REST API endpoint:

--cl http://beacon_node_1:4000/ --cl http://beacon_node_2:4000/ ...

The Beacon Node endpoint will be used to relay all Validator Client requests and intercept proposals, and also to obtain the client's ENR, which the blobber will use to connect to the client via devp2p.

The validator client must be then configured to connect to the blobber instead of the Beacon Node, starting at port 20,000 (by default) and increasing by 1 for each Beacon Node configured using the --cl flag.

Validator Keys

In order to produce block signatures, correct and equivocating, the blobber needs the validator keys of the validators that will be used to perform the actions, and these, ideally, should be the whole set or a subset of the keys that the configured validator client has.

Either of the following parameter flags can be used to configure these keys:

• --validator-key-file: Path to a single text file containing the validator secret keys in hexadecimal format, one key per line.
• --validator-key-folder: Path to a folder containing the "keys" and "secrets" subfolders with the validator secret keys.

Proposal Actions

The blobber can be configured to perform actions on a block proposal, such as delaying blobs broadcasting, create equivocating blob sidecars, among other things.

At the moment, the blobber can be configured to do one proposal action with a certain frequency.

To configure the proposal action the flag --proposal-action is used:

--proposal-action '{"name": "blob_gossip_delay"}'

Each proposal action has configurable parameters which can be set with the same flag:

--proposal-action '{"name": "blob_gossip_delay", "delay_milliseconds": 1000}'

To see a list of available proposal actions see here.

Documentation

Index

• Constants
• func ParseResponse(response []byte) (string, *deneb.BlockContents, error)
• type Blobber
  • func NewBlobber(ctx context.Context, opts ...config.Option) (*Blobber, error)
  • func (b *Blobber) AddBeaconClient(cl *beacon_client.BeaconClient, validatorProxy bool) *validator_proxy.ValidatorProxy
  • func (b *Blobber) Address() string
  • func (b *Blobber) Close()
  • func (b *Blobber) GetProducedBlockRoots() map[beacon_common.Slot][32]byte
  • func (b *Blobber) IncludeBlobRecord() *common.BlobRecord
  • func (b *Blobber) RejectBlobRecord() *common.BlobRecord
• type BlockDataStruct
• type BuiltBlocksMap

Constants

const (
	PortBeaconTCP    = 9000
	PortBeaconUDP    = 9000
	PortBeaconAPI    = 4000
	PortBeaconGRPC   = 4001
	PortMetrics      = 8080
	PortValidatorAPI = 5000
	FarFutureEpoch   = beacon_common.Epoch(0xffffffffffffffff)

	DEFAULT_BLOBBER_HOST       = "0.0.0.0"
	DEFAULT_BLOBBER_PORT       = 19999
	DEFAULT_PROXIES_PORT_START = 20000

	DEFAULT_VALIDATOR_LOAD_TIMEOUT_SECONDS = 20
)

Functions

func ParseResponse

func ParseResponse(response []byte) (string, *deneb.BlockContents, error)

Types

type Blobber

type Blobber struct {

	// Configuration object
	*config.Config
	// contains filtered or unexported fields
}

func NewBlobber

func NewBlobber(ctx context.Context, opts ...config.Option) (*Blobber, error)

func (*Blobber) AddBeaconClient

func (b *Blobber) AddBeaconClient(cl *beacon_client.BeaconClient, validatorProxy bool) *validator_proxy.ValidatorProxy

func (*Blobber) Address

func (b *Blobber) Address() string

func (*Blobber) Close

func (b *Blobber) Close()

func (*Blobber) GetProducedBlockRoots

func (b *Blobber) GetProducedBlockRoots() map[beacon_common.Slot][32]byte

func (*Blobber) IncludeBlobRecord

func (b *Blobber) IncludeBlobRecord() *common.BlobRecord

Return a list of blobs that each proposal action has classified as must-be-included

func (*Blobber) RejectBlobRecord

func (b *Blobber) RejectBlobRecord() *common.BlobRecord

Return a list of blobs that each proposal action has classified as must-be-rejected

type BlockDataStruct

type BlockDataStruct struct {
	Version string          `json:"version"`
	Data    json.RawMessage `json:"data"`
}

type BuiltBlocksMap

type BuiltBlocksMap struct {
	BlockRoots map[beacon_common.Slot][32]byte
	sync.RWMutex
}