utils

Documentation

Index

• Variables
• func CollectEventData(conf *Config, path string) error
• func IsEVMRootHeight(chainID flow.ChainID, flowHeight uint64) bool
• func IsSporkHeight(chainID flow.ChainID, flowHeight uint64) bool
• func OffchainReplayBackwardCompatibilityTest(log zerolog.Logger, chainID flow.ChainID, flowStartHeight uint64, ...) error
• func ReplayEVMEventsToStore(log zerolog.Logger, store environment.ValueStore, chainID flow.ChainID, ...) (map[flow.RegisterID]flow.RegisterValue, map[flow.RegisterID]flow.RegisterValue, ...)
• func VerifyRegisterUpdates(expectedUpdates map[flow.RegisterID]flow.RegisterValue, ...) error
• type Config
• type EVMEventsAccumulator
  • func NewEVMEventsAccumulator() *EVMEventsAccumulator
  • func (a *EVMEventsAccumulator) HasBlockEvent(evmBlockEvent *events.BlockEventPayload, ...) (*events.BlockEventPayload, []events.TransactionEventPayload, bool)
• type Event

Variables

var Devnet51Config = Config{
	// contains filtered or unexported fields
}

var Mainnet25Config = Config{
	// contains filtered or unexported fields
}

Functions

func CollectEventData

func CollectEventData(conf *Config, path string) error

func IsEVMRootHeight

func IsEVMRootHeight(chainID flow.ChainID, flowHeight uint64) bool

EVM Root Height is the first block that has EVM Block Event where the EVM block height is 1

func IsSporkHeight

func IsSporkHeight(chainID flow.ChainID, flowHeight uint64) bool

IsSporkHeight returns true if the given flow height is a spork height for the given chainID At spork height, there is no EVM events

func OffchainReplayBackwardCompatibilityTest

func OffchainReplayBackwardCompatibilityTest(
	log zerolog.Logger,
	chainID flow.ChainID,
	flowStartHeight uint64,
	flowEndHeight uint64,
	headers storage.Headers,
	results storage.ExecutionResults,
	executionDataStore execution_data.ExecutionDataGetter,
	store environment.ValueStore,
	onHeightReplayed func(uint64) error,
) error

OffchainReplayBackwardCompatibilityTest replays the offchain EVM state transition for a given range of flow blocks, the replay will also verify the StateUpdateChecksum of the EVM state transition from each transaction execution. the updated register values will be saved to the given value store.

func ReplayEVMEventsToStore

func ReplayEVMEventsToStore(
	log zerolog.Logger,
	store environment.ValueStore,
	chainID flow.ChainID,
	rootAddr flow.Address,
	evmBlockEvent *events.BlockEventPayload,
	evmTxEvents []events.TransactionEventPayload,
) (
	map[flow.RegisterID]flow.RegisterValue,
	map[flow.RegisterID]flow.RegisterValue,
	error,
)

func VerifyRegisterUpdates

func VerifyRegisterUpdates(expectedUpdates map[flow.RegisterID]flow.RegisterValue, actualUpdates map[flow.RegisterID]flow.RegisterValue) error

Types

type Config

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

type EVMEventsAccumulator

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

func NewEVMEventsAccumulator

func NewEVMEventsAccumulator() *EVMEventsAccumulator

func (*EVMEventsAccumulator) HasBlockEvent

func (a *EVMEventsAccumulator) HasBlockEvent(
	evmBlockEvent *events.BlockEventPayload,
	evmTxEvents []events.TransactionEventPayload) (
	*events.BlockEventPayload,
	[]events.TransactionEventPayload,
	bool,
)

type Event

type Event struct {
	FlowBlockHeight uint64 `json:"flow_height"`
	EventType       string `json:"type"`
	EventPayload    string `json:"payload"`
	// contains filtered or unexported fields
}