aboutsummaryrefslogtreecommitdiffstats
path: root/ethpipe/world.go
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-08-04 22:25:53 +0800
committerobscuren <geffobscura@gmail.com>2014-08-04 22:25:53 +0800
commit342cc122b43f01301d0188de1e333c32ed64ae8c (patch)
treea8bfb3288a5866de2a315319124e7a6b908f7bd3 /ethpipe/world.go
parent03ce15df4c7ef51d4373233ab5c3766282b31771 (diff)
downloadgo-tangerine-342cc122b43f01301d0188de1e333c32ed64ae8c.tar
go-tangerine-342cc122b43f01301d0188de1e333c32ed64ae8c.tar.gz
go-tangerine-342cc122b43f01301d0188de1e333c32ed64ae8c.tar.bz2
go-tangerine-342cc122b43f01301d0188de1e333c32ed64ae8c.tar.lz
go-tangerine-342cc122b43f01301d0188de1e333c32ed64ae8c.tar.xz
go-tangerine-342cc122b43f01301d0188de1e333c32ed64ae8c.tar.zst
go-tangerine-342cc122b43f01301d0188de1e333c32ed64ae8c.zip
Added general Pipe API
Diffstat (limited to 'ethpipe/world.go')
-rw-r--r--ethpipe/world.go60
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
+}