keeper

package
v0.4.9-rc9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 5, 2024 License: Apache-2.0 Imports: 58 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckSenderBalance

func CheckSenderBalance(
	balance sdkmath.Int,
	txData txs.TxData,
) error

CheckSenderBalance validates that the tx cost value is positive and that the sender has enough funds to pay for the fees and value of the transaction.

func GasToRefund

func GasToRefund(availableRefund, gasConsumed, refundQuotient uint64) uint64

GasToRefund calculates the amount of gas the states machine should refund to the sender. It is capped by the refund quotient value(do not pass 0 to refundQuotient).

func GetProposerAddress

func GetProposerAddress(ctx cosmos.Context, proposerAddress cosmos.ConsAddress) cosmos.ConsAddress

GetProposerAddress returns current block proposer's address when provided proposer address is empty.

func VerifyFee

func VerifyFee(
	txData txs.TxData,
	denom string,
	baseFee *big.Int,
	homestead, istanbul, isCheckTx bool,
) (cosmos.Coins, error)

VerifyFee is used to return the fee for the given transaction data in cosmos.Coins. It checks that the gas limit is not reached, the gas limit is higher than the intrinsic gas and that the base fee is higher than the gas fee cap.

Types

type Keeper

type Keeper struct {

	// store the block context, this will be fresh every block.
	BlockContext *artvmtype.EthBlockContext

	// cache of aspect sig
	VerifySigCache *sync.Map
	// contains filtered or unexported fields
}

Keeper grants access to the EVM module states and implements the go-ethereum StateDB interface.

func NewKeeper

func NewKeeper(
	cdc codec.BinaryCodec,
	storeKey, transientKey storetypes.StoreKey,
	authority cosmos.AccAddress,
	accountKeeper types.AccountKeeper,
	bankKeeper types.BankKeeper,
	stakingKeeper types.StakingKeeper,
	feeKeeper types.FeeKeeper,
	aspectProvider *provider.ArtelaProvider,
	tracer string,
	subSpace paramsmodule.Subspace,
	app *baseapp.BaseApp,
	logger log.Logger,
) *Keeper

NewKeeper generates new evm module keeper

func (Keeper) Account

Account implements the Query/StateAccount gRPC method

func (Keeper) AddTransientGasUsed

func (k Keeper) AddTransientGasUsed(ctx cosmos.Context, gasUsed uint64) (uint64, error)

AddTransientGasUsed accumulate gas used by each eth msg included in current cosmos txs.

func (*Keeper) ApplyMessage

func (k *Keeper) ApplyMessage(ctx cosmos.Context, msg *core.Message, tracer vm.EVMLogger, commit bool) (*txs.MsgEthereumTxResponse, error)

ApplyMessage calls ApplyMessageWithConfig with an empty TxConfig.

func (*Keeper) ApplyMessageWithConfig

func (k *Keeper) ApplyMessageWithConfig(ctx cosmos.Context,
	aspectCtx *artelatypes.AspectRuntimeContext,
	msg *core.Message,
	tracer vm.EVMLogger,
	commit bool,
	cfg *states.EVMConfig,
	txConfig states.TxConfig,
	isCustomVerification bool,
) (*txs.MsgEthereumTxResponse, error)

ApplyMessageWithConfig computes the new states by applying the given message against the existing states. If the message fails, the VM execution error with the reason will be returned to the client and the txs won't be committed to the store.

Reverted states

The snapshot and rollback are supported by the `states.StateDB`.

Different Callers

It's called in three scenarios: 1. `ApplyTransaction`, in the txs processing flow. 2. `EthCall/EthEstimateGas` grpc query handler. 3. Called by other native modules directly.

PreChecks and Preprocessing

All relevant states transition preChecks for the MsgEthereumTx are performed on the AnteHandler, prior to running the txs against the states. The PreChecks run are the following:

1. the nonce of the message caller is correct 2. caller has enough balance to cover txs fee(gasLimit * gasPrice) 3. the amount of gas required is available in the block 4. the purchased gas is enough to cover intrinsic usage 5. there is no overflow when calculating intrinsic gas 6. caller has enough balance to cover asset transfer for **topmost** call

The preprocessing steps performed by the AnteHandler are:

1. set up the initial access list (if fork > Berlin)

Tracer parameter

It should be a `vm.Tracer` object or nil, if pass `nil`, it'll create a default one based on keeper options.

Commit parameter

If commit is true, the `StateDB` will be committed, otherwise discarded.

func (*Keeper) ApplyTransaction

func (k *Keeper) ApplyTransaction(ctx cosmos.Context, tx *ethereum.Transaction) (*txs.MsgEthereumTxResponse, error)

ApplyTransaction runs and attempts to perform a states transition with the given txs (i.e Message), that will only be persisted (committed) to the underlying KVStore if the txs does not fail.

Gas tracking

Ethereum consumes gas according to the EVM opcodes instead of general reads and writes to store. Because of this, the states transition needs to ignore the SDK gas consumption mechanism defined by the GasKVStore and instead consume the amount of gas used by the VM execution. The amount of gas used is tracked by the EVM and returned in the execution result.

Prior to the execution, the starting txs gas meter is saved and replaced with an infinite gas meter in a new context in order to ignore the SDK gas consumption config values (read, write, has, delete). After the execution, the gas used from the message execution will be added to the starting gas consumed, taking into consideration the amount of gas returned. Finally, the context is updated with the EVM gas consumed value prior to returning.

For relevant discussion see: https://github.com/cosmos/cosmos-sdk/discussions/9072

func (Keeper) Balance

Balance implements the Query/Balance gRPC method

func (Keeper) BaseFee

BaseFee implements the Query/BaseFee gRPC method

func (Keeper) ChainID

func (k Keeper) ChainID() *big.Int

ChainID returns the EIP155 chain ID for the EVM context

func (Keeper) Code

Code implements the Query/Code gRPC method

func (*Keeper) DeductTxCostsFromUserBalance

func (k *Keeper) DeductTxCostsFromUserBalance(
	ctx cosmos.Context,
	fees cosmos.Coins,
	from common.Address,
) error

DeductTxCostsFromUserBalance deducts the fees from the user balance. Returns an error if the specified sender address does not exist or the account balance is not sufficient.

func (*Keeper) DeleteAccount

func (k *Keeper) DeleteAccount(ctx cosmos.Context, addr common.Address) error

DeleteAccount handles contract's suicide call: - clear balance - remove code - remove states - remove auth account

func (*Keeper) EVMConfig

func (k *Keeper) EVMConfig(ctx cosmos.Context, proposerAddress cosmos.ConsAddress, chainID *big.Int) (*states.EVMConfig, error)

EVMConfig creates the EVMConfig based on current states

func (*Keeper) EVMConfigFromCtx

func (k *Keeper) EVMConfigFromCtx(ctx cosmos.Context) (*states.EVMConfig, error)

func (Keeper) EmitBlockBloomEvent

func (k Keeper) EmitBlockBloomEvent(ctx cosmos.Context, bloom ethereum.Bloom)

EmitBlockBloomEvent emit block bloom events

func (Keeper) EstimateGas

func (k Keeper) EstimateGas(c context.Context, req *txs.EthCallRequest) (*txs.EstimateGasResponse, error)

EstimateGas implements eth_estimateGas rpc api.

func (Keeper) EthCall

EthCall implements eth_call rpc api.

func (*Keeper) EthereumTx

func (k *Keeper) EthereumTx(goCtx context.Context, msg *txs.MsgEthereumTx) (*txs.MsgEthereumTxResponse, error)

EthereumTx implements the gRPC MsgServer interface. It receives a txs which is then executed (i.e applied) against the go-ethereum EVM. The provided SDK Context is set to the Keeper so that it can implements and call the StateDB methods without receiving it as a function parameter.

func (*Keeper) ForEachStorage

func (k *Keeper) ForEachStorage(ctx cosmos.Context, addr common.Address, cb func(key, value common.Hash) bool)

ForEachStorage iterate contract storage, callback return false to break early

func (*Keeper) GetAccount

func (k *Keeper) GetAccount(ctx cosmos.Context, addr common.Address) *states.StateAccount

GetAccount returns nil if account is not exist, returns error if it's not `EthAccountI`

func (*Keeper) GetAccountOrEmpty

func (k *Keeper) GetAccountOrEmpty(ctx cosmos.Context, addr common.Address) states.StateAccount

GetAccountOrEmpty returns empty account if not exist, returns error if it's not `EthAccount`

func (Keeper) GetAccountStorage

func (k Keeper) GetAccountStorage(ctx cosmos.Context, address common.Address) support.Storage

GetAccountStorage return states storage associated with an account

func (*Keeper) GetAccountWithoutBalance

func (k *Keeper) GetAccountWithoutBalance(ctx cosmos.Context, addr common.Address) *states.StateAccount

GetAccountWithoutBalance load nonce and codeHash without balance, more efficient in cases where balance is not needed.

func (Keeper) GetAspectContext

func (k Keeper) GetAspectContext(ctx context.Context, address common.Address, key string) ([]byte, error)

func (Keeper) GetAuthority

func (k Keeper) GetAuthority() cosmos.AccAddress

GetAuthority returns the x/evm module authority address

func (*Keeper) GetBalance

func (k *Keeper) GetBalance(ctx cosmos.Context, addr common.Address) *big.Int

GetBalance load account's balance of gas token

func (Keeper) GetBaseFee

func (k Keeper) GetBaseFee(ctx cosmos.Context, ethCfg *params.ChainConfig) *big.Int

GetBaseFee returns current base fee, return values: - `nil`: london hardfork not enabled. - `0`: london hardfork enabled but fee is not enabled. - `n`: both london hardfork and fee are enabled.

func (Keeper) GetBlockBloomTransient

func (k Keeper) GetBlockBloomTransient(ctx cosmos.Context) *big.Int

GetBlockBloomTransient returns bloom bytes for the current block height

func (Keeper) GetBlockContext

func (k Keeper) GetBlockContext() *artvmtype.EthBlockContext

func (*Keeper) GetChainConfig

func (k *Keeper) GetChainConfig(ctx cosmos.Context) *params.ChainConfig

func (Keeper) GetClientContext

func (k Keeper) GetClientContext() client.Context

func (*Keeper) GetCode

func (k *Keeper) GetCode(ctx cosmos.Context, codeHash common.Hash) []byte

GetCode loads contract code from database, implements `states.Keeper` interface.

func (*Keeper) GetEthIntrinsicGas

func (k *Keeper) GetEthIntrinsicGas(ctx cosmos.Context, msg *core.Message, cfg *params.ChainConfig, isContractCreation bool, isCustomVerification bool) (uint64, error)

GetEthIntrinsicGas returns the intrinsic gas cost for the transaction.

func (Keeper) GetHashFn

func (k Keeper) GetHashFn(ctx cosmos.Context) vm.GetHashFunc

GetHashFn implements vm.GetHashFunc for Artela. It handles 3 cases:

  1. The requested height matches the current height from context (and thus same epoch number)
  2. The requested height is from a previous height from the same chain epoch
  3. The requested height is from a height greater than the latest one

func (Keeper) GetLegacyParams

func (k Keeper) GetLegacyParams(ctx cosmos.Context) support.Params

GetLegacyParams returns param set for version before migrate

func (Keeper) GetLogSizeTransient

func (k Keeper) GetLogSizeTransient(ctx cosmos.Context) uint64

GetLogSizeTransient returns EVM log index on the current block.

func (Keeper) GetMinGasMultiplier

func (k Keeper) GetMinGasMultiplier(ctx cosmos.Context) cosmos.Dec

GetMinGasMultiplier returns the MinGasMultiplier param from the fee market module

func (*Keeper) GetNonce

func (k *Keeper) GetNonce(ctx cosmos.Context, addr common.Address) uint64

GetNonce returns the sequence number of an account, returns 0 if not exists.

func (Keeper) GetParams

func (k Keeper) GetParams(ctx cosmos.Context) (params support.Params)

GetParams returns the total set of evm parameters.

func (Keeper) GetProposerAddress

func (k Keeper) GetProposerAddress(ctx cosmos.Context, proposerAddress cosmos.ConsAddress) (common.Address, error)

GetProposerAddress returns the block proposer's validator operator address.

func (Keeper) GetSender

func (*Keeper) GetState

func (k *Keeper) GetState(ctx cosmos.Context, addr common.Address, key common.Hash) common.Hash

GetState loads contract states from database, implements `states.Keeper` interface.

func (Keeper) GetTransientGasUsed

func (k Keeper) GetTransientGasUsed(ctx cosmos.Context) uint64

GetTransientGasUsed returns the gas used by current cosmos txs.

func (Keeper) GetTxIndexTransient

func (k Keeper) GetTxIndexTransient(ctx cosmos.Context) uint64

GetTxIndexTransient returns EVM txs index on the current block.

func (Keeper) IsCommit

func (k Keeper) IsCommit(ctx context.Context) bool

func (Keeper) JITSenderAspectByContext

func (k Keeper) JITSenderAspectByContext(ctx context.Context, userOpHash common.Hash) (common.Address, error)

func (Keeper) Logger

func (k Keeper) Logger(ctx cosmos.Context) log.Logger

Logger returns a module-specific logger.

func (*Keeper) MakeSigner

func (k *Keeper) MakeSigner(ctx cosmos.Context, tx *ethereum.Transaction, config *params.ChainConfig, blockNumber *big.Int, blockTime uint64) ethereum.Signer

func (*Keeper) NewEVM

func (k *Keeper) NewEVM(
	ctx cosmos.Context,
	msg *core.Message,
	cfg *states.EVMConfig,
	tracer vm.EVMLogger,
	stateDB vm.StateDB,
) *vm.EVM

NewEVM generates a go-ethereum VM from the provided Message fields and the chain parameters (ChainConfig and module Params). It additionally sets the validator operator address as the coinbase address to make it available for the COINBASE opcode, even though there is no beneficiary of the coinbase txs (since we're not mining).

func (Keeper) Params

Params implements the Query/Params gRPC method

func (*Keeper) RefundGas

func (k *Keeper) RefundGas(ctx cosmos.Context, msg *core.Message, leftoverGas uint64, denom string) error

RefundGas transfers the leftover gas to the sender of the message, caped to half of the total gas consumed in the transaction. Additionally, the function sets the total gas consumed to the value returned by the EVM execution, thus ignoring the previous intrinsic gas consumed during in the AnteHandler.

func (*Keeper) ResetGasMeterAndConsumeGas

func (k *Keeper) ResetGasMeterAndConsumeGas(ctx cosmos.Context, gasUsed uint64)

ResetGasMeterAndConsumeGas reset first the gas meter consumed value to zero and set it back to the new value 'gasUsed'

func (Keeper) ResetTransientGasUsed

func (k Keeper) ResetTransientGasUsed(ctx cosmos.Context)

ResetTransientGasUsed reset gas used to prepare for execution of current cosmos txs, called in ante handler.

func (*Keeper) SetAccount

func (k *Keeper) SetAccount(ctx cosmos.Context, addr common.Address, account states.StateAccount) error

SetAccount updates nonce/balance/codeHash together.

func (Keeper) SetAspectContext

func (k Keeper) SetAspectContext(ctx context.Context, address common.Address, key string, value []byte) error

func (*Keeper) SetBalance

func (k *Keeper) SetBalance(ctx cosmos.Context, addr common.Address, amount *big.Int) error

SetBalance update account's balance, compare with current balance first, then decide to mint or burn.

func (Keeper) SetBlockBloomTransient

func (k Keeper) SetBlockBloomTransient(ctx cosmos.Context, bloom *big.Int)

SetBlockBloomTransient sets the given bloom bytes to the transient store. This value is reset on every block.

func (*Keeper) SetClientContext

func (k *Keeper) SetClientContext(ctx client.Context)

func (*Keeper) SetCode

func (k *Keeper) SetCode(ctx cosmos.Context, codeHash, code []byte)

SetCode set contract code, delete if code is empty.

func (Keeper) SetLogSizeTransient

func (k Keeper) SetLogSizeTransient(ctx cosmos.Context, logSize uint64)

SetLogSizeTransient fetches the current EVM log index from the transient store, increases its value by one and then sets the new index back to the transient store.

func (Keeper) SetParams

func (k Keeper) SetParams(ctx cosmos.Context, params support.Params) error

SetParams sets the EVM params each in their individual key for better get performance

func (*Keeper) SetState

func (k *Keeper) SetState(ctx cosmos.Context, addr common.Address, key common.Hash, value []byte)

SetState update contract storage, delete if value is empty.

func (Keeper) SetTransientGasUsed

func (k Keeper) SetTransientGasUsed(ctx cosmos.Context, gasUsed uint64)

SetTransientGasUsed sets the gas used by current cosmos txs.

func (Keeper) SetTxIndexTransient

func (k Keeper) SetTxIndexTransient(ctx cosmos.Context, index uint64)

SetTxIndexTransient set the index of processing txs

func (Keeper) Storage

Storage implements the Query/Storage gRPC method

func (Keeper) TraceBlock

TraceBlock configures a new tracer according to the provided configuration, and executes the given message in the provided environment for all the transactions in the queried block. The return value will be tracer dependent.

func (Keeper) TraceTx

TraceTx configures a new tracer according to the provided configuration, and executes the given message in the provided environment. The return value will be tracer dependent.

func (Keeper) Tracer

func (k Keeper) Tracer(ctx cosmos.Context, msg *core.Message, ethCfg *params.ChainConfig) vm.EVMLogger

Tracer return a default vm.Tracer based on current keeper states

func (*Keeper) TxConfig

func (k *Keeper) TxConfig(ctx cosmos.Context, txHash common.Hash, txType uint8) states.TxConfig

TxConfig loads `TxConfig` from current transient storage

func (*Keeper) UpdateParams

func (k *Keeper) UpdateParams(goCtx context.Context, req *txs.MsgUpdateParams) (*txs.MsgUpdateParamsResponse, error)

UpdateParams implements the gRPC MsgServer interface. When an UpdateParams proposal passes, it updates the module parameters. The update can only be performed if the requested authority is the Cosmos SDK governance module account.

func (Keeper) VMConfig

func (k Keeper) VMConfig(ctx cosmos.Context, _ *core.Message, cfg *states.EVMConfig, tracer vm.EVMLogger) vm.Config

VMConfig creates an EVM configuration from the debug setting and the extra EIPs enabled on the module parameters. The config support uses the default JumpTable from the EVM.

func (Keeper) ValidatorAccount

ValidatorAccount implements the Query/Balance gRPC method

func (*Keeper) VerifySig

func (k *Keeper) VerifySig(ctx cosmos.Context, tx *ethereum.Transaction) (common.Address, []byte, error)

func (Keeper) WithAspectContext

WithAspectContext creates the Aspect Context and establishes the link to the SDK context.

func (*Keeper) WithChainID

func (k *Keeper) WithChainID(chainId string)

WithChainID sets the chain id to the local variable in the keeper

type Migrator

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

Migrator is a struct for handling in-place store migrations.

func NewMigrator

func NewMigrator(keeper Keeper) Migrator

NewMigrator returns a new Migrator.

func (Migrator) Migrate5to6

func (m Migrator) Migrate5to6(ctx sdk.Context) error

Migrate5to6 migrates the store from consensus version 5 to 6

func (Migrator) Migrate6to7

func (m Migrator) Migrate6to7(ctx sdk.Context) error

Migrate6to7 migrates the store from consensus version 6 to 7

func (Migrator) Migrate7to8

func (m Migrator) Migrate7to8(ctx sdk.Context) error

Migrate7to8 migrates the store from consensus version 7 to 8

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL