aboutsummaryrefslogtreecommitdiffstats
path: root/rpc/api.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2015-02-26 19:06:10 +0800
committerobscuren <geffobscura@gmail.com>2015-02-26 19:06:10 +0800
commita1c830cd3c53bce7748d97e3f99fe6a90d526adb (patch)
treebc8d4cdc041b1fb2a6399c1365c18d01b3a7a53d /rpc/api.go
parent49ded3aa7752148ebfbacd4e6ff5f46dc9376f89 (diff)
downloadgo-tangerine-a1c830cd3c53bce7748d97e3f99fe6a90d526adb.tar.gz
go-tangerine-a1c830cd3c53bce7748d97e3f99fe6a90d526adb.tar.zst
go-tangerine-a1c830cd3c53bce7748d97e3f99fe6a90d526adb.zip
Defautl block
Diffstat (limited to 'rpc/api.go')
-rw-r--r--rpc/api.go63
1 files changed, 31 insertions, 32 deletions
diff --git a/rpc/api.go b/rpc/api.go
index 3b4a914ef..28024c206 100644
--- a/rpc/api.go
+++ b/rpc/api.go
@@ -52,19 +52,20 @@ type EthereumApi struct {
db ethutil.Database
- defaultBlockAge int
+ defaultBlockAge int64
}
func NewEthereumApi(eth *xeth.XEth) *EthereumApi {
db, _ := ethdb.NewLDBDatabase("dapps")
api := &EthereumApi{
- eth: eth,
- mux: eth.Backend().EventMux(),
- quit: make(chan struct{}),
- filterManager: filter.NewFilterManager(eth.Backend().EventMux()),
- logs: make(map[int]*logFilter),
- messages: make(map[int]*whisperFilter),
- db: db,
+ eth: eth,
+ mux: eth.Backend().EventMux(),
+ quit: make(chan struct{}),
+ filterManager: filter.NewFilterManager(eth.Backend().EventMux()),
+ logs: make(map[int]*logFilter),
+ messages: make(map[int]*whisperFilter),
+ db: db,
+ defaultBlockAge: -1,
}
go api.filterManager.Start()
go api.start()
@@ -72,6 +73,22 @@ func NewEthereumApi(eth *xeth.XEth) *EthereumApi {
return api
}
+func (self *EthereumApi) setStateByBlockNumber(num int64) {
+ chain := self.xeth().Backend().ChainManager()
+ var block *types.Block
+
+ if self.defaultBlockAge < 0 {
+ num = chain.CurrentBlock().Number().Int64() + num + 1
+ }
+ block = chain.GetBlockByNumber(uint64(num))
+
+ if block != nil {
+ self.useState(state.New(block.Root(), self.xeth().Backend().Db()))
+ } else {
+ self.useState(chain.State())
+ }
+}
+
func (self *EthereumApi) start() {
timer := time.NewTicker(filterTickerTime)
events := self.mux.Subscribe(core.ChainEvent{})
@@ -83,12 +100,7 @@ done:
switch ev.(type) {
case core.ChainEvent:
if self.defaultBlockAge < 0 {
- chain := self.xeth().Backend().ChainManager()
- block := chain.GetBlockByNumber(chain.CurrentBlock().Number().Uint64() - uint64(self.defaultBlockAge))
- if block != nil {
- statedb := state.New(block.Root(), self.db)
- self.useState(statedb)
- }
+ self.setStateByBlockNumber(self.defaultBlockAge)
}
}
case <-timer.C:
@@ -239,21 +251,6 @@ func (p *EthereumApi) GetBlock(args *GetBlockArgs, reply *interface{}) error {
return nil
}
-/*
-func unlockAccount(server, account *Account) bool {
- pwd, status := server.PasswordDialog()
- switch status {
- case Ok:
- if !account.Unlock([]byte(pwd)) {
- return unlockAccount(account)
- }
- return true
- default:
- return false
- }
-}
-*/
-
func (p *EthereumApi) Transact(args *NewTxArgs, reply *interface{}) error {
if len(args.Gas) == 0 {
args.Gas = defaultGas.String()
@@ -378,8 +375,10 @@ func (p *EthereumApi) GetDefaultBlockAge(reply *interface{}) error {
return nil
}
-func (p *EthereumApi) SetDefaultBlockAge(defaultBlockAge int, reply *interface{}) error {
+func (p *EthereumApi) SetDefaultBlockAge(defaultBlockAge int64, reply *interface{}) error {
p.defaultBlockAge = defaultBlockAge
+ p.setStateByBlockNumber(p.defaultBlockAge)
+
*reply = true
return nil
}
@@ -531,7 +530,7 @@ func (p *EthereumApi) GetRequestReply(req *RpcRequest, reply *interface{}) error
if err != nil {
return err
}
- return p.SetDefaultBlockAge(args, reply)
+ return p.SetDefaultBlockAge(int64(args), reply)
case "eth_peerCount":
return p.GetPeerCount(reply)
case "eth_number":
@@ -720,7 +719,7 @@ func (self *EthereumApi) useState(statedb *state.StateDB) {
self.xethMu.Lock()
defer self.xethMu.Unlock()
- self.eth = self.xeth().UseState(statedb)
+ self.eth = self.eth.UseState(statedb)
}
func t(f ui.Frontend) {