Add proof support and update dependencies

Makefile

@@ -3,8 +3,11 @@
 all: test install
 
 NOVENDOR = go list github.com/tendermint/basecoin/... | grep -v /vendor/
-
-install: 
+
+build:
+	go build github.com/tendermint/basecoin/cmd/...
+
+install:
 	go install github.com/tendermint/basecoin/cmd/...
 
 test:
@@ -20,4 +23,4 @@ update_deps:
 get_vendor_deps:
 	go get github.com/Masterminds/glide
 	glide install
-	
+

app/app.go

@@ -126,6 +126,15 @@ func (app *Basecoin) Query(query []byte) (res abci.Result) {
 	return app.eyesCli.QuerySync(query)
 }
 
+// TMSP::Query
+func (app *Basecoin) Proof(key []byte, height uint64) (res abci.Result) {
+	if len(key) == 0 {
+		return abci.ErrEncodingError.SetLog("Key cannot be zero length")
+	}
+
+	return app.eyesCli.ProofSync(key, height)
+}
+
 // TMSP::Commit
 func (app *Basecoin) Commit() (res abci.Result) {
 

app/genesis.go

@@ -0,0 +1,63 @@
+package app
+
+import (
+	"encoding/json"
+	"fmt"
+	"reflect"
+
+	"github.com/pkg/errors"
+	cmn "github.com/tendermint/go-common"
+)
+
+func (app *Basecoin) LoadGenesis(path string) error {
+	kvz, err := loadGenesis(path)
+	if err != nil {
+		return err
+	}
+	for _, kv := range kvz {
+		log := app.SetOption(kv.Key, kv.Value)
+		// TODO: remove debug output
+		fmt.Printf("Set %v=%v. Log: %v", kv.Key, kv.Value, log)
+	}
+	return nil
+}
+
+type keyValue struct {
+	Key   string `json:"key"`
+	Value string `json:"value"`
+}
+
+func loadGenesis(filePath string) (kvz []keyValue, err error) {
+	kvz_ := []interface{}{}
+	bytes, err := cmn.ReadFile(filePath)
+	if err != nil {
+		return nil, errors.Wrap(err, "loading genesis file")
+	}
+	err = json.Unmarshal(bytes, &kvz_)
+	if err != nil {
+		return nil, errors.Wrap(err, "parsing genesis file")
+	}
+	if len(kvz_)%2 != 0 {
+		return nil, errors.New("genesis cannot have an odd number of items.  Format = [key1, value1, key2, value2, ...]")
+	}
+	for i := 0; i < len(kvz_); i += 2 {
+		keyIfc := kvz_[i]
+		valueIfc := kvz_[i+1]
+		var key, value string
+		key, ok := keyIfc.(string)
+		if !ok {
+			return nil, errors.Errorf("genesis had invalid key %v of type %v", keyIfc, reflect.TypeOf(keyIfc))
+		}
+		if value_, ok := valueIfc.(string); ok {
+			value = value_
+		} else {
+			valueBytes, err := json.Marshal(valueIfc)
+			if err != nil {
+				return nil, errors.Errorf("genesis had invalid value %v: %v", value_, err.Error())
+			}
+			value = string(valueBytes)
+		}
+		kvz = append(kvz, keyValue{key, value})
+	}
+	return kvz, nil
+}

cmd/basecoin/main.go

@@ -1,19 +1,15 @@
 package main
 
 import (
-	"encoding/json"
 	"flag"
-	"fmt"
-	"reflect"
 
 	"github.com/tendermint/abci/server"
 	"github.com/tendermint/basecoin/app"
-	. "github.com/tendermint/go-common"
+	cmn "github.com/tendermint/go-common"
 	eyes "github.com/tendermint/merkleeyes/client"
 )
 
 func main() {
-
 	addrPtr := flag.String("address", "tcp://0.0.0.0:46658", "Listen address")
 	eyesPtr := flag.String("eyes", "local", "MerkleEyes address, or 'local' for embedded")
 	genFilePath := flag.String("genesis", "", "Genesis file, if any")
@@ -22,73 +18,30 @@ func main() {
 	// Connect to MerkleEyes
 	eyesCli, err := eyes.NewClient(*eyesPtr, "socket")
 	if err != nil {
-		Exit("connect to MerkleEyes: " + err.Error())
+		cmn.Exit("connect to MerkleEyes: " + err.Error())
 	}
 
 	// Create Basecoin app
 	app := app.NewBasecoin(eyesCli)
 
 	// If genesis file was specified, set key-value options
 	if *genFilePath != "" {
-		kvz := loadGenesis(*genFilePath)
-		for _, kv := range kvz {
-			log := app.SetOption(kv.Key, kv.Value)
-			fmt.Println(Fmt("Set %v=%v. Log: %v", kv.Key, kv.Value, log))
+		err := app.LoadGenesis(*genFilePath)
+		if err != nil {
+			cmn.Exit(cmn.Fmt("%+v", err))
 		}
 	}
 
 	// Start the listener
 	svr, err := server.NewServer(*addrPtr, "socket", app)
 	if err != nil {
-		Exit("create listener: " + err.Error())
+		cmn.Exit("create listener: " + err.Error())
 	}
 
 	// Wait forever
-	TrapSignal(func() {
+	cmn.TrapSignal(func() {
 		// Cleanup
 		svr.Stop()
 	})
 
 }
-
-//----------------------------------------
-
-type KeyValue struct {
-	Key   string `json:"key"`
-	Value string `json:"value"`
-}
-
-func loadGenesis(filePath string) (kvz []KeyValue) {
-	kvz_ := []interface{}{}
-	bytes, err := ReadFile(filePath)
-	if err != nil {
-		Exit("loading genesis file: " + err.Error())
-	}
-	err = json.Unmarshal(bytes, &kvz_)
-	if err != nil {
-		Exit("parsing genesis file: " + err.Error())
-	}
-	if len(kvz_)%2 != 0 {
-		Exit("genesis cannot have an odd number of items.  Format = [key1, value1, key2, value2, ...]")
-	}
-	for i := 0; i < len(kvz_); i += 2 {
-		keyIfc := kvz_[i]
-		valueIfc := kvz_[i+1]
-		var key, value string
-		key, ok := keyIfc.(string)
-		if !ok {
-			Exit(Fmt("genesis had invalid key %v of type %v", keyIfc, reflect.TypeOf(keyIfc)))
-		}
-		if value_, ok := valueIfc.(string); ok {
-			value = value_
-		} else {
-			valueBytes, err := json.Marshal(valueIfc)
-			if err != nil {
-				Exit(Fmt("genesis had invalid value %v: %v", value_, err.Error()))
-			}
-			value = string(valueBytes)
-		}
-		kvz = append(kvz, KeyValue{key, value})
-	}
-	return kvz
-}

cmd/paytovote/main.go

@@ -0,0 +1,53 @@
+package main
+
+import (
+	"flag"
+
+	"github.com/tendermint/abci/server"
+	"github.com/tendermint/basecoin/app"
+	"github.com/tendermint/basecoin/plugins/counter"
+	cmn "github.com/tendermint/go-common"
+	eyes "github.com/tendermint/merkleeyes/client"
+)
+
+func main() {
+	addrPtr := flag.String("address", "tcp://0.0.0.0:46658", "Listen address")
+	eyesPtr := flag.String("eyes", "local", "MerkleEyes address, or 'local' for embedded")
+	genFilePath := flag.String("genesis", "", "Genesis file, if any")
+	flag.Parse()
+
+	// Connect to MerkleEyes
+	eyesCli, err := eyes.NewClient(*eyesPtr, "socket")
+	if err != nil {
+		cmn.Exit("connect to MerkleEyes: " + err.Error())
+	}
+
+	// Create Basecoin app
+	app := app.NewBasecoin(eyesCli)
+
+	// add plugins
+	// TODO: add some more, like the cool voting app
+	counter := counter.New("counter")
+	app.RegisterPlugin(counter)
+
+	// If genesis file was specified, set key-value options
+	if *genFilePath != "" {
+		err := app.LoadGenesis(*genFilePath)
+		if err != nil {
+			cmn.Exit(cmn.Fmt("%+v", err))
+		}
+	}
+
+	// Start the listener
+	svr, err := server.NewServer(*addrPtr, "socket", app)
+	if err != nil {
+		cmn.Exit("create listener: " + err.Error())
+	}
+
+	// Wait forever
+	cmn.TrapSignal(func() {
+		// Cleanup
+		svr.Stop()
+	})
+
+}

glide.yaml

@@ -15,9 +15,8 @@ import:
 - package: github.com/tendermint/merkleeyes
   version: develop
 - package: github.com/tendermint/tendermint
-  version: develop
+  version: abci_proof
 - package: github.com/tendermint/abci
-  version: develop
-
+  version: abci_proof
 - package: github.com/gorilla/websocket
   version: v1.1.0

plugins/counter/counter.go

@@ -32,7 +32,7 @@ func (cp *CounterPlugin) StateKey() []byte {
 	return []byte(fmt.Sprintf("CounterPlugin{name=%v}.State", cp.name))
 }
 
-func NewCounterPlugin(name string) *CounterPlugin {
+func New(name string) *CounterPlugin {
 	return &CounterPlugin{
 		name: name,
 	}
@@ -43,7 +43,6 @@ func (cp *CounterPlugin) SetOption(store types.KVStore, key string, value string
 }
 
 func (cp *CounterPlugin) RunTx(store types.KVStore, ctx types.CallContext, txBytes []byte) (res abci.Result) {
-
 	// Decode tx
 	var tx CounterTx
 	err := wire.ReadBinaryBytes(txBytes, &tx)

plugins/counter/counter_test.go

@@ -23,7 +23,7 @@ func TestCounterPlugin(t *testing.T) {
 
 	// Add Counter plugin
 	counterPluginName := "testcounter"
-	counterPlugin := NewCounterPlugin(counterPluginName)
+	counterPlugin := New(counterPluginName)
 	bcApp.RegisterPlugin(counterPlugin)
 
 	// Account initialization