evm

Documentation

Index

• Variables
• func DecodeERC20TokenDeploymentEvent(log *geth.Log) (types.EventTokenDeployed, error)
• func DecodeERC20TransferEvent(log *geth.Log) (types.EventTransfer, error)
• func DecodeEventContractCall(log *geth.Log) (types.EventContractCall, error)
• func DecodeEventContractCallWithToken(log *geth.Log) (types.EventContractCallWithToken, error)
• func DecodeEventTokenSent(log *geth.Log) (types.EventTokenSent, error)
• func DecodeMultisigOperatorshipTransferredEvent(log *geth.Log) (types.EventMultisigOperatorshipTransferred, error)
• type LatestFinalizedBlockCache
  • func NewLatestFinalizedBlockCache() LatestFinalizedBlockCache
• type Mgr
  • func NewMgr(rpcs map[string]rpc.Client, broadcaster broadcast.Broadcaster, ...) *Mgr
  • func (mgr Mgr) GetTxReceiptIfFinalized(chain nexus.ChainName, txID common.Hash, confHeight uint64) (results.Result[geth.Receipt], error)
  • func (mgr Mgr) GetTxReceiptsIfFinalized(chain nexus.ChainName, txIDs []common.Hash, confHeight uint64) ([]results.Result[geth.Receipt], error)
  • func (mgr Mgr) ProcessDepositConfirmation(event *types.ConfirmDepositStarted) error
  • func (mgr Mgr) ProcessGatewayTxConfirmation(event *types.ConfirmGatewayTxStarted) error
  • func (mgr Mgr) ProcessGatewayTxsConfirmation(event *types.ConfirmGatewayTxsStarted) error
  • func (mgr Mgr) ProcessNewChain(event *types.ChainAdded) (err error)
  • func (mgr Mgr) ProcessTokenConfirmation(event *types.ConfirmTokenStarted) error
  • func (mgr Mgr) ProcessTransferKeyConfirmation(event *types.ConfirmKeyTransferStarted) error

Variables

var (
	ERC20TransferSig                = crypto.Keccak256Hash([]byte("Transfer(address,address,uint256)"))
	ERC20TokenDeploymentSig         = crypto.Keccak256Hash([]byte("TokenDeployed(string,address)"))
	MultisigTransferOperatorshipSig = crypto.Keccak256Hash([]byte("OperatorshipTransferred(bytes)"))
	ContractCallSig                 = crypto.Keccak256Hash([]byte("ContractCall(address,string,string,bytes32,bytes)"))
	ContractCallWithTokenSig        = crypto.Keccak256Hash([]byte("ContractCallWithToken(address,string,string,bytes32,bytes,string,uint256)"))
	TokenSentSig                    = crypto.Keccak256Hash([]byte("TokenSent(address,string,string,string,uint256)"))
)

Smart contract event signatures

var ErrNotFinalized = goerrors.New("not finalized")

ErrNotFinalized is returned when a transaction is not finalized

var ErrTxFailed = goerrors.New("transaction failed")

ErrTxFailed is returned when a transaction has failed

Functions

func DecodeERC20TokenDeploymentEvent

func DecodeERC20TokenDeploymentEvent(log *geth.Log) (types.EventTokenDeployed, error)

func DecodeERC20TransferEvent

func DecodeERC20TransferEvent(log *geth.Log) (types.EventTransfer, error)

func DecodeEventContractCall

func DecodeEventContractCall(log *geth.Log) (types.EventContractCall, error)

func DecodeEventContractCallWithToken

func DecodeEventContractCallWithToken(log *geth.Log) (types.EventContractCallWithToken, error)

func DecodeEventTokenSent

func DecodeEventTokenSent(log *geth.Log) (types.EventTokenSent, error)

func DecodeMultisigOperatorshipTransferredEvent

func DecodeMultisigOperatorshipTransferredEvent(log *geth.Log) (types.EventMultisigOperatorshipTransferred, error)

Types

type LatestFinalizedBlockCache

type LatestFinalizedBlockCache interface {
	// Get returns the latest finalized block number for chain
	Get(chain nexus.ChainName) *big.Int
	// Set sets the latest finalized block number for chain, if the given block number is greater than the current latest finalized block number
	Set(chain nexus.ChainName, blockNumber *big.Int)
}

LatestFinalizedBlockCache is a cache for the latest finalized block number for each chain

func NewLatestFinalizedBlockCache

func NewLatestFinalizedBlockCache() LatestFinalizedBlockCache

type Mgr

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

Mgr manages all communication with Ethereum

func NewMgr

func NewMgr(rpcs map[string]rpc.Client, broadcaster broadcast.Broadcaster, valAddr sdk.ValAddress, proxy sdk.AccAddress, latestFinalizedBlockCache LatestFinalizedBlockCache) *Mgr

NewMgr returns a new Mgr instance

func (Mgr) GetTxReceiptIfFinalized

func (mgr Mgr) GetTxReceiptIfFinalized(chain nexus.ChainName, txID common.Hash, confHeight uint64) (results.Result[geth.Receipt], error)

GetTxReceiptIfFinalized retrieves receipt for provided transaction ID.

Result is

- Ok(receipt) if the transaction is finalized and successful

- Err(ethereum.NotFound) if the transaction is not found

- Err(ErrTxFailed) if the transaction is finalized but failed

- Err(ErrNotFinalized) if the transaction is not finalized

- Err(err) otherwise

func (Mgr) GetTxReceiptsIfFinalized

func (mgr Mgr) GetTxReceiptsIfFinalized(chain nexus.ChainName, txIDs []common.Hash, confHeight uint64) ([]results.Result[geth.Receipt], error)

GetTxReceiptsIfFinalized retrieves receipts for provided transaction IDs.

Individual result is

- Ok(receipt) if the transaction is finalized and successful

- Err(ethereum.NotFound) if the transaction is not found

- Err(ErrTxFailed) if the transaction is finalized but failed

- Err(ErrNotFinalized) if the transaction is not finalized

- Err(err) otherwise

func (Mgr) ProcessDepositConfirmation

func (mgr Mgr) ProcessDepositConfirmation(event *types.ConfirmDepositStarted) error

ProcessDepositConfirmation votes on the correctness of an EVM chain token deposit

func (Mgr) ProcessGatewayTxConfirmation

func (mgr Mgr) ProcessGatewayTxConfirmation(event *types.ConfirmGatewayTxStarted) error

ProcessGatewayTxConfirmation votes on the correctness of an EVM chain gateway's transactions

func (Mgr) ProcessGatewayTxsConfirmation

func (mgr Mgr) ProcessGatewayTxsConfirmation(event *types.ConfirmGatewayTxsStarted) error

ProcessGatewayTxsConfirmation votes on the correctness of an EVM chain multiple gateway transactions

func (Mgr) ProcessNewChain

func (mgr Mgr) ProcessNewChain(event *types.ChainAdded) (err error)

ProcessNewChain notifies the operator that vald needs to be restarted/udpated for a new chain

func (Mgr) ProcessTokenConfirmation

func (mgr Mgr) ProcessTokenConfirmation(event *types.ConfirmTokenStarted) error

ProcessTokenConfirmation votes on the correctness of an EVM chain token deployment

func (Mgr) ProcessTransferKeyConfirmation

func (mgr Mgr) ProcessTransferKeyConfirmation(event *types.ConfirmKeyTransferStarted) error

ProcessTransferKeyConfirmation votes on the correctness of an EVM chain key transfer