aboutsummaryrefslogtreecommitdiffstats
path: root/ethpipe/world.go
diff options
context:
space:
mode:
Diffstat (limited to 'ethpipe/world.go')
-rw-r--r--ethpipe/world.go64
1 files changed, 64 insertions, 0 deletions
diff --git a/ethpipe/world.go b/ethpipe/world.go
new file mode 100644
index 000000000..e34bd31aa
--- /dev/null
+++ b/ethpipe/world.go
@@ -0,0 +1,64 @@
+package ethpipe
+
+import (
+ "container/list"
+
+ "github.com/ethereum/go-ethereum/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) *Object {
+ return &Object{self.State().GetStateObject(addr)}
+}
+
+func (self *World) SafeGet(addr []byte) *Object {
+ return &Object{self.safeGet(addr)}
+}
+
+func (self *World) safeGet(addr []byte) *ethstate.StateObject {
+ object := self.State().GetStateObject(addr)
+ if object == nil {
+ object = ethstate.NewStateObject(addr)
+ }
+
+ return object
+}
+
+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.pipe.obj.Peers()
+}
+
+func (self *World) Config() *Config {
+ return self.cfg
+}