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.
103 lines
2.5 KiB
103 lines
2.5 KiB
package main
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"os"
|
|
"time"
|
|
|
|
abcicli "github.com/tendermint/abci/client"
|
|
"github.com/tendermint/abci/types"
|
|
"github.com/tendermint/tmlibs/log"
|
|
"github.com/tendermint/tmlibs/process"
|
|
)
|
|
|
|
func startApp(abciApp string) *process.Process {
|
|
// Start the app
|
|
//outBuf := NewBufferCloser(nil)
|
|
proc, err := process.StartProcess("abci_app",
|
|
"",
|
|
"bash",
|
|
[]string{"-c", fmt.Sprintf("abci-cli %s", abciApp)},
|
|
nil,
|
|
os.Stdout,
|
|
)
|
|
if err != nil {
|
|
panicf("running abci_app: %v", err)
|
|
}
|
|
|
|
// TODO a better way to handle this?
|
|
time.Sleep(time.Second)
|
|
|
|
return proc
|
|
}
|
|
|
|
func startClient(abciType string) abcicli.Client {
|
|
// Start client
|
|
client, err := abcicli.NewClient("tcp://127.0.0.1:46658", abciType, true)
|
|
if err != nil {
|
|
panic(err.Error())
|
|
}
|
|
logger := log.NewTMLogger(log.NewSyncWriter(os.Stdout))
|
|
client.SetLogger(logger.With("module", "abcicli"))
|
|
if _, err := client.Start(); err != nil {
|
|
panicf("connecting to abci_app: %v", err.Error())
|
|
}
|
|
|
|
return client
|
|
}
|
|
|
|
func setOption(client abcicli.Client, key, value string) {
|
|
_, err := client.SetOptionSync(key, value)
|
|
if err != nil {
|
|
panicf("setting %v=%v: \nerr: %v", key, value, err)
|
|
}
|
|
}
|
|
|
|
func commit(client abcicli.Client, hashExp []byte) {
|
|
res, err := client.CommitSync()
|
|
if err != nil {
|
|
panicf("client error: %v", err)
|
|
}
|
|
if res.IsErr() {
|
|
panicf("committing err %v\n", res)
|
|
}
|
|
if !bytes.Equal(res.Data, hashExp) {
|
|
panicf("Commit hash was unexpected. Got %X expected %X", res.Data, hashExp)
|
|
}
|
|
}
|
|
|
|
func deliverTx(client abcicli.Client, txBytes []byte, codeExp types.CodeType, dataExp []byte) {
|
|
res, err := client.DeliverTxSync(txBytes)
|
|
if err != nil {
|
|
panicf("client error: %v", err)
|
|
}
|
|
if res.Code != codeExp {
|
|
panicf("DeliverTx response code was unexpected. Got %v expected %v. Log: %v", res.Code, codeExp, res.Log)
|
|
}
|
|
if !bytes.Equal(res.Data, dataExp) {
|
|
panicf("DeliverTx response data was unexpected. Got %X expected %X", res.Data, dataExp)
|
|
}
|
|
}
|
|
|
|
/*func checkTx(client abcicli.Client, txBytes []byte, codeExp types.CodeType, dataExp []byte) {
|
|
res, err := client.CheckTxSync(txBytes)
|
|
if err != nil {
|
|
panicf("client error: %v", err)
|
|
}
|
|
if res.IsErr() {
|
|
panicf("checking tx %X: %v\nlog: %v", txBytes, res.Log)
|
|
}
|
|
if res.Code != codeExp {
|
|
panicf("CheckTx response code was unexpected. Got %v expected %v. Log: %v",
|
|
res.Code, codeExp, res.Log)
|
|
}
|
|
if !bytes.Equal(res.Data, dataExp) {
|
|
panicf("CheckTx response data was unexpected. Got %X expected %X",
|
|
res.Data, dataExp)
|
|
}
|
|
}*/
|
|
|
|
func panicf(format string, a ...interface{}) {
|
|
panic(fmt.Sprintf(format, a...))
|
|
}
|