message

Documentation

Index

• Constants
• func NewEVMTransferMessage(source uint8, destination uint8, transfer TransferData, messageID string) *message.Message
• func NewEvmStateRootMessage(source uint8, destination uint8, stateRoot StateRootData, messageID string) *message.Message
• func NewHashiMessage(source uint8, destination uint8, data HashiData, messageID string) *message.Message
• type BlockFetcher
• type BlockStorer
• type EventHandler
• type HashiData
• type HashiMessageHandler
  • func (h *HashiMessageHandler) HandleMessage(m *message.Message) (*proposal.Proposal, error)
• type StateRootData
• type StateRootHandler
  • func NewStateRootHandler(domainID uint8, eventHandlers []EventHandler, blockFetcher BlockFetcher, ...) *StateRootHandler
  • func (h *StateRootHandler) HandleMessage(m *message.Message) (*proposal.Proposal, error)
• type TransferData
• type TransferHandler
  • func (h *TransferHandler) HandleMessage(m *message.Message) (*proposal.Proposal, error)
• type TransferType

Constants

const (
	HashiMessage  message.MessageType   = "HashiMessage"
	HashiProposal proposal.ProposalType = "HashiProposal"
)

const (
	EVMStateRootMessage message.MessageType = "EVMStateRootMessage"
	MAX_BLOCK_RANGE     int64               = 1000
)

const (
	EVMTransferMessage  message.MessageType   = "EVMTransferMessage"
	EVMTransferProposal proposal.ProposalType = "EVMTransferProposal"

	GenericTransfer  TransferType = "genericTransfer"
	FungibleTransfer TransferType = "fungibleTransfer"
)

Functions

func NewEVMTransferMessage

func NewEVMTransferMessage(source uint8, destination uint8, transfer TransferData, messageID string) *message.Message

func NewEvmStateRootMessage

func NewEvmStateRootMessage(source uint8, destination uint8, stateRoot StateRootData, messageID string) *message.Message

func NewHashiMessage

func NewHashiMessage(source uint8, destination uint8, data HashiData, messageID string) *message.Message

Types

type BlockFetcher

type BlockFetcher interface {
	SignedBeaconBlock(ctx context.Context, opts *api.SignedBeaconBlockOpts) (*api.Response[*spec.VersionedSignedBeaconBlock], error)
}

type BlockStorer

type BlockStorer interface {
	StoreBlock(sourceDomainID uint8, destinationDomainID uint8, blockNumber *big.Int) error
	LatestBlock(sourceDomainID uint8, destinationDomainID uint8) (*big.Int, error)
}

type EventHandler

type EventHandler interface {
	HandleEvents(destination uint8, startBlock *big.Int, endBlock *big.Int, slot *big.Int) error
}

type HashiData

type HashiData struct {
	SrcSlot           *big.Int
	TxSlot            *big.Int
	ReceiptRootProof  [][]byte
	ReceiptRoot       [32]byte
	ReceiptProof      [][]byte
	TxIndexRLPEncoded []byte
	LogIndex          *big.Int
}

type HashiMessageHandler

type HashiMessageHandler struct{}

func (*HashiMessageHandler) HandleMessage

func (h *HashiMessageHandler) HandleMessage(m *message.Message) (*proposal.Proposal, error)

type StateRootData

type StateRootData struct {
	StateRoot [32]byte
	Slot      *big.Int
}

type StateRootHandler

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

func NewStateRootHandler

func NewStateRootHandler(
	domainID uint8,
	eventHandlers []EventHandler,
	blockFetcher BlockFetcher,
	blockStorer BlockStorer,
	startBlock *big.Int,
) *StateRootHandler

func (*StateRootHandler) HandleMessage

func (h *StateRootHandler) HandleMessage(m *message.Message) (*proposal.Proposal, error)

HandleMessage fetches deposits for the given state root and submits a transfer message with execution state proofs per transfer

type TransferData

type TransferData struct {
	Deposit      *events.Deposit
	Slot         *big.Int
	AccountProof []string
	StorageProof []string
	Type         TransferType
}

type TransferHandler

type TransferHandler struct{}

func (*TransferHandler) HandleMessage

func (h *TransferHandler) HandleMessage(m *message.Message) (*proposal.Proposal, error)

type TransferType

type TransferType string