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.
112 lines
3.1 KiB
112 lines
3.1 KiB
package proxy
|
|
|
|
import (
|
|
"github.com/pkg/errors"
|
|
|
|
cmn "github.com/tendermint/tmlibs/common"
|
|
)
|
|
|
|
//-----------------------------
|
|
|
|
// Tendermint's interface to the application consists of multiple connections
|
|
type AppConns interface {
|
|
cmn.Service
|
|
|
|
Mempool() AppConnMempool
|
|
Consensus() AppConnConsensus
|
|
Query() AppConnQuery
|
|
}
|
|
|
|
func NewAppConns(clientCreator ClientCreator, handshaker Handshaker) AppConns {
|
|
return NewMultiAppConn(clientCreator, handshaker)
|
|
}
|
|
|
|
//-----------------------------
|
|
// multiAppConn implements AppConns
|
|
|
|
type Handshaker interface {
|
|
Handshake(AppConns) error
|
|
}
|
|
|
|
// a multiAppConn is made of a few appConns (mempool, consensus, query)
|
|
// and manages their underlying abci clients, including the handshake
|
|
// which ensures the app and tendermint are synced.
|
|
// TODO: on app restart, clients must reboot together
|
|
type multiAppConn struct {
|
|
cmn.BaseService
|
|
|
|
handshaker Handshaker
|
|
|
|
mempoolConn *appConnMempool
|
|
consensusConn *appConnConsensus
|
|
queryConn *appConnQuery
|
|
|
|
clientCreator ClientCreator
|
|
}
|
|
|
|
// Make all necessary abci connections to the application
|
|
func NewMultiAppConn(clientCreator ClientCreator, handshaker Handshaker) *multiAppConn {
|
|
multiAppConn := &multiAppConn{
|
|
handshaker: handshaker,
|
|
clientCreator: clientCreator,
|
|
}
|
|
multiAppConn.BaseService = *cmn.NewBaseService(nil, "multiAppConn", multiAppConn)
|
|
return multiAppConn
|
|
}
|
|
|
|
// Returns the mempool connection
|
|
func (app *multiAppConn) Mempool() AppConnMempool {
|
|
return app.mempoolConn
|
|
}
|
|
|
|
// Returns the consensus Connection
|
|
func (app *multiAppConn) Consensus() AppConnConsensus {
|
|
return app.consensusConn
|
|
}
|
|
|
|
// Returns the query Connection
|
|
func (app *multiAppConn) Query() AppConnQuery {
|
|
return app.queryConn
|
|
}
|
|
|
|
func (app *multiAppConn) OnStart() error {
|
|
// query connection
|
|
querycli, err := app.clientCreator.NewABCIClient()
|
|
if err != nil {
|
|
return errors.Wrap(err, "Error creating ABCI client (query connection)")
|
|
}
|
|
querycli.SetLogger(app.Logger.With("module", "abci-client", "connection", "query"))
|
|
if _, err := querycli.Start(); err != nil {
|
|
return errors.Wrap(err, "Error starting ABCI client (query connection)")
|
|
}
|
|
app.queryConn = NewAppConnQuery(querycli)
|
|
|
|
// mempool connection
|
|
memcli, err := app.clientCreator.NewABCIClient()
|
|
if err != nil {
|
|
return errors.Wrap(err, "Error creating ABCI client (mempool connection)")
|
|
}
|
|
memcli.SetLogger(app.Logger.With("module", "abci-client", "connection", "mempool"))
|
|
if _, err := memcli.Start(); err != nil {
|
|
return errors.Wrap(err, "Error starting ABCI client (mempool connection)")
|
|
}
|
|
app.mempoolConn = NewAppConnMempool(memcli)
|
|
|
|
// consensus connection
|
|
concli, err := app.clientCreator.NewABCIClient()
|
|
if err != nil {
|
|
return errors.Wrap(err, "Error creating ABCI client (consensus connection)")
|
|
}
|
|
concli.SetLogger(app.Logger.With("module", "abci-client", "connection", "consensus"))
|
|
if _, err := concli.Start(); err != nil {
|
|
return errors.Wrap(err, "Error starting ABCI client (consensus connection)")
|
|
}
|
|
app.consensusConn = NewAppConnConsensus(concli)
|
|
|
|
// ensure app is synced to the latest state
|
|
if app.handshaker != nil {
|
|
return app.handshaker.Handshake(app)
|
|
}
|
|
|
|
return nil
|
|
}
|