You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
99 lines
2.5 KiB
99 lines
2.5 KiB
package dummy
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
|
|
"github.com/tendermint/abci/example/code"
|
|
"github.com/tendermint/abci/types"
|
|
wire "github.com/tendermint/go-wire"
|
|
"github.com/tendermint/iavl"
|
|
dbm "github.com/tendermint/tmlibs/db"
|
|
)
|
|
|
|
var _ types.Application = (*DummyApplication)(nil)
|
|
|
|
type DummyApplication struct {
|
|
types.BaseApplication
|
|
|
|
state *iavl.VersionedTree
|
|
}
|
|
|
|
func NewDummyApplication() *DummyApplication {
|
|
state := iavl.NewVersionedTree(0, dbm.NewMemDB())
|
|
return &DummyApplication{state: state}
|
|
}
|
|
|
|
func (app *DummyApplication) Info(req types.RequestInfo) (resInfo types.ResponseInfo) {
|
|
return types.ResponseInfo{Data: fmt.Sprintf("{\"size\":%v}", app.state.Size())}
|
|
}
|
|
|
|
// tx is either "key=value" or just arbitrary bytes
|
|
func (app *DummyApplication) DeliverTx(tx []byte) types.ResponseDeliverTx {
|
|
var key, value []byte
|
|
parts := bytes.Split(tx, []byte("="))
|
|
if len(parts) == 2 {
|
|
key, value = parts[0], parts[1]
|
|
} else {
|
|
key, value = tx, tx
|
|
}
|
|
app.state.Set(key, value)
|
|
|
|
tags := []*types.KVPair{
|
|
{Key: "app.creator", ValueType: types.KVPair_STRING, ValueString: "jae"},
|
|
{Key: "app.key", ValueType: types.KVPair_STRING, ValueString: string(key)},
|
|
}
|
|
return types.ResponseDeliverTx{Code: code.CodeTypeOK, Tags: tags}
|
|
}
|
|
|
|
func (app *DummyApplication) CheckTx(tx []byte) types.ResponseCheckTx {
|
|
return types.ResponseCheckTx{Code: code.CodeTypeOK}
|
|
}
|
|
|
|
func (app *DummyApplication) Commit() types.ResponseCommit {
|
|
// Save a new version
|
|
var hash []byte
|
|
var err error
|
|
|
|
if app.state.Size() > 0 {
|
|
// just add one more to height (kind of arbitrarily stupid)
|
|
height := app.state.LatestVersion() + 1
|
|
hash, err = app.state.SaveVersion(height)
|
|
if err != nil {
|
|
// if this wasn't a dummy app, we'd do something smarter
|
|
panic(err)
|
|
}
|
|
}
|
|
|
|
return types.ResponseCommit{Code: code.CodeTypeOK, Data: hash}
|
|
}
|
|
|
|
func (app *DummyApplication) Query(reqQuery types.RequestQuery) (resQuery types.ResponseQuery) {
|
|
if reqQuery.Prove {
|
|
value, proof, err := app.state.GetWithProof(reqQuery.Data)
|
|
// if this wasn't a dummy app, we'd do something smarter
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
resQuery.Index = -1 // TODO make Proof return index
|
|
resQuery.Key = reqQuery.Data
|
|
resQuery.Value = value
|
|
resQuery.Proof = wire.BinaryBytes(proof)
|
|
if value != nil {
|
|
resQuery.Log = "exists"
|
|
} else {
|
|
resQuery.Log = "does not exist"
|
|
}
|
|
return
|
|
} else {
|
|
index, value := app.state.Get(reqQuery.Data)
|
|
resQuery.Index = int64(index)
|
|
resQuery.Value = value
|
|
if value != nil {
|
|
resQuery.Log = "exists"
|
|
} else {
|
|
resQuery.Log = "does not exist"
|
|
}
|
|
return
|
|
}
|
|
}
|