add events and logs

Author: arajasek

app/app.go

@@ -87,7 +87,6 @@ import (
 	upgradeclient "github.com/cosmos/cosmos-sdk/x/upgrade/client"
 	upgradekeeper "github.com/cosmos/cosmos-sdk/x/upgrade/keeper"
 	upgradetypes "github.com/cosmos/cosmos-sdk/x/upgrade/types"
-	"github.com/ethereum/go-ethereum/core"
 	ethtypes "github.com/ethereum/go-ethereum/core/types"
 	"github.com/ethereum/go-ethereum/core/vm"
 	"github.com/ethereum/go-ethereum/ethclient"
@@ -1334,6 +1333,7 @@ func (app *App) ProcessTxsSynchronousGiga(ctx sdk.Context, txs [][]byte, typedTx
 
 	txResults := make([]*abci.ExecTxResult, len(txs))
 	for i, tx := range txs {
+		fmt.Println("GIGA WORKING tx", absoluteTxIndices[i])
 		ctx = ctx.WithTxIndex(absoluteTxIndices[i])
 		evmMsg := app.GetEVMMsg(typedTxs[i])
 		// If not an EVM tx, fall back to v2 processing
@@ -1691,7 +1691,14 @@ func (app *App) executeEVMTxWithGigaExecutor(ctx sdk.Context, txIndex int, msg *
 		}, nil
 	}
 
+	// Prepare context for EVM transaction (set infinite gas meter like original flow)
+	// Use a fresh EventManager to collect ALL events during this transaction
+	ctx = ctx.WithGasMeter(sdk.NewInfiniteGasMeterWithMultiplier(ctx))
+	ctx = ctx.WithTxIndex(txIndex)
+	ctx = ctx.WithEventManager(sdk.NewEventManager())
+
 	// Associate the address if not already associated (same as EVMPreprocessDecorator)
+	// This emits address_associated event
 	if _, isAssociated := app.EvmKeeper.GetEVMAddress(ctx, seiAddr); !isAssociated {
 		associateHelper := helpers.NewAssociationHelper(&app.EvmKeeper, app.BankKeeper, &app.AccountKeeper)
 		if err := associateHelper.AssociateAddresses(ctx, seiAddr, sender, pubkey); err != nil {
@@ -1702,11 +1709,7 @@ func (app *App) executeEVMTxWithGigaExecutor(ctx sdk.Context, txIndex int, msg *
 		}
 	}
 
-	// Prepare context for EVM transaction (set infinite gas meter like original flow)
-	ctx = ctx.WithGasMeter(sdk.NewInfiniteGasMeterWithMultiplier(ctx))
-	ctx = ctx.WithTxIndex(txIndex)
-
-	// Create state DB for this transaction
+	// Create state DB for this transaction (uses ctx with our EventManager)
 	stateDB := evmstate.NewDBImpl(ctx, &app.EvmKeeper, false)
 	defer stateDB.Cleanup()
 
@@ -1729,7 +1732,8 @@ func (app *App) executeEVMTxWithGigaExecutor(ctx sdk.Context, txIndex int, msg *
 	// Create Giga executor VM
 	gigaExecutor := gigaexecutor.NewGethExecutor(*blockCtx, stateDB, cfg, vm.Config{}, gigaprecompiles.AllCustomPrecompilesFailFast)
 
-	// Execute the transaction through giga VM
+	// Execute the transaction with feeCharged=false
+	// This allows BuyGas to emit coin_spent events during execution
 	execResult, execErr := gigaExecutor.ExecuteTransaction(ethTx, sender, app.EvmKeeper.GetBaseFee(ctx), &gp)
 	if execErr != nil {
 		return &abci.ExecTxResult{
@@ -1760,18 +1764,7 @@ func (app *App) executeEVMTxWithGigaExecutor(ctx sdk.Context, txIndex int, msg *
 	}
 
 	// Create core.Message from ethTx for WriteReceipt
-	// WriteReceipt needs msg for GasPrice, To, From, Data, Nonce fields
-	evmMsg := &core.Message{
-		Nonce:     ethTx.Nonce(),
-		GasLimit:  ethTx.Gas(),
-		GasPrice:  ethTx.GasPrice(),
-		GasFeeCap: ethTx.GasFeeCap(),
-		GasTipCap: ethTx.GasTipCap(),
-		To:        ethTx.To(),
-		Value:     ethTx.Value(),
-		Data:      ethTx.Data(),
-		From:      sender,
-	}
+	evmMsg := app.EvmKeeper.GetEVMMessage(ctx, ethTx, sender)
 	receipt, rerr := app.EvmKeeper.WriteReceipt(ctx, stateDB, evmMsg, uint32(ethTx.Type()), ethTx.Hash(), execResult.UsedGas, vmError)
 	if rerr != nil {
 		return &abci.ExecTxResult{
@@ -1799,12 +1792,30 @@ func (app *App) executeEVMTxWithGigaExecutor(ctx sdk.Context, txIndex int, msg *
 	// isn't committed, so we pass the receipt through the response for later processing.
 	receiptBytes, _ := receipt.Marshal()
 
+	// Collect all events from the EventManager
+	// In V2, events are structured as: anteEvents + [message:action + msgResult.Events]
+	// For Giga, we collect all events and append message:action at the end
+	// This ensures all execution events are captured properly
+	eventMsgName := sdk.MsgTypeURL(msg)
+	allEvents := ctx.EventManager().Events()
+	
+	// Append message:action event at the end
+	allEvents = allEvents.AppendEvents(sdk.Events{
+		sdk.NewEvent(sdk.EventTypeMessage, sdk.NewAttribute(sdk.AttributeKeyAction, eventMsgName)),
+	})
+
+	// Create message log (same format as RunMsgs)
+	msgLogs := sdk.ABCIMessageLogs{
+		sdk.NewABCIMessageLog(uint32(0), vmError, allEvents),
+	}
+
 	//nolint:gosec // G115: safe, UsedGas won't exceed int64 max
 	return &abci.ExecTxResult{
 		Code:    code,
 		Data:    receiptBytes,
 		GasUsed: int64(execResult.UsedGas),
-		Log:     vmError,
+		Log:     strings.TrimSpace(msgLogs.String()),
+		Events:  sdk.MarkEventsToIndex(allEvents.ToABCIEvents(), app.IndexEvents),
 		EvmTxInfo: &abci.EvmTxInfo{
 			TxHash:  ethTx.Hash().Hex(),
 			VmError: vmError,

giga/executor/executor.go

@@ -33,12 +33,20 @@ func NewGethExecutor(blockCtx vm.BlockContext, stateDB vm.StateDB, chainConfig *
 }
 
 func (e *Executor) ExecuteTransaction(tx *types.Transaction, sender common.Address, baseFee *big.Int, gasPool *core.GasPool) (*core.ExecutionResult, error) {
+	return e.ExecuteTransactionWithOptions(tx, sender, baseFee, gasPool, false, true)
+}
+
+// ExecuteTransactionWithOptions executes a transaction with explicit control over fee and nonce handling.
+// - feeCharged: if true, assumes gas fee was already charged (skips BuyGas). Use true to match V2 behavior.
+// - shouldIncrementNonce: if true, increments the sender's nonce during execution.
+func (e *Executor) ExecuteTransactionWithOptions(tx *types.Transaction, sender common.Address, baseFee *big.Int, gasPool *core.GasPool, feeCharged bool, shouldIncrementNonce bool) (*core.ExecutionResult, error) {
 	message, err := core.TransactionToMessage(tx, &internal.Signer{From: sender}, baseFee)
 	if err != nil {
 		return nil, err
 	}
 
-	executionResult, err := core.ApplyMessage(e.evm, message, gasPool)
+	e.evm.SetTxContext(core.NewEVMTxContext(message))
+	executionResult, err := core.NewStateTransition(e.evm, message, gasPool, feeCharged, shouldIncrementNonce).Execute()
 	if err != nil {
 		return nil, err
 	}