feat(store): add rawlog in txstatus

consensus/replay_test.go

@@ -1224,7 +1224,7 @@ func (bs *mockBlockStore) LoadBlockMeta(height int64) *types.BlockMeta {
 func (bs *mockBlockStore) LoadBlockPart(height int64, index int) *types.Part { return nil }
 func (bs *mockBlockStore) SaveBlock(block *types.Block, blockParts *types.PartSet, seenCommit *types.Commit) {
 }
-func (bs *mockBlockStore) SaveTxInfo(block *types.Block, txResponseCode []uint32) error {
+func (bs *mockBlockStore) SaveTxInfo(block *types.Block, txResponseCode []uint32, logs []string) error {
 	return nil
 }
 func (bs *mockBlockStore) LoadTxInfo(hash []byte) *cmtstore.TxInfo { return &cmtstore.TxInfo{} }

proto/tendermint/store/types.proto

@@ -16,4 +16,7 @@ message TxInfo {
   // The response code of executing the tx. 0 means
   // successfully executed, all others are error codes.
   uint32 code     = 3;
+  // The unprocessed log output generated during
+  // the execution of a transaction.
+  string rawLog   = 4;
 }

rpc/core/blocks_test.go

@@ -301,7 +301,7 @@ func (mockBlockStore) LoadSeenCommit(height int64) *types.Commit         { retur
 func (mockBlockStore) PruneBlocks(height int64) (uint64, error)          { return 0, nil }
 func (mockBlockStore) SaveBlock(block *types.Block, blockParts *types.PartSet, seenCommit *types.Commit) {
 }
-func (mockBlockStore) SaveTxInfo(block *types.Block, txResponseCode []uint32) error {
+func (mockBlockStore) SaveTxInfo(block *types.Block, txResponseCodes []uint32, logs []string) error {
 	return nil
 }
 

state/execution.go

@@ -248,7 +248,8 @@ func (blockExec *BlockExecutor) ApplyBlock(
 	// for correct crash recovery
 	if blockExec.blockStore != nil {
 		respCodes := getResponseCodes(abciResponses.DeliverTxs)
-		if err := blockExec.blockStore.SaveTxInfo(block, respCodes); err != nil {
+		logs := getLogs(abciResponses.DeliverTxs)
+		if err := blockExec.blockStore.SaveTxInfo(block, respCodes, logs); err != nil {
 			return state, 0, err
 		}
 	}
@@ -684,3 +685,12 @@ func getResponseCodes(responses []*abci.ResponseDeliverTx) []uint32 {
 	}
 	return responseCodes
 }
+
+// getLogs gets logs from a list of ResponseDeliverTx.
+func getLogs(responses []*abci.ResponseDeliverTx) []string {
+	logs := make([]string, len(responses))
+	for i, response := range responses {
+		logs[i] = response.Log
+	}
+	return logs
+}

state/services.go

@@ -26,7 +26,7 @@ type BlockStore interface {
 	LoadBlock(height int64) *types.Block
 
 	SaveBlock(block *types.Block, blockParts *types.PartSet, seenCommit *types.Commit)
-	SaveTxInfo(block *types.Block, txResponseCode []uint32) error
+	SaveTxInfo(block *types.Block, txResponseCodes []uint32, logs []string) error
 
 	PruneBlocks(height int64) (uint64, error)
 

store/store.go

@@ -451,10 +451,13 @@ func (bs *BlockStore) SaveSeenCommit(height int64, seenCommit *types.Commit) err
 }
 
 // SaveTxInfo indexes the txs from the block with the given response codes from execution.
-func (bs *BlockStore) SaveTxInfo(block *types.Block, txResponseCodes []uint32) error {
+func (bs *BlockStore) SaveTxInfo(block *types.Block, txResponseCodes []uint32, logs []string) error {
 	if len(txResponseCodes) != len(block.Txs) {
 		return fmt.Errorf("txResponseCodes length mismatch with block txs length")
 	}
+	if len(logs) != len(block.Txs) {
+		return fmt.Errorf("logs length mismatch with block txs length")
+	}
 
 	// Create a new batch
 	batch := bs.db.NewBatch()
@@ -465,6 +468,7 @@ func (bs *BlockStore) SaveTxInfo(block *types.Block, txResponseCodes []uint32) e
 			Height: block.Height,
 			Index:  uint32(i),
 			Code:   txResponseCodes[i],
+			RawLog: logs[i],
 		}
 		txInfoBytes, err := proto.Marshal(&txInfo)
 		if err != nil {

store/store_test.go

@@ -384,6 +384,7 @@ func TestSaveTxInfo(t *testing.T) {
 
 	// Create 1000 blocks
 	txResponseCodes := make([]uint32, len(block.Txs))
+	logs := make([]string, len(block.Txs))
 	for h := int64(1); h <= 1000; h++ {
 		block := makeBlock(h, state, new(types.Commit))
 		partSet := block.MakePartSet(2)
@@ -395,13 +396,15 @@ func TestSaveTxInfo(t *testing.T) {
 			// If even set it to 0
 			if i%2 == 0 {
 				txResponseCodes[i] = 0
+				logs[i] = "success"
 			} else {
 				txResponseCodes[i] = 1
+				logs[i] = "failure"
 			}
 		}
 
 		// Save the tx info
-		err := blockStore.SaveTxInfo(block, txResponseCodes)
+		err := blockStore.SaveTxInfo(block, txResponseCodes, logs)
 		require.NoError(t, err)
 	}
 
@@ -414,6 +417,7 @@ func TestSaveTxInfo(t *testing.T) {
 			require.Equal(t, block.Height, txInfo.Height)
 			require.Equal(t, uint32(i), txInfo.Index)
 			require.Equal(t, txResponseCodes[i], txInfo.Code)
+			require.Equal(t, logs[i], txInfo.RawLog)
 		}
 	}
 
@@ -426,6 +430,7 @@ func TestSaveTxInfo(t *testing.T) {
 	require.Equal(t, txInfo.Height, int64(777))
 	require.Equal(t, uint32(1), txInfo.Code)
 	require.Equal(t, uint32(5), txInfo.Index)
+	require.Equal(t, "failure", txInfo.RawLog)
 }
 
 func TestLoadBaseMeta(t *testing.T) {
@@ -597,7 +602,7 @@ func TestPruneBlocksPrunesTxs(t *testing.T) {
 		partSet := block.MakePartSet(2)
 		seenCommit := makeTestCommit(h, cmttime.Now())
 		blockStore.SaveBlock(block, partSet, seenCommit)
-		err := blockStore.SaveTxInfo(block, make([]uint32, len(block.Txs)))
+		err := blockStore.SaveTxInfo(block, make([]uint32, len(block.Txs)), make([]string, len(block.Txs)))
 		require.NoError(t, err)
 		for _, tx := range block.Txs {
 			indexedTxHashes = append(indexedTxHashes, tx.Hash())