cleanup main function
This commit is contained in:
Aleksandr Bezobchuk
parent
cb5c081858
commit
c6269e23b3
385
main.go
385
main.go
@ -4,169 +4,232 @@
|
||||
// as Ethermint.
|
||||
package main
|
||||
|
||||
// eth_common "github.com/ethereum/go-ethereum/common"
|
||||
// eth_misc "github.com/ethereum/go-ethereum/consensus/misc"
|
||||
// eth_core "github.com/ethereum/go-ethereum/core"
|
||||
// eth_state "github.com/ethereum/go-ethereum/core/state"
|
||||
// eth_types "github.com/ethereum/go-ethereum/core/types"
|
||||
// eth_vm "github.com/ethereum/go-ethereum/core/vm"
|
||||
// eth_params "github.com/ethereum/go-ethereum/params"
|
||||
// eth_rlp "github.com/ethereum/go-ethereum/rlp"
|
||||
// dbm "github.com/tendermint/tendermint/libs/db"
|
||||
import (
|
||||
"bytes"
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"io"
|
||||
"os"
|
||||
|
||||
// var (
|
||||
// // TODO: Document...
|
||||
// miner501 = eth_common.HexToAddress("0x35e8e5dC5FBd97c5b421A80B596C030a2Be2A04D")
|
||||
// )
|
||||
ethcommon "github.com/ethereum/go-ethereum/common"
|
||||
ethmisc "github.com/ethereum/go-ethereum/consensus/misc"
|
||||
ethcore "github.com/ethereum/go-ethereum/core"
|
||||
ethstate "github.com/ethereum/go-ethereum/core/state"
|
||||
ethtypes "github.com/ethereum/go-ethereum/core/types"
|
||||
ethvm "github.com/ethereum/go-ethereum/core/vm"
|
||||
ethparams "github.com/ethereum/go-ethereum/params"
|
||||
ethrlp "github.com/ethereum/go-ethereum/rlp"
|
||||
"github.com/ledgerwatch/ethermint/core"
|
||||
"github.com/ledgerwatch/ethermint/state"
|
||||
dbm "github.com/tendermint/tendermint/libs/db"
|
||||
)
|
||||
|
||||
var (
|
||||
// TODO: Document...
|
||||
miner501 = ethcommon.HexToAddress("0x35e8e5dC5FBd97c5b421A80B596C030a2Be2A04D")
|
||||
genInvestor = ethcommon.HexToAddress("0x756F45E3FA69347A9A973A725E3C98bC4db0b5a0")
|
||||
)
|
||||
|
||||
// TODO: Document...
|
||||
func main() {
|
||||
// stateDb := dbm.NewDB("state" /* name */, dbm.MemDBBackend, "" /* dir */)
|
||||
// codeDB := dbm.NewDB("code" /* name */, dbm.MemDBBackend, "" /* dir */)
|
||||
// d, err := OurNewDatabase(stateDb, codeDB)
|
||||
// if err != nil {
|
||||
// panic(err)
|
||||
// }
|
||||
// fmt.Printf("Instantiating state.StateDB\n")
|
||||
// // With empty root hash, i.e. empty state
|
||||
// statedb, err := eth_state.New(eth_common.Hash{}, d)
|
||||
// if err != nil {
|
||||
// panic(err)
|
||||
// }
|
||||
// g := eth_core.DefaultGenesisBlock()
|
||||
// for addr, account := range g.Alloc {
|
||||
// statedb.AddBalance(addr, account.Balance)
|
||||
// statedb.SetCode(addr, account.Code)
|
||||
// statedb.SetNonce(addr, account.Nonce)
|
||||
// for key, value := range account.Storage {
|
||||
// statedb.SetState(addr, key, value)
|
||||
// }
|
||||
// }
|
||||
stateDB := dbm.NewDB("state", dbm.MemDBBackend, "")
|
||||
codeDB := dbm.NewDB("code", dbm.MemDBBackend, "")
|
||||
|
||||
// // One of the genesis account having 200 ETH
|
||||
// b := statedb.GetBalance(eth_common.HexToAddress("0x756F45E3FA69347A9A973A725E3C98bC4db0b5a0"))
|
||||
// fmt.Printf("Balance: %s\n", b)
|
||||
// genesis_root, err := statedb.Commit(false /* deleteEmptyObjects */)
|
||||
// if err != nil {
|
||||
// panic(err)
|
||||
// }
|
||||
// commitID := d.stateStore.Commit()
|
||||
// fmt.Printf("CommitID after genesis: %v\n", commitID)
|
||||
// fmt.Printf("Genesis state root hash: %x\n", genesis_root[:])
|
||||
// // File with blockchain data exported from geth by using "geth expordb" command
|
||||
// input, err := os.Open("/Users/alexeyakhunov/mygit/blockchain")
|
||||
// if err != nil {
|
||||
// panic(err)
|
||||
// }
|
||||
// defer input.Close()
|
||||
// // Ethereum mainnet config
|
||||
// chainConfig := eth_params.MainnetChainConfig
|
||||
// stream := eth_rlp.NewStream(input, 0)
|
||||
// var block eth_types.Block
|
||||
// n := 0
|
||||
// var root500 eth_common.Hash // Root hash after block 500
|
||||
// var root501 eth_common.Hash // Root hash after block 501
|
||||
// prev_root := genesis_root
|
||||
// d.tracing = true
|
||||
// chainContext := &OurChainContext{}
|
||||
// vmConfig := eth_vm.Config{}
|
||||
// for {
|
||||
// if err = stream.Decode(&block); err == io.EOF {
|
||||
// err = nil // Clear it
|
||||
// break
|
||||
// } else if err != nil {
|
||||
// panic(fmt.Errorf("at block %d: %v", block.NumberU64(), err))
|
||||
// }
|
||||
// // don't import first block
|
||||
// if block.NumberU64() == 0 {
|
||||
// continue
|
||||
// }
|
||||
// header := block.Header()
|
||||
// chainContext.coinbase = header.Coinbase
|
||||
// statedb, err := eth_state.New(prev_root, d)
|
||||
// if err != nil {
|
||||
// panic(fmt.Errorf("at block %d: %v", block.NumberU64(), err))
|
||||
// }
|
||||
// var (
|
||||
// receipts eth_types.Receipts
|
||||
// usedGas = new(uint64)
|
||||
// allLogs []*eth_types.Log
|
||||
// gp = new(eth_core.GasPool).AddGas(block.GasLimit())
|
||||
// )
|
||||
// if chainConfig.DAOForkSupport && chainConfig.DAOForkBlock != nil && chainConfig.DAOForkBlock.Cmp(block.Number()) == 0 {
|
||||
// eth_misc.ApplyDAOHardFork(statedb)
|
||||
// }
|
||||
// for i, tx := range block.Transactions() {
|
||||
// statedb.Prepare(tx.Hash(), block.Hash(), i)
|
||||
// var h eth_common.Hash = tx.Hash()
|
||||
// if bytes.Equal(h[:], eth_common.FromHex("0xc438cfcc3b74a28741bda361032f1c6362c34aa0e1cedff693f31ec7d6a12717")) {
|
||||
// vmConfig.Tracer = eth_vm.NewStructLogger(ð_vm.LogConfig{})
|
||||
// vmConfig.Debug = true
|
||||
// }
|
||||
// receipt, _, err := eth_core.ApplyTransaction(chainConfig, chainContext, nil, gp, statedb, header, tx, usedGas, vmConfig)
|
||||
// if vmConfig.Tracer != nil {
|
||||
// w, err := os.Create("structlogs.txt")
|
||||
// if err != nil {
|
||||
// panic(err)
|
||||
// }
|
||||
// encoder := json.NewEncoder(w)
|
||||
// logs := FormatLogs(vmConfig.Tracer.(*eth_vm.StructLogger).StructLogs())
|
||||
// if err := encoder.Encode(logs); err != nil {
|
||||
// panic(err)
|
||||
// }
|
||||
// if err := w.Close(); err != nil {
|
||||
// panic(err)
|
||||
// }
|
||||
// vmConfig.Debug = false
|
||||
// vmConfig.Tracer = nil
|
||||
// }
|
||||
// if err != nil {
|
||||
// panic(fmt.Errorf("at block %d, tx %x: %v", block.NumberU64(), tx.Hash(), err))
|
||||
// }
|
||||
// receipts = append(receipts, receipt)
|
||||
// allLogs = append(allLogs, receipt.Logs...)
|
||||
// }
|
||||
// // Apply mining rewards to the statedb
|
||||
// accumulateRewards(chainConfig, statedb, header, block.Uncles())
|
||||
// // Commit block
|
||||
// prev_root, err = statedb.Commit(chainConfig.IsEIP158(block.Number()) /* deleteEmptyObjects */)
|
||||
// if err != nil {
|
||||
// panic(fmt.Errorf("at block %d: %v", block.NumberU64(), err))
|
||||
// }
|
||||
// //fmt.Printf("State root after block %d: %x\n", block.NumberU64(), prev_root)
|
||||
// d.stateStore.Commit()
|
||||
// //fmt.Printf("CommitID after block %d: %v\n", block.NumberU64(), commitID)
|
||||
// switch block.NumberU64() {
|
||||
// case 500:
|
||||
// root500 = prev_root
|
||||
// case 501:
|
||||
// root501 = prev_root
|
||||
// }
|
||||
// n++
|
||||
// if n%10000 == 0 {
|
||||
// fmt.Printf("Processed %d blocks\n", n)
|
||||
// }
|
||||
// if n >= 100000 {
|
||||
// break
|
||||
// }
|
||||
// }
|
||||
// fmt.Printf("Processed %d blocks\n", n)
|
||||
// d.tracing = true
|
||||
// genesis_state, err := eth_state.New(genesis_root, d)
|
||||
// fmt.Printf("Balance of one of the genesis investors: %s\n", genesis_state.GetBalance(eth_common.HexToAddress("0x756F45E3FA69347A9A973A725E3C98bC4db0b5a0")))
|
||||
// //miner501 := eth_common.HexToAddress("0x35e8e5dC5FBd97c5b421A80B596C030a2Be2A04D") // Miner of the block 501
|
||||
// // Try to create a new statedb from root of the block 500
|
||||
// fmt.Printf("root500: %x\n", root500[:])
|
||||
// state500, err := eth_state.New(root500, d)
|
||||
// if err != nil {
|
||||
// panic(err)
|
||||
// }
|
||||
// miner501_balance_at_500 := state500.GetBalance(miner501)
|
||||
// state501, err := eth_state.New(root501, d)
|
||||
// if err != nil {
|
||||
// panic(err)
|
||||
// }
|
||||
// miner501_balance_at_501 := state501.GetBalance(miner501)
|
||||
// fmt.Printf("Investor's balance after block 500: %d\n", state500.GetBalance(eth_common.HexToAddress("0x756F45E3FA69347A9A973A725E3C98bC4db0b5a0")))
|
||||
// fmt.Printf("Miner of block 501's balance after block 500: %d\n", miner501_balance_at_500)
|
||||
// fmt.Printf("Miner of block 501's balance after block 501: %d\n", miner501_balance_at_501)
|
||||
ethermintDB, err := state.NewDatabase(stateDB, codeDB)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
fmt.Println("instantiating new geth state.StateDB")
|
||||
|
||||
// start with empty root hash (i.e. empty state)
|
||||
gethStateDB, err := ethstate.New(ethcommon.Hash{}, ethermintDB)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
genBlock := ethcore.DefaultGenesisBlock()
|
||||
for addr, account := range genBlock.Alloc {
|
||||
gethStateDB.AddBalance(addr, account.Balance)
|
||||
gethStateDB.SetCode(addr, account.Code)
|
||||
gethStateDB.SetNonce(addr, account.Nonce)
|
||||
|
||||
for key, value := range account.Storage {
|
||||
gethStateDB.SetState(addr, key, value)
|
||||
}
|
||||
}
|
||||
|
||||
// get balance of one of the genesis account having 200 ETH
|
||||
b := gethStateDB.GetBalance(genInvestor)
|
||||
fmt.Printf("balance of %s: %s\n", genInvestor.String(), b)
|
||||
|
||||
// commit the geth stateDB with 'false' to delete empty objects
|
||||
genRoot, err := gethStateDB.Commit(false)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
commitID := ethermintDB.Commit()
|
||||
|
||||
fmt.Printf("commitID after genesis: %v\n", commitID)
|
||||
fmt.Printf("genesis state root hash: %x\n", genRoot[:])
|
||||
|
||||
// file with blockchain data exported from geth by using "geth exportdb"
|
||||
// command.
|
||||
//
|
||||
// TODO: Allow this to be configurable
|
||||
input, err := os.Open("/Users/alexeyakhunov/mygit/blockchain")
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
defer input.Close()
|
||||
|
||||
// ethereum mainnet config
|
||||
chainConfig := ethparams.MainnetChainConfig
|
||||
|
||||
// create RLP stream for exported blocks
|
||||
stream := ethrlp.NewStream(input, 0)
|
||||
|
||||
var (
|
||||
block ethtypes.Block
|
||||
root500 ethcommon.Hash // root hash after block 500
|
||||
root501 ethcommon.Hash // root hash after block 501
|
||||
)
|
||||
|
||||
prevRoot := genRoot
|
||||
ethermintDB.Tracing = true
|
||||
chainContext := &core.ChainContext{}
|
||||
vmConfig := ethvm.Config{}
|
||||
|
||||
n := 0
|
||||
for {
|
||||
if err = stream.Decode(&block); err == io.EOF {
|
||||
err = nil
|
||||
break
|
||||
} else if err != nil {
|
||||
panic(fmt.Errorf("failed to decode at block %d: %s", block.NumberU64(), err))
|
||||
}
|
||||
|
||||
// don't import first block
|
||||
if block.NumberU64() == 0 {
|
||||
continue
|
||||
}
|
||||
|
||||
header := block.Header()
|
||||
chainContext.Coinbase = header.Coinbase
|
||||
|
||||
gethStateDB, err := ethstate.New(prevRoot, ethermintDB)
|
||||
if err != nil {
|
||||
panic(fmt.Errorf("failed to instantiate geth state.StateDB at block %d: %v", block.NumberU64(), err))
|
||||
}
|
||||
|
||||
var (
|
||||
receipts ethtypes.Receipts
|
||||
usedGas = new(uint64)
|
||||
allLogs []*ethtypes.Log
|
||||
gp = new(ethcore.GasPool).AddGas(block.GasLimit())
|
||||
)
|
||||
|
||||
if chainConfig.DAOForkSupport && chainConfig.DAOForkBlock != nil && chainConfig.DAOForkBlock.Cmp(block.Number()) == 0 {
|
||||
ethmisc.ApplyDAOHardFork(gethStateDB)
|
||||
}
|
||||
|
||||
for i, tx := range block.Transactions() {
|
||||
gethStateDB.Prepare(tx.Hash(), block.Hash(), i)
|
||||
|
||||
txHash := tx.Hash()
|
||||
// TODO: Why this address?
|
||||
if bytes.Equal(txHash[:], ethcommon.FromHex("0xc438cfcc3b74a28741bda361032f1c6362c34aa0e1cedff693f31ec7d6a12717")) {
|
||||
vmConfig.Tracer = ethvm.NewStructLogger(ðvm.LogConfig{})
|
||||
vmConfig.Debug = true
|
||||
}
|
||||
|
||||
receipt, _, err := ethcore.ApplyTransaction(chainConfig, chainContext, nil, gp, gethStateDB, header, tx, usedGas, vmConfig)
|
||||
if vmConfig.Tracer != nil {
|
||||
w, err := os.Create("structlogs.txt")
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
encoder := json.NewEncoder(w)
|
||||
logs := FormatLogs(vmConfig.Tracer.(*ethvm.StructLogger).StructLogs())
|
||||
|
||||
if err := encoder.Encode(logs); err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
if err := w.Close(); err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
vmConfig.Debug = false
|
||||
vmConfig.Tracer = nil
|
||||
}
|
||||
|
||||
if err != nil {
|
||||
panic(fmt.Errorf("at block %d, tx %x: %v", block.NumberU64(), tx.Hash(), err))
|
||||
}
|
||||
|
||||
receipts = append(receipts, receipt)
|
||||
allLogs = append(allLogs, receipt.Logs...)
|
||||
}
|
||||
|
||||
// apply mining rewards to the geth stateDB
|
||||
accumulateRewards(chainConfig, gethStateDB, header, block.Uncles())
|
||||
|
||||
// commit block in geth
|
||||
prevRoot, err = gethStateDB.Commit(chainConfig.IsEIP158(block.Number()))
|
||||
if err != nil {
|
||||
panic(fmt.Errorf("at block %d: %v", block.NumberU64(), err))
|
||||
}
|
||||
|
||||
// commit block in Ethermint
|
||||
ethermintDB.Commit()
|
||||
|
||||
switch block.NumberU64() {
|
||||
case 500:
|
||||
root500 = prevRoot
|
||||
case 501:
|
||||
root501 = prevRoot
|
||||
}
|
||||
|
||||
n++
|
||||
if n%10000 == 0 {
|
||||
fmt.Printf("processed %d blocks\n", n)
|
||||
}
|
||||
if n >= 100000 {
|
||||
break
|
||||
}
|
||||
}
|
||||
|
||||
fmt.Printf("processed %d blocks\n", n)
|
||||
|
||||
ethermintDB.Tracing = true
|
||||
|
||||
genState, err := ethstate.New(genRoot, ethermintDB)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
|
||||
fmt.Printf("balance of one of the genesis investors: %s\n", genState.GetBalance(genInvestor))
|
||||
|
||||
// try to create a new geth stateDB from root of the block 500
|
||||
fmt.Printf("root500: %x\n", root500[:])
|
||||
|
||||
state500, err := ethstate.New(root500, ethermintDB)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
miner501BalanceAt500 := state500.GetBalance(miner501)
|
||||
|
||||
state501, err := ethstate.New(root501, ethermintDB)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
miner501BalanceAt501 := state501.GetBalance(miner501)
|
||||
|
||||
fmt.Printf("investor's balance after block 500: %d\n", state500.GetBalance(genInvestor))
|
||||
fmt.Printf("miner of block 501's balance after block 500: %d\n", miner501BalanceAt500)
|
||||
fmt.Printf("miner of block 501's balance after block 501: %d\n", miner501BalanceAt501)
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user