feat(baseapp): expose grpc query router via depinject. (#20264)
This commit is contained in:
parent
8ffc80749b
commit
bd886bb4b0
@ -38,8 +38,13 @@ Ref: https://keepachangelog.com/en/1.0.0/
|
||||
|
||||
## [Unreleased]
|
||||
|
||||
### Improvements
|
||||
|
||||
* (runtime) [#20264](https://github.com/cosmos/cosmos-sdk/pull/20264) Expose grpc query router via depinject.
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
* (baseapp) [#20144](https://github.com/cosmos/cosmos-sdk/pull/20144) Remove txs from mempool when antehandler fails in recheck.
|
||||
* (baseapp) [#20107](https://github.com/cosmos/cosmos-sdk/pull/20107) Avoid header height overwrite block height.
|
||||
* (cli) [#20020](https://github.com/cosmos/cosmos-sdk/pull/20020) Make bootstrap-state command support both new and legacy genesis format.
|
||||
|
||||
|
||||
@ -277,10 +277,8 @@ func (app *BaseApp) Trace() bool {
|
||||
// MsgServiceRouter returns the MsgServiceRouter of a BaseApp.
|
||||
func (app *BaseApp) MsgServiceRouter() *MsgServiceRouter { return app.msgServiceRouter }
|
||||
|
||||
// SetMsgServiceRouter sets the MsgServiceRouter of a BaseApp.
|
||||
func (app *BaseApp) SetMsgServiceRouter(msgServiceRouter *MsgServiceRouter) {
|
||||
app.msgServiceRouter = msgServiceRouter
|
||||
}
|
||||
// GRPCQueryRouter returns the GRPCQueryRouter of a BaseApp.
|
||||
func (app *BaseApp) GRPCQueryRouter() *GRPCQueryRouter { return app.grpcQueryRouter }
|
||||
|
||||
// MountStores mounts all IAVL or DB stores to the provided keys in the BaseApp
|
||||
// multistore.
|
||||
|
||||
@ -19,9 +19,6 @@ import (
|
||||
grpctypes "github.com/cosmos/cosmos-sdk/types/grpc"
|
||||
)
|
||||
|
||||
// GRPCQueryRouter returns the GRPCQueryRouter of a BaseApp.
|
||||
func (app *BaseApp) GRPCQueryRouter() *GRPCQueryRouter { return app.grpcQueryRouter }
|
||||
|
||||
// RegisterGRPCServer registers gRPC services directly with the gRPC server.
|
||||
func (app *BaseApp) RegisterGRPCServer(server gogogrpc.Server) {
|
||||
// Define an interceptor for all gRPC queries: this interceptor will create
|
||||
|
||||
@ -372,3 +372,13 @@ func (app *BaseApp) SetStreamingManager(manager storetypes.StreamingManager) {
|
||||
func (app *BaseApp) SetDisableBlockGasMeter(disableBlockGasMeter bool) {
|
||||
app.disableBlockGasMeter = disableBlockGasMeter
|
||||
}
|
||||
|
||||
// SetMsgServiceRouter sets the MsgServiceRouter of a BaseApp.
|
||||
func (app *BaseApp) SetMsgServiceRouter(msgServiceRouter *MsgServiceRouter) {
|
||||
app.msgServiceRouter = msgServiceRouter
|
||||
}
|
||||
|
||||
// SetGRPCQueryRouter sets the GRPCQueryRouter of the BaseApp.
|
||||
func (app *BaseApp) SetGRPCQueryRouter(grpcQueryRouter *GRPCQueryRouter) {
|
||||
app.grpcQueryRouter = grpcQueryRouter
|
||||
}
|
||||
|
||||
@ -50,6 +50,7 @@ type App struct {
|
||||
basicManager module.BasicManager
|
||||
baseAppOptions []BaseAppOption
|
||||
msgServiceRouter *baseapp.MsgServiceRouter
|
||||
grpcQueryRouter *baseapp.GRPCQueryRouter
|
||||
appConfig *appv1alpha1.Config
|
||||
logger log.Logger
|
||||
// initChainer is the init chainer function defined by the app config.
|
||||
|
||||
@ -31,6 +31,7 @@ func (a *AppBuilder) Build(db dbm.DB, traceStore io.Writer, baseAppOptions ...fu
|
||||
|
||||
bApp := baseapp.NewBaseApp(a.app.config.AppName, a.app.logger, db, nil, baseAppOptions...)
|
||||
bApp.SetMsgServiceRouter(a.app.msgServiceRouter)
|
||||
bApp.SetGRPCQueryRouter(a.app.grpcQueryRouter)
|
||||
bApp.SetCommitMultiStoreTracer(traceStore)
|
||||
bApp.SetVersion(version.Version)
|
||||
bApp.SetInterfaceRegistry(a.app.interfaceRegistry)
|
||||
|
||||
@ -86,6 +86,7 @@ func ProvideApp(interfaceRegistry codectypes.InterfaceRegistry) (
|
||||
*codec.LegacyAmino,
|
||||
*AppBuilder,
|
||||
*baseapp.MsgServiceRouter,
|
||||
*baseapp.GRPCQueryRouter,
|
||||
appmodule.AppModule,
|
||||
protodesc.Resolver,
|
||||
protoregistry.MessageTypeResolver,
|
||||
@ -108,6 +109,7 @@ func ProvideApp(interfaceRegistry codectypes.InterfaceRegistry) (
|
||||
|
||||
cdc := codec.NewProtoCodec(interfaceRegistry)
|
||||
msgServiceRouter := baseapp.NewMsgServiceRouter()
|
||||
grpcQueryRouter := baseapp.NewGRPCQueryRouter()
|
||||
app := &App{
|
||||
storeKeys: nil,
|
||||
interfaceRegistry: interfaceRegistry,
|
||||
@ -115,10 +117,11 @@ func ProvideApp(interfaceRegistry codectypes.InterfaceRegistry) (
|
||||
amino: amino,
|
||||
basicManager: module.BasicManager{},
|
||||
msgServiceRouter: msgServiceRouter,
|
||||
grpcQueryRouter: grpcQueryRouter,
|
||||
}
|
||||
appBuilder := &AppBuilder{app}
|
||||
|
||||
return cdc, amino, appBuilder, msgServiceRouter, appModule{app}, protoFiles, protoTypes, nil
|
||||
return cdc, amino, appBuilder, msgServiceRouter, grpcQueryRouter, appModule{app}, protoFiles, protoTypes, nil
|
||||
}
|
||||
|
||||
type AppInputs struct {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user