From 342cc122b43f01301d0188de1e333c32ed64ae8c Mon Sep 17 00:00:00 2001
From: obscuren <geffobscura@gmail.com>
Date: Mon, 4 Aug 2014 16:25:53 +0200
Subject: Added general Pipe API

---
 ethpipe/world.go | 60 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 60 insertions(+)
 create mode 100644 ethpipe/world.go

(limited to 'ethpipe/world.go')

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
+}
-- 
cgit v1.2.3