cache typed txs

Author: codchen

app/app.go

@@ -1602,6 +1602,7 @@ func (app *App) ProcessBlock(ctx sdk.Context, txs [][]byte, req BlockProcessRequ
 	evmTxs := make([]*evmtypes.MsgEVMTransaction, len(txs)) // nil for non-EVM txs
 	txResults := make([]*abci.ExecTxResult, len(txs))
 	typedTxs := app.DecodeTransactionsConcurrently(ctx, txs)
+	app.EvmKeeper.SetTypedTxs(req.GetHeight(), typedTxs)
 
 	prioritizedTxs, otherTxs, prioritizedTypedTxs, otherTypedTxs, prioritizedIndices, otherIndices := app.PartitionPrioritizedTxs(ctx, txs, typedTxs)
 

evmrpc/utils.go

@@ -199,10 +199,17 @@ func filterTransactions(
 	startOfBlockNonce := make(map[string]uint64)
 	latestCtx := ctxProvider(LatestCtxHeight)
 	prevCtx := ctxProvider(block.Block.Height - 1)
+	typedTxs := k.GetTypedTxs(block.Block.Height)
 	for i, tx := range block.Block.Data.Txs {
-		sdkTx, err := txDecoder(tx)
-		if err != nil {
-			continue
+		var sdkTx sdk.Tx
+		if typedTxs != nil {
+			sdkTx = typedTxs[i]
+		} else {
+			sdkTx_, err := txDecoder(tx)
+			if err != nil {
+				continue
+			}
+			sdkTx = sdkTx_
 		}
 		for _, msg := range sdkTx.GetMsgs() {
 			switch m := msg.(type) {

x/evm/keeper/keeper.go

@@ -87,6 +87,8 @@ type Keeper struct {
 	customPrecompiles       map[common.Address]precompiles.VersionedPrecompiles
 	latestCustomPrecompiles map[common.Address]vm.PrecompiledContract
 	latestUpgrade           string
+
+	typedTxs map[int64][]sdk.Tx
 }
 
 type AddressNoncePair struct {
@@ -606,6 +608,17 @@ func (k *Keeper) getReplayBlockCtx(ctx sdk.Context) (*vm.BlockContext, error) {
 	}, nil
 }
 
+func (k *Keeper) SetTypedTxs(height int64, txs []sdk.Tx) {
+	if _, ok := k.typedTxs[height-1000]; ok {
+		delete(k.typedTxs, height-1000)
+	}
+	k.typedTxs[height] = txs
+}
+
+func (k *Keeper) GetTypedTxs(height int64) []sdk.Tx {
+	return k.typedTxs[height]
+}
+
 func uint64Cmp(a, b uint64) int {
 	if a < b {
 		return -1