working
This commit is contained in:
parent
40fd4589c1
commit
41ae60c1fb
|
@ -19,7 +19,7 @@ import (
|
||||||
|
|
||||||
var mainHeaderKey = []byte("header")
|
var mainHeaderKey = []byte("header")
|
||||||
|
|
||||||
// BaseApp - The ABCI application
|
// The ABCI application
|
||||||
type BaseApp struct {
|
type BaseApp struct {
|
||||||
logger log.Logger
|
logger log.Logger
|
||||||
|
|
||||||
|
@ -59,7 +59,7 @@ type BaseApp struct {
|
||||||
|
|
||||||
var _ abci.Application = &BaseApp{}
|
var _ abci.Application = &BaseApp{}
|
||||||
|
|
||||||
// NewBaseApp - create and name new BaseApp
|
// Create and name new BaseApp
|
||||||
func NewBaseApp(name string) *BaseApp {
|
func NewBaseApp(name string) *BaseApp {
|
||||||
var baseapp = &BaseApp{
|
var baseapp = &BaseApp{
|
||||||
logger: makeDefaultLogger(),
|
logger: makeDefaultLogger(),
|
||||||
|
@ -89,12 +89,12 @@ func (app *BaseApp) initMultiStore() {
|
||||||
app.cms = cms
|
app.cms = cms
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name - BaseApp Name
|
// BaseApp Name
|
||||||
func (app *BaseApp) Name() string {
|
func (app *BaseApp) Name() string {
|
||||||
return app.name
|
return app.name
|
||||||
}
|
}
|
||||||
|
|
||||||
// MountStore - Mount a store to the provided key in the BaseApp multistore
|
// Mount a store to the provided key in the BaseApp multistore
|
||||||
func (app *BaseApp) MountStore(key sdk.StoreKey, typ sdk.StoreType) {
|
func (app *BaseApp) MountStore(key sdk.StoreKey, typ sdk.StoreType) {
|
||||||
app.cms.MountStoreWithDB(key, typ, app.db)
|
app.cms.MountStoreWithDB(key, typ, app.db)
|
||||||
}
|
}
|
||||||
|
@ -118,24 +118,24 @@ func (app *BaseApp) SetBeginBlocker(...) {}
|
||||||
func (app *BaseApp) SetEndBlocker(...) {}
|
func (app *BaseApp) SetEndBlocker(...) {}
|
||||||
*/
|
*/
|
||||||
|
|
||||||
// LoadLatestVersion - TODO add description
|
// TODO add description
|
||||||
func (app *BaseApp) LoadLatestVersion(mainKey sdk.StoreKey) error {
|
func (app *BaseApp) LoadLatestVersion(mainKey sdk.StoreKey) error {
|
||||||
app.cms.LoadLatestVersion()
|
app.cms.LoadLatestVersion()
|
||||||
return app.initFromStore(mainKey)
|
return app.initFromStore(mainKey)
|
||||||
}
|
}
|
||||||
|
|
||||||
// LoadVersion - load application version
|
// Load application version
|
||||||
func (app *BaseApp) LoadVersion(version int64, mainKey sdk.StoreKey) error {
|
func (app *BaseApp) LoadVersion(version int64, mainKey sdk.StoreKey) error {
|
||||||
app.cms.LoadVersion(version)
|
app.cms.LoadVersion(version)
|
||||||
return app.initFromStore(mainKey)
|
return app.initFromStore(mainKey)
|
||||||
}
|
}
|
||||||
|
|
||||||
// LastCommitID - The last CommitID of the multistore.
|
// The last CommitID of the multistore.
|
||||||
func (app *BaseApp) LastCommitID() sdk.CommitID {
|
func (app *BaseApp) LastCommitID() sdk.CommitID {
|
||||||
return app.cms.LastCommitID()
|
return app.cms.LastCommitID()
|
||||||
}
|
}
|
||||||
|
|
||||||
// LastBlockHeight - The last commited block height.
|
// The last commited block height.
|
||||||
func (app *BaseApp) LastBlockHeight() int64 {
|
func (app *BaseApp) LastBlockHeight() int64 {
|
||||||
return app.cms.LastCommitID().Version
|
return app.cms.LastCommitID().Version
|
||||||
}
|
}
|
||||||
|
@ -180,7 +180,7 @@ func (app *BaseApp) initFromStore(mainKey sdk.StoreKey) error {
|
||||||
|
|
||||||
//----------------------------------------
|
//----------------------------------------
|
||||||
|
|
||||||
// Info - Implements ABCI
|
// Implements ABCI
|
||||||
func (app *BaseApp) Info(req abci.RequestInfo) abci.ResponseInfo {
|
func (app *BaseApp) Info(req abci.RequestInfo) abci.ResponseInfo {
|
||||||
|
|
||||||
lastCommitID := app.cms.LastCommitID()
|
lastCommitID := app.cms.LastCommitID()
|
||||||
|
@ -192,13 +192,13 @@ func (app *BaseApp) Info(req abci.RequestInfo) abci.ResponseInfo {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetOption - Implements ABCI
|
// Implements ABCI
|
||||||
func (app *BaseApp) SetOption(req abci.RequestSetOption) (res abci.ResponseSetOption) {
|
func (app *BaseApp) SetOption(req abci.RequestSetOption) (res abci.ResponseSetOption) {
|
||||||
// TODO: Implement
|
// TODO: Implement
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// InitChain - Implements ABCI
|
// Implements ABCI
|
||||||
func (app *BaseApp) InitChain(req abci.RequestInitChain) (res abci.ResponseInitChain) {
|
func (app *BaseApp) InitChain(req abci.RequestInitChain) (res abci.ResponseInitChain) {
|
||||||
// TODO: Use req.Validators
|
// TODO: Use req.Validators
|
||||||
return
|
return
|
||||||
|
@ -215,7 +215,7 @@ func (app *BaseApp) Query(req abci.RequestQuery) (res abci.ResponseQuery) {
|
||||||
return queryable.Query(req)
|
return queryable.Query(req)
|
||||||
}
|
}
|
||||||
|
|
||||||
// BeginBlock - Implements ABCI
|
// Implements ABCI
|
||||||
func (app *BaseApp) BeginBlock(req abci.RequestBeginBlock) (res abci.ResponseBeginBlock) {
|
func (app *BaseApp) BeginBlock(req abci.RequestBeginBlock) (res abci.ResponseBeginBlock) {
|
||||||
// NOTE: For consistency we should unset these upon EndBlock.
|
// NOTE: For consistency we should unset these upon EndBlock.
|
||||||
app.header = &req.Header
|
app.header = &req.Header
|
||||||
|
@ -225,7 +225,7 @@ func (app *BaseApp) BeginBlock(req abci.RequestBeginBlock) (res abci.ResponseBeg
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// CheckTx - Implements ABCI
|
// Implements ABCI
|
||||||
func (app *BaseApp) CheckTx(txBytes []byte) (res abci.ResponseCheckTx) {
|
func (app *BaseApp) CheckTx(txBytes []byte) (res abci.ResponseCheckTx) {
|
||||||
|
|
||||||
// Decode the Tx.
|
// Decode the Tx.
|
||||||
|
@ -251,7 +251,7 @@ func (app *BaseApp) CheckTx(txBytes []byte) (res abci.ResponseCheckTx) {
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// DeliverTx - Implements ABCI
|
// Implements ABCI
|
||||||
func (app *BaseApp) DeliverTx(txBytes []byte) (res abci.ResponseDeliverTx) {
|
func (app *BaseApp) DeliverTx(txBytes []byte) (res abci.ResponseDeliverTx) {
|
||||||
|
|
||||||
// Decode the Tx.
|
// Decode the Tx.
|
||||||
|
@ -339,7 +339,7 @@ func (app *BaseApp) runTx(isCheckTx bool, txBytes []byte, tx sdk.Tx) (result sdk
|
||||||
return result
|
return result
|
||||||
}
|
}
|
||||||
|
|
||||||
// EndBlock - Implements ABCI
|
// Implements ABCI
|
||||||
func (app *BaseApp) EndBlock(req abci.RequestEndBlock) (res abci.ResponseEndBlock) {
|
func (app *BaseApp) EndBlock(req abci.RequestEndBlock) (res abci.ResponseEndBlock) {
|
||||||
res.ValidatorUpdates = app.valUpdates
|
res.ValidatorUpdates = app.valUpdates
|
||||||
app.valUpdates = nil
|
app.valUpdates = nil
|
||||||
|
@ -349,7 +349,7 @@ func (app *BaseApp) EndBlock(req abci.RequestEndBlock) (res abci.ResponseEndBloc
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// Commit - Implements ABCI
|
// Implements ABCI
|
||||||
func (app *BaseApp) Commit() (res abci.ResponseCommit) {
|
func (app *BaseApp) Commit() (res abci.ResponseCommit) {
|
||||||
app.msDeliver.Write()
|
app.msDeliver.Write()
|
||||||
commitID := app.cms.Commit()
|
commitID := app.cms.Commit()
|
||||||
|
|
Loading…
Reference in New Issue