evm

Documentation

Index

• Constants
• func OpenKeystore(dir string) *keystore.KeyStore
• func StoredContracts() map[string]StoredContract
• type Client
  • func NewClient(cfg config.EVM, palomaClient palomaClienter, internalChainID string) Client
  • func (c Client) DeployContract(ctx context.Context, contractAbi abi.ABI, bytecode, constructorInput []byte) (contractAddr common.Address, tx *ethtypes.Transaction, err error)
  • func (c Client) ExecuteSmartContract(ctx context.Context, contractAbi abi.ABI, addr common.Address, method string, ...) (*etherumtypes.Transaction, error)
  • func (c Client) FilterLogs(ctx context.Context, fq etherum.FilterQuery, currBlockHeight *big.Int, ...) (bool, error)
• type Processor
  • func NewProcessor(c Client, chainID string) Processor
  • func (p Processor) ExternalAccount() chain.ExternalAccount
  • func (p Processor) ProcessMessages(ctx context.Context, queueTypeName string, msgs []chain.MessageWithSignatures) error
  • func (p Processor) SignMessages(ctx context.Context, queueTypeName string, messages ...chain.QueuedMessage) ([]chain.SignedQueuedMessage, error)
  • func (p Processor) SupportedQueues() []string
• type StoredContract

Constants

const (
	ErrSmartContractNotFound     = whoops.Errorf("smart contract %s was not found")
	ErrInvalidAddress            = whoops.Errorf("provided address: '%s' is not valid")
	ErrAddressNotFoundInKeyStore = whoops.Errorf("address: '%s' not found in keystore: %s")
	ErrUnsupportedMessageType    = whoops.Errorf("unsupported message type: %T")

	ErrNoConsensus = whoops.String("no consensus reached")
)

const (
	SignedMessagePrefix = "\x19Ethereum Signed Message:\n32"
)

Functions

func OpenKeystore

func OpenKeystore(dir string) *keystore.KeyStore

func StoredContracts

func StoredContracts() map[string]StoredContract

Types

type Client

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

func NewClient

func NewClient(
	cfg config.EVM,
	palomaClient palomaClienter,
	internalChainID string,
) Client

func (Client) DeployContract

func (c Client) DeployContract(ctx context.Context, contractAbi abi.ABI, bytecode, constructorInput []byte) (contractAddr common.Address, tx *ethtypes.Transaction, err error)

func (Client) ExecuteSmartContract

func (c Client) ExecuteSmartContract(ctx context.Context, contractAbi abi.ABI, addr common.Address, method string, arguments []any) (*etherumtypes.Transaction, error)

func (Client) FilterLogs

func (c Client) FilterLogs(ctx context.Context, fq etherum.FilterQuery, currBlockHeight *big.Int, fn func(logs []ethtypes.Log) bool) (bool, error)

FilterLogs will gather all logs given a FilterQuery. If it encounters an error saying that there are too many results in the provided block window, then it's going to try to do this using a "binary search" approach while splitting the possible set in two, recursively.

type Processor

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

func NewProcessor

func NewProcessor(c Client, chainID string) Processor

func (Processor) ExternalAccount

func (p Processor) ExternalAccount() chain.ExternalAccount

func (Processor) ProcessMessages

func (p Processor) ProcessMessages(ctx context.Context, queueTypeName string, msgs []chain.MessageWithSignatures) error

func (Processor) SignMessages

func (p Processor) SignMessages(ctx context.Context, queueTypeName string, messages ...chain.QueuedMessage) ([]chain.SignedQueuedMessage, error)

func (Processor) SupportedQueues

func (p Processor) SupportedQueues() []string

type StoredContract

type StoredContract struct {
	ABI    abi.ABI
	Source []byte
}