ethereum

type CallMsg struct {
	From     libcommon.Address  // the sender of the 'transaction'
	To       *libcommon.Address // the destination contract (nil for contract creation)
	Gas      uint64             // if 0, the call executes with near-infinite gas
	GasPrice *uint256.Int       // wei <-> gas exchange ratio
	Value    *uint256.Int       // amount of wei sent along with the call
	Data     []byte             // input data, usually an ABI-encoded contract method invocation

	FeeCap     *uint256.Int      // EIP-1559 fee cap per gas.
	Tip        *uint256.Int      // EIP-1559 tip per gas.
	AccessList types2.AccessList // EIP-2930 access list.
}

type ChainReader interface {
	BlockByHash(ctx context.Context, hash libcommon.Hash) (*types.Block, error)
	BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)
	HeaderByHash(ctx context.Context, hash libcommon.Hash) (*types.Header, error)
	HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)
	TransactionCount(ctx context.Context, blockHash libcommon.Hash) (uint, error)
	TransactionInBlock(ctx context.Context, blockHash libcommon.Hash, index uint) (types.Transaction, error)

	// This method subscribes to notifications about changes of the head block of
	// the canonical chain.
	SubscribeNewHead(ctx context.Context, ch chan<- *types.Header) (Subscription, error)
}

type ChainStateReader interface {
	BalanceAt(ctx context.Context, account libcommon.Address, blockNumber *big.Int) (*uint256.Int, error)
	StorageAt(ctx context.Context, account libcommon.Address, key libcommon.Hash, blockNumber *big.Int) ([]byte, error)
	CodeAt(ctx context.Context, account libcommon.Address, blockNumber *big.Int) ([]byte, error)
	NonceAt(ctx context.Context, account libcommon.Address, blockNumber *big.Int) (uint64, error)
}

type ChainSyncReader interface {
	SyncProgress(ctx context.Context) (*SyncProgress, error)
}

type ContractCaller interface {
	CallContract(ctx context.Context, call CallMsg, blockNumber *big.Int) ([]byte, error)
}

type FilterQuery struct {
	BlockHash *libcommon.Hash     // used by eth_getLogs, return logs only from block with this hash
	FromBlock *big.Int            // beginning of the queried range, nil means genesis block
	ToBlock   *big.Int            // end of the range, nil means latest block
	Addresses []libcommon.Address // restricts matches to events created by specific contracts

	// The Topic list restricts matches to particular event topics. Each event has a list
	// of topics. Topics matches a prefix of that list. An empty element slice matches any
	// topic. Non-empty elements represent an alternative that matches any of the
	// contained topics.
	//
	// Examples:
	// {} or nil          matches any topic list
	// {{A}}              matches topic A in first position
	// {{}, {B}}          matches any topic in first position AND B in second position
	// {{A}, {B}}         matches topic A in first position AND B in second position
	// {{A, B}, {C, D}}   matches topic (A OR B) in first position AND (C OR D) in second position
	Topics [][]libcommon.Hash
}

type GasEstimator interface {
	EstimateGas(ctx context.Context, call CallMsg) (uint64, error)
}

type GasPricer interface {
	SuggestGasPrice(ctx context.Context) (*big.Int, error)
}

type LogFilterer interface {
	FilterLogs(ctx context.Context, q FilterQuery) ([]types.Log, error)
	SubscribeFilterLogs(ctx context.Context, q FilterQuery, ch chan<- types.Log) (Subscription, error)
}

type PendingContractCaller interface {
	PendingCallContract(ctx context.Context, call CallMsg) ([]byte, error)
}

type PendingStateEventer interface {
	SubscribePendingTransactions(ctx context.Context, ch chan<- *types.Transaction) (Subscription, error)
}

type PendingStateReader interface {
	PendingBalanceAt(ctx context.Context, account libcommon.Address) (*big.Int, error)
	PendingStorageAt(ctx context.Context, account libcommon.Address, key libcommon.Hash) ([]byte, error)
	PendingCodeAt(ctx context.Context, account libcommon.Address) ([]byte, error)
	PendingNonceAt(ctx context.Context, account libcommon.Address) (uint64, error)
	PendingTransactionCount(ctx context.Context) (uint, error)
}

type Subscription interface {
	// Unsubscribe cancels the sending of events to the data channel
	// and closes the error channel.
	Unsubscribe()
	// Err returns the subscription error channel. The error channel receives
	// a value if there is an issue with the subscription (e.g. the network connection
	// delivering the events has been closed). Only one value will ever be sent.
	// The error channel is closed by Unsubscribe.
	Err() <-chan error
}

type SyncProgress struct {
	StartingBlock uint64 // Block number where sync began
	CurrentBlock  uint64 // Current block number where sync is at
	HighestBlock  uint64 // Highest alleged block number in the chain
	PulledStates  uint64 // Number of state trie entries already downloaded
	KnownStates   uint64 // Total number of state trie entries known about
}

type TransactionReader interface {
	// TransactionByHash checks the pool of pending transactions in addition to the
	// blockchain. The isPending return value indicates whether the transaction has been
	// mined yet. Note that the transaction may not be part of the canonical chain even if
	// it's not pending.
	TransactionByHash(ctx context.Context, txHash libcommon.Hash) (tx types.Transaction, isPending bool, err error)
	// TransactionReceipt returns the receipt of a mined transaction. Note that the
	// transaction may not be included in the current canonical chain even if a receipt
	// exists.
	TransactionReceipt(ctx context.Context, txHash libcommon.Hash) (*types.Receipt, error)
}

type TransactionSender interface {
	SendTransaction(ctx context.Context, tx types.Transaction) error
}