diff options
author | obscuren <geffobscura@gmail.com> | 2014-08-04 22:25:53 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-08-04 22:25:53 +0800 |
commit | 342cc122b43f01301d0188de1e333c32ed64ae8c (patch) | |
tree | a8bfb3288a5866de2a315319124e7a6b908f7bd3 /ethpipe/world.go | |
parent | 03ce15df4c7ef51d4373233ab5c3766282b31771 (diff) | |
download | dexon-342cc122b43f01301d0188de1e333c32ed64ae8c.tar dexon-342cc122b43f01301d0188de1e333c32ed64ae8c.tar.gz dexon-342cc122b43f01301d0188de1e333c32ed64ae8c.tar.bz2 dexon-342cc122b43f01301d0188de1e333c32ed64ae8c.tar.lz dexon-342cc122b43f01301d0188de1e333c32ed64ae8c.tar.xz dexon-342cc122b43f01301d0188de1e333c32ed64ae8c.tar.zst dexon-342cc122b43f01301d0188de1e333c32ed64ae8c.zip |
Added general Pipe API
Diffstat (limited to 'ethpipe/world.go')
-rw-r--r-- | ethpipe/world.go | 60 |
1 files changed, 60 insertions, 0 deletions
diff --git a/ethpipe/world.go b/ethpipe/world.go new file mode 100644 index 000000000..507391521 --- /dev/null +++ b/ethpipe/world.go @@ -0,0 +1,60 @@ +package ethpipe + +import ( + "container/list" + + "github.com/ethereum/eth-go/ethstate" +) + +type world struct { + pipe *Pipe + cfg *config +} + +func NewWorld(pipe *Pipe) *world { + world := &world{pipe, nil} + world.cfg = &config{pipe} + + return world +} + +func (self *Pipe) World() *world { + return self.world +} + +func (self *world) State() *ethstate.State { + return self.pipe.stateManager.CurrentState() +} + +func (self *world) Get(addr []byte) *ethstate.StateObject { + return self.State().GetStateObject(addr) +} + +func (self *world) safeGet(addr []byte) *ethstate.StateObject { + object := self.Get(addr) + if object != nil { + return object + } + + return ethstate.NewStateObject(addr) +} + +func (self *world) Coinbase() *ethstate.StateObject { + return nil +} + +func (self *world) IsMining() bool { + return self.pipe.obj.IsMining() +} + +func (self *world) IsListening() bool { + return self.pipe.obj.IsListening() +} + +func (self *world) Peers() *list.List { + return self.obj.Peers() +} + +func (self *world) Config() *config { + return self.cfg +} |