diff options
author | Taylor Gerring <taylor.gerring@gmail.com> | 2015-04-01 04:40:12 +0800 |
---|---|---|
committer | Taylor Gerring <taylor.gerring@gmail.com> | 2015-04-01 04:40:12 +0800 |
commit | 40ea46620066bd7888b3f9a425fcd6201e0c7320 (patch) | |
tree | 298a8041dfc26c837c57410ff5b175a656e31217 /core/block_processor.go | |
parent | 7e3875b52720bf7456c9dd6162caeb7250d3686e (diff) | |
download | go-tangerine-40ea46620066bd7888b3f9a425fcd6201e0c7320.tar go-tangerine-40ea46620066bd7888b3f9a425fcd6201e0c7320.tar.gz go-tangerine-40ea46620066bd7888b3f9a425fcd6201e0c7320.tar.bz2 go-tangerine-40ea46620066bd7888b3f9a425fcd6201e0c7320.tar.lz go-tangerine-40ea46620066bd7888b3f9a425fcd6201e0c7320.tar.xz go-tangerine-40ea46620066bd7888b3f9a425fcd6201e0c7320.tar.zst go-tangerine-40ea46620066bd7888b3f9a425fcd6201e0c7320.zip |
Store and retrieve tx context metadata #608
Improving this in the future will allow for cleaning up a bit of legacy
code.
Diffstat (limited to 'core/block_processor.go')
-rw-r--r-- | core/block_processor.go | 28 |
1 files changed, 25 insertions, 3 deletions
diff --git a/core/block_processor.go b/core/block_processor.go index e970ad06e..ceb0ef8a7 100644 --- a/core/block_processor.go +++ b/core/block_processor.go @@ -233,8 +233,9 @@ func (sm *BlockProcessor) processWithParent(block, parent *types.Block) (td *big sm.txpool.RemoveSet(block.Transactions()) } - for _, tx := range block.Transactions() { - putTx(sm.extraDb, tx) + // This puts transactions in a extra db for rpc + for i, tx := range block.Transactions() { + putTx(sm.extraDb, tx, block, i) } if uncle { @@ -358,11 +359,32 @@ func (sm *BlockProcessor) GetLogs(block *types.Block) (logs state.Logs, err erro return state.Logs(), nil } -func putTx(db common.Database, tx *types.Transaction) { +func putTx(db common.Database, tx *types.Transaction, block *types.Block, i int) { rlpEnc, err := rlp.EncodeToBytes(tx) if err != nil { statelogger.Infoln("Failed encoding tx", err) return } db.Put(tx.Hash().Bytes(), rlpEnc) + + rlpEnc, err = rlp.EncodeToBytes(block.Hash().Bytes()) + if err != nil { + statelogger.Infoln("Failed encoding meta", err) + return + } + 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) + if err != nil { + statelogger.Infoln("Failed encoding meta", err) + return + } + db.Put(append(tx.Hash().Bytes(), 0x0003), rlpEnc) } |