handlers

Documentation

Index

• Constants
• type AccountProof
• type BeaconClient
• type Client
• type DepositEventHandler
  • func NewDepositEventHandler(domainID uint8, client Client, routerAddres common.Address, slotIndex uint8, ...) *DepositEventHandler
  • func (h *DepositEventHandler) HandleEvents(destination uint8, startBlock *big.Int, endBlock *big.Int, slot *big.Int) error
• type EventFetcher
• type HashiEventHandler
  • func NewHashiEventHandler(domainID uint8, client Client, beaconClient BeaconClient, ...) *HashiEventHandler
  • func (h *HashiEventHandler) HandleEvents(destination uint8, startBlock *big.Int, endBlock *big.Int, slot *big.Int) error
• type ReceiptProver
• type RootProver
• type StateRootEventHandler
  • func NewStateRootEventHandler(msgChan chan []*message.Message, eventFetcher EventFetcher, ...) *StateRootEventHandler
  • func (h *StateRootEventHandler) HandleEvents(startBlock *big.Int, endBlock *big.Int) error
• type StorageProof

Constants

const (
	EVMStateRootMessage message.MessageType = "EVMStateRootMessage"
)

const (
	MAX_BLOCK_RANGE int64 = 1000
)

Types

type AccountProof

type AccountProof struct {
	AccountProof []string       `json:"accountProof"`
	StorageProof []StorageProof `json:"storageProof"`
}

type BeaconClient

type BeaconClient interface {
	BeaconBlockHeader(
		ctx context.Context,
		opts *api.BeaconBlockHeaderOpts,
	) (
		*api.Response[*apiv1.BeaconBlockHeader],
		error,
	)
}

type Client

type Client interface {
	CallContext(ctx context.Context, target interface{}, rpcMethod string, args ...interface{}) error
	FetchEventLogs(ctx context.Context, contractAddress common.Address, event string, startBlock *big.Int, endBlock *big.Int) ([]types.Log, error)
	BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)
	TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)
}

type DepositEventHandler

type DepositEventHandler struct {
	// contains filtered or unexported fields
}

func NewDepositEventHandler

func NewDepositEventHandler(
	domainID uint8,
	client Client,
	routerAddres common.Address,
	slotIndex uint8,
	genericResources []string,
	msgChan chan []*message.Message) *DepositEventHandler

func (*DepositEventHandler) HandleEvents

func (h *DepositEventHandler) HandleEvents(destination uint8, startBlock *big.Int, endBlock *big.Int, slot *big.Int) error

type EventFetcher

type EventFetcher interface {
	FetchEventLogs(ctx context.Context, contractAddress common.Address, event string, startBlock *big.Int, endBlock *big.Int) ([]types.Log, error)
}

type HashiEventHandler

type HashiEventHandler struct {
	// contains filtered or unexported fields
}

func NewHashiEventHandler

func NewHashiEventHandler(
	domainID uint8,
	client Client,
	beaconClient BeaconClient,
	receiptProver ReceiptProver,
	rootProver RootProver,
	yahoAddress common.Address,
	chainIDS map[uint8]uint64,
	msgChan chan []*message.Message) *HashiEventHandler

func (*HashiEventHandler) HandleEvents

func (h *HashiEventHandler) HandleEvents(destination uint8, startBlock *big.Int, endBlock *big.Int, slot *big.Int) error

type ReceiptProver

type ReceiptProver interface {
	ReceiptProof(txHash common.Hash) ([][]byte, error)
}

type RootProver

type RootProver interface {
	ReceiptsRootProof(ctx context.Context, currentSlot *big.Int, targetSlot *big.Int) ([][]byte, error)
}

type StateRootEventHandler

type StateRootEventHandler struct {
	// contains filtered or unexported fields
}

func NewStateRootEventHandler

func NewStateRootEventHandler(
	msgChan chan []*message.Message,
	eventFetcher EventFetcher,
	stateRootAddress common.Address,
	domainID uint8,
) *StateRootEventHandler

func (*StateRootEventHandler) HandleEvents

func (h *StateRootEventHandler) HandleEvents(startBlock *big.Int, endBlock *big.Int) error

HandleEvents fetches state root submitted events and sends message to origin domain

type StorageProof

type StorageProof struct {
	Proof []string `json:"proof"`
}