txMeta storage as struct

core/block_processor.go

@@ -235,7 +235,7 @@ func (sm *BlockProcessor) processWithParent(block, parent *types.Block) (td *big
 
 	// This puts transactions in a extra db for rpc
 	for i, tx := range block.Transactions() {
-		putTx(sm.extraDb, tx, block, i)
+		putTx(sm.extraDb, tx, block, uint64(i))
 	}
 
 	if uncle {
@@ -359,7 +359,7 @@ func (sm *BlockProcessor) GetLogs(block *types.Block) (logs state.Logs, err erro
 	return state.Logs(), nil
 }
 
-func putTx(db common.Database, tx *types.Transaction, block *types.Block, i int) {
+func putTx(db common.Database, tx *types.Transaction, block *types.Block, i uint64) {
 	rlpEnc, err := rlp.EncodeToBytes(tx)
 	if err != nil {
 		statelogger.Infoln("Failed encoding tx", err)
@@ -367,24 +367,18 @@ func putTx(db common.Database, tx *types.Transaction, block *types.Block, i int)
 	}
 	db.Put(tx.Hash().Bytes(), rlpEnc)
 
-	rlpEnc, err = rlp.EncodeToBytes(block.Hash().Bytes())
-	if err != nil {
-		statelogger.Infoln("Failed encoding meta", err)
-		return
+	var txExtra struct {
+		BlockHash  common.Hash
+		BlockIndex uint64
+		Index      uint64
 	}
-	db.Put(append(tx.Hash().Bytes(), 0x0001), rlpEnc)
-
-	rlpEnc, err = rlp.EncodeToBytes(block.Number().Bytes())
-	if err != nil {
-		statelogger.Infoln("Failed encoding meta", err)
-		return
-	}
-	db.Put(append(tx.Hash().Bytes(), 0x0002), rlpEnc)
-
-	rlpEnc, err = rlp.EncodeToBytes(i)
+	txExtra.BlockHash = block.Hash()
+	txExtra.BlockIndex = block.NumberU64()
+	txExtra.Index = i
+	rlpMeta, err := rlp.EncodeToBytes(txExtra)
 	if err != nil {
 		statelogger.Infoln("Failed encoding meta", err)
 		return
 	}
-	db.Put(append(tx.Hash().Bytes(), 0x0003), rlpEnc)
+	db.Put(append(tx.Hash().Bytes(), 0x0001), rlpMeta)
 }

xeth/xeth.go

@@ -19,6 +19,7 @@ import (
 	"github.com/ethereum/go-ethereum/event/filter"
 	"github.com/ethereum/go-ethereum/logger"
 	"github.com/ethereum/go-ethereum/miner"
+	"github.com/ethereum/go-ethereum/rlp"
 )
 
 var (
@@ -191,20 +192,20 @@ func (self *XEth) EthTransactionByHash(hash string) (tx *types.Transaction, blha
 		tx = types.NewTransactionFromBytes(data)
 	}
 
-	// blockhash
-	data, _ = self.backend.ExtraDb().Get(append(common.FromHex(hash), 0x0001))
-	if len(data) != 0 {
-		blhash = common.BytesToHash(data)
-	}
-	// blocknum
-	data, _ = self.backend.ExtraDb().Get(append(common.FromHex(hash), 0x0002))
-	if len(data) != 0 {
-		blnum = common.Bytes2Big(data)
+	// meta
+	var txExtra struct {
+		BlockHash  common.Hash
+		BlockIndex int64
+		Index      uint64
 	}
-	// txindex
-	data, _ = self.backend.ExtraDb().Get(append(common.FromHex(hash), 0x0003))
-	if len(data) != 0 {
-		txi = common.BytesToNumber(data)
+
+	v, _ := self.backend.ExtraDb().Get(append(common.FromHex(hash), 0x0001))
+	r := bytes.NewReader(v)
+	err := rlp.Decode(r, &txExtra)
+	if err == nil {
+		blhash = txExtra.BlockHash
+		blnum = big.NewInt(txExtra.BlockIndex)
+		txi = txExtra.Index
 	}
 
 	return