feat: expose InitChain tx responses

gno.land/pkg/gnoland/app.go

@@ -157,6 +157,8 @@
 // InitChainer returns a function that can initialize the chain with genesis.
 func InitChainer(baseApp *sdk.BaseApp, acctKpr auth.AccountKeeperI, bankKpr bank.BankKeeperI, resHandler GenesisTxHandler) func(sdk.Context, abci.RequestInitChain) abci.ResponseInitChain {
 	return func(ctx sdk.Context, req abci.RequestInitChain) abci.ResponseInitChain {
+		txResponses := []abci.ResponseDeliverTx{}
+
 		if req.AppState != nil {
 			// Get genesis state
 			genState := req.AppState.(GnoGenesisState)
@@ -183,13 +185,20 @@
 					)
 				}
 
+				txResponses = append(txResponses, abci.ResponseDeliverTx{
+					ResponseBase: res.ResponseBase,
+					GasWanted:    res.GasWanted,
+					GasUsed:      res.GasUsed,
+				})
+
 				resHandler(ctx, tx, res)
 			}
 		}
 
 		// Done!
 		return abci.ResponseInitChain{
-			Validators: req.Validators,
+			Validators:  req.Validators,
+			TxResponses: txResponses,
 		}
 	}
 }

tm2/pkg/bft/abci/types/mock_application.go

@@ -0,0 +1,89 @@
+package abci
+
+type MockApplication struct {
+	BaseApplication
+	InfoFn       func(RequestInfo) ResponseInfo
+	SetOptionFn  func(RequestSetOption) ResponseSetOption
+	QueryFn      func(RequestQuery) ResponseQuery
+	CheckTxFn    func(RequestCheckTx) ResponseCheckTx
+	InitChainFn  func(RequestInitChain) ResponseInitChain
+	BeginBlockFn func(RequestBeginBlock) ResponseBeginBlock
+	DeliverTxFn  func(RequestDeliverTx) ResponseDeliverTx
+	EndBlockFn   func(RequestEndBlock) ResponseEndBlock
+	CommitFn     func() ResponseCommit
+	CloseFn      func() error
+}
+
+// Info/Query Connection
+func (app *MockApplication) Info(req RequestInfo) ResponseInfo {
+	if app.InfoFn != nil {
+		return app.InfoFn(req)
+	}
+	return ResponseInfo{}
+}
+
+func (app *MockApplication) SetOption(req RequestSetOption) ResponseSetOption {
+	if app.SetOptionFn != nil {
+		return app.SetOptionFn(req)
+	}
+	return ResponseSetOption{}
+}
+
+func (app *MockApplication) Query(req RequestQuery) ResponseQuery {
+	if app.QueryFn != nil {
+		return app.QueryFn(req)
+	}
+	return ResponseQuery{}
+}
+
+// Mempool Connection
+func (app *MockApplication) CheckTx(req RequestCheckTx) ResponseCheckTx {
+	if app.CheckTxFn != nil {
+		return app.CheckTxFn(req)
+	}
+	return ResponseCheckTx{}
+}
+
+// Consensus Connection
+func (app *MockApplication) InitChain(req RequestInitChain) ResponseInitChain {
+	if app.InitChainFn != nil {
+		return app.InitChainFn(req)
+	}
+	return ResponseInitChain{}
+}
+
+func (app *MockApplication) BeginBlock(req RequestBeginBlock) ResponseBeginBlock {
+	if app.BeginBlockFn != nil {
+		return app.BeginBlockFn(req)
+	}
+	return ResponseBeginBlock{}
+}
+
+func (app *MockApplication) DeliverTx(req RequestDeliverTx) ResponseDeliverTx {
+	if app.DeliverTxFn != nil {
+		return app.DeliverTxFn(req)
+	}
+	return ResponseDeliverTx{}
+}
+
+func (app *MockApplication) EndBlock(req RequestEndBlock) ResponseEndBlock {
+	if app.EndBlockFn != nil {
+		return app.EndBlockFn(req)
+	}
+	return ResponseEndBlock{}
+}
+
+func (app *MockApplication) Commit() ResponseCommit {
+	if app.CommitFn != nil {
+		return app.CommitFn()
+	}
+	return ResponseCommit{}
+}
+
+// Cleanup
+func (app *MockApplication) Close() error {
+	if app.CloseFn != nil {
+		return app.CloseFn()
+	}
+	return nil
+}

tm2/pkg/bft/abci/types/types.go

@@ -159,6 +159,7 @@ type ResponseInitChain struct {
 	ResponseBase
 	ConsensusParams *ConsensusParams
 	Validators      []ValidatorUpdate
+	TxResponses     []ResponseDeliverTx
 }
 
 type ResponseQuery struct {

tm2/pkg/bft/consensus/replay.go

@@ -307,6 +307,13 @@ func (h *Handshaker) ReplayBlocks(
 			return nil, err
 		}
 
+		// Save the results by height
+		abciResponse := sm.NewABCIResponsesFromNum(len(res.TxResponses))
+		copy(abciResponse.DeliverTxs, res.TxResponses)
+		sm.SaveABCIResponses(h.stateDB, 0, abciResponse)
+
+		// NOTE: we don't save results by tx hash since the transactions are in the AppState opaque type
+
 		if stateBlockHeight == 0 { // we only update state when we are in initial state
 			// If the app returned validators or consensus params, update the state.
 			if len(res.Validators) > 0 {

tm2/pkg/bft/consensus/replay_test.go

@@ -1131,7 +1131,15 @@ func TestHandshakeUpdatesValidators(t *testing.T) {
 
 	val, _ := types.RandValidator(true, 10)
 	vals := types.NewValidatorSet([]*types.Validator{val})
-	app := &initChainApp{vals: vals.ABCIValidatorUpdates()}
+	appVals := vals.ABCIValidatorUpdates()
+	// returns the vals on InitChain
+	app := &abci.MockApplication{
+		InitChainFn: func(req abci.RequestInitChain) abci.ResponseInitChain {
+			return abci.ResponseInitChain{
+				Validators: appVals,
+			}
+		},
+	}
 	clientCreator := proxy.NewLocalClientCreator(app)
 
 	config, genesisFile := ResetConfig("handshake_test_")
@@ -1144,13 +1152,11 @@ func TestHandshakeUpdatesValidators(t *testing.T) {
 	genDoc, _ := sm.MakeGenesisDocFromFile(genesisFile)
 	handshaker := NewHandshaker(stateDB, state, store, genDoc)
 	proxyApp := appconn.NewAppConns(clientCreator)
-	if err := proxyApp.Start(); err != nil {
-		t.Fatalf("Error starting proxy app connections: %v", err)
-	}
-	defer proxyApp.Stop()
-	if err := handshaker.Handshake(proxyApp); err != nil {
-		t.Fatalf("Error on abci handshake: %v", err)
-	}
+	err := proxyApp.Start()
+	require.NoError(t, err, "Error starting proxy app connections")
+	defer func() { err := proxyApp.Stop(); require.NoError(t, err) }()
+	err = handshaker.Handshake(proxyApp)
+	require.NoError(t, err, "Error on abci handshake")
 
 	// reload the state, check the validator set was updated
 	state = sm.LoadState(stateDB)
@@ -1161,14 +1167,36 @@ func TestHandshakeUpdatesValidators(t *testing.T) {
 	assert.Equal(t, newValAddr, expectValAddr)
 }
 
-// returns the vals on InitChain
-type initChainApp struct {
-	abci.BaseApplication
-	vals []abci.ValidatorUpdate
-}
+func TestHandshakeGenesisResponseDeliverTx(t *testing.T) {
+	t.Parallel()
 
-func (ica *initChainApp) InitChain(req abci.RequestInitChain) abci.ResponseInitChain {
-	return abci.ResponseInitChain{
-		Validators: ica.vals,
+	const numInitResponses = 42
+
+	app := &abci.MockApplication{
+		InitChainFn: func(req abci.RequestInitChain) abci.ResponseInitChain {
+			return abci.ResponseInitChain{
+				TxResponses: make([]abci.ResponseDeliverTx, numInitResponses),
+			}
+		},
 	}
+	clientCreator := proxy.NewLocalClientCreator(app)
+
+	config, genesisFile := ResetConfig("handshake_test_")
+	defer os.RemoveAll(config.RootDir)
+	stateDB, state, store := makeStateAndStore(config, genesisFile, "v0.0.0-test")
+
+	// now start the app using the handshake - it should sync
+	genDoc, _ := sm.MakeGenesisDocFromFile(genesisFile)
+	handshaker := NewHandshaker(stateDB, state, store, genDoc)
+	proxyApp := appconn.NewAppConns(clientCreator)
+	err := proxyApp.Start()
+	require.NoError(t, err, "Error starting proxy app connections")
+	defer func() { err := proxyApp.Stop(); require.NoError(t, err) }()
+	err = handshaker.Handshake(proxyApp)
+	require.NoError(t, err, "Error on abci handshake")
+
+	// check that the genesis transaction results are saved
+	res, err := sm.LoadABCIResponses(stateDB, 0)
+	require.NoError(t, err, "Failed to load genesis ABCI responses")
+	assert.Len(t, res.DeliverTxs, numInitResponses)
 }

tm2/pkg/bft/rpc/core/blocks.go

@@ -236,7 +236,7 @@
 // ```
 func Block(ctx *rpctypes.Context, heightPtr *int64) (*ctypes.ResultBlock, error) {
 	storeHeight := blockStore.Height()
-	height, err := getHeight(storeHeight, heightPtr)
+	height, err := getHeight(storeHeight, heightPtr, 1)
 	if err != nil {
 		return nil, err
 	}
@@ -327,7 +327,7 @@
 // ```
 func Commit(ctx *rpctypes.Context, heightPtr *int64) (*ctypes.ResultCommit, error) {
 	storeHeight := blockStore.Height()
-	height, err := getHeight(storeHeight, heightPtr)
+	height, err := getHeight(storeHeight, heightPtr, 1)
 	if err != nil {
 		return nil, err
 	}
@@ -400,7 +400,7 @@
 // ```
 func BlockResults(ctx *rpctypes.Context, heightPtr *int64) (*ctypes.ResultBlockResults, error) {
 	storeHeight := blockStore.Height()
-	height, err := getHeight(storeHeight, heightPtr)
+	height, err := getHeight(storeHeight, heightPtr, 0)
 	if err != nil {
 		return nil, err
 	}
@@ -417,11 +417,11 @@
 	return res, nil
 }
 
-func getHeight(currentHeight int64, heightPtr *int64) (int64, error) {
+func getHeight(currentHeight int64, heightPtr *int64, min int64) (int64, error) {
 	if heightPtr != nil {
 		height := *heightPtr
-		if height <= 0 {
-			return 0, fmt.Errorf("height must be greater than 0")
+		if height < min {
+			return 0, fmt.Errorf("height must be greater than or equal to %d", min)
 		}
 		if height > currentHeight {
 			return 0, fmt.Errorf("height must be less than or equal to the current blockchain height")

tm2/pkg/bft/rpc/core/consensus.go

@@ -58,7 +58,7 @@
 	// The latest validator that we know is the
 	// NextValidator of the last block.
 	height := consensusState.GetState().LastBlockHeight + 1
-	height, err := getHeight(height, heightPtr)
+	height, err := getHeight(height, heightPtr, 1)
 	if err != nil {
 		return nil, err
 	}
@@ -344,7 +344,7 @@
 // ```
 func ConsensusParams(ctx *rpctypes.Context, heightPtr *int64) (*ctypes.ResultConsensusParams, error) {
 	height := consensusState.GetState().LastBlockHeight + 1
-	height, err := getHeight(height, heightPtr)
+	height, err := getHeight(height, heightPtr, 1)
 	if err != nil {
 		return nil, err
 	}

tm2/pkg/bft/rpc/core/tx.go

@@ -19,7 +19,7 @@ func Tx(_ *rpctypes.Context, hash []byte) (*ctypes.ResultTx, error) {
 	}
 
 	// Sanity check the block height
-	height, err := getHeight(blockStore.Height(), &resultIndex.BlockNum)
+	height, err := getHeight(blockStore.Height(), &resultIndex.BlockNum, 1)
 	if err != nil {
 		return nil, err
 	}

tm2/pkg/bft/state/execution.go

@@ -106,10 +106,10 @@ func (blockExec *BlockExecutor) ApplyBlock(state State, blockID types.BlockID, b
 
 	fail.Fail() // XXX
 
-	// Save the results before we commit.
-	saveABCIResponses(blockExec.db, block.Height, abciResponses)
+	// Save the results by height
+	SaveABCIResponses(blockExec.db, block.Height, abciResponses)
 
-	// Save the transaction results
+	// Save the results by tx hash
 	for index, tx := range block.Txs {
 		saveTxResultIndex(
 			blockExec.db,

tm2/pkg/bft/state/export_test.go

@@ -42,12 +42,6 @@ func CalcValidatorsKey(height int64) []byte {
 	return calcValidatorsKey(height)
 }
 
-// SaveABCIResponses is an alias for the private saveABCIResponses method in
-// store.go, exported exclusively and explicitly for testing.
-func SaveABCIResponses(db dbm.DB, height int64, abciResponses *ABCIResponses) {
-	saveABCIResponses(db, height, abciResponses)
-}
-
 // SaveConsensusParamsInfo is an alias for the private saveConsensusParamsInfo
 // method in store.go, exported exclusively and explicitly for testing.
 func SaveConsensusParamsInfo(db dbm.DB, nextHeight, changeHeight int64, params abci.ConsensusParams) {

tm2/pkg/bft/state/store.go

@@ -9,6 +9,7 @@ import (
 	"github.com/gnolang/gno/tm2/pkg/bft/types"
 	dbm "github.com/gnolang/gno/tm2/pkg/db"
 	osm "github.com/gnolang/gno/tm2/pkg/os"
+	"golang.org/x/exp/constraints"
 )
 
 const (
@@ -131,8 +132,13 @@ type ABCIResponses struct {
 
 // NewABCIResponses returns a new ABCIResponses
 func NewABCIResponses(block *types.Block) *ABCIResponses {
-	resDeliverTxs := make([]abci.ResponseDeliverTx, block.NumTxs)
-	if block.NumTxs == 0 {
+	return NewABCIResponsesFromNum(block.NumTxs)
+}
+
+// NewABCIResponsesFromNum returns a new ABCIResponses with a set number of txs
+func NewABCIResponsesFromNum[N constraints.Integer](numTxs N) *ABCIResponses {
+	resDeliverTxs := make([]abci.ResponseDeliverTx, numTxs)
+	if numTxs == 0 {
 		// This makes Amino encoding/decoding consistent.
 		resDeliverTxs = nil
 	}
@@ -175,7 +181,7 @@ func LoadABCIResponses(db dbm.DB, height int64) (*ABCIResponses, error) {
 // SaveABCIResponses persists the ABCIResponses to the database.
 // This is useful in case we crash after app.Commit and before s.Save().
 // Responses are indexed by height so they can also be loaded later to produce Merkle proofs.
-func saveABCIResponses(db dbm.DB, height int64, abciResponses *ABCIResponses) {
+func SaveABCIResponses(db dbm.DB, height int64, abciResponses *ABCIResponses) {
 	db.Set(CalcABCIResponsesKey(height), abciResponses.Bytes())
 }