From ab8b878f57a5e0b369c8727223e3af5d3ef34813 Mon Sep 17 00:00:00 2001 From: mmsqe Date: Fri, 28 Mar 2025 00:05:12 +0800 Subject: [PATCH] feat(baseapp): extend abci listeners in streaming manager (#24160) Co-authored-by: yihuang --- CHANGELOG.md | 1 + baseapp/baseapp.go | 4 ++++ 2 files changed, 5 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index 8f9376c1cb..703500df02 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -46,6 +46,7 @@ Every module contains its own CHANGELOG.md. Please refer to the module you are i * (client/keys) [#21829](https://github.com/cosmos/cosmos-sdk/pull/21829) Add support for importing hex key using standard input. * (x/auth/ante) [#23128](https://github.com/cosmos/cosmos-sdk/pull/23128) Allow custom verifyIsOnCurve when validate tx for public key like ethsecp256k1. * (x/auth/ante) [#23283](https://github.com/cosmos/cosmos-sdk/pull/23283) Allow ed25519 transaction signatures. +* (baseapp) [#24160](https://github.com/cosmos/cosmos-sdk/pull/24160) Add `StreamingManager` to baseapp to extend the abci listeners. ### Improvements diff --git a/baseapp/baseapp.go b/baseapp/baseapp.go index 455be68cdf..9e334d16b1 100644 --- a/baseapp/baseapp.go +++ b/baseapp/baseapp.go @@ -1217,6 +1217,10 @@ func (app *BaseApp) TxEncode(tx sdk.Tx) ([]byte, error) { return app.txEncoder(tx) } +func (app *BaseApp) StreamingManager() storetypes.StreamingManager { + return app.streamingManager +} + // Close is called in start cmd to gracefully cleanup resources. func (app *BaseApp) Close() error { var errs []error