fix: pass FinalizeBlock request and response to ABCIListener (#18486)

Co-authored-by: Aleksandr Bezobchuk <alexanderbez@users.noreply.github.com>
2023-11-16 18:59:29 +00:00
parent 7a28425874
commit a27cfa067a
2 changed files with 9 additions and 0 deletions
@@ -891,6 +891,14 @@ func (app *BaseApp) FinalizeBlock(req *abci.RequestFinalizeBlock) (*abci.Respons
 	if res != nil {
 		res.AppHash = app.workingHash()
 	}
+
+	// call the streaming service hooks with the FinalizeBlock messages
+	for _, streamingListener := range app.streamingManager.ABCIListeners {
+		if err := streamingListener.ListenFinalizeBlock(app.finalizeBlockState.ctx, *req, *res); err != nil {
+			app.logger.Error("ListenFinalizeBlock listening hook failed", "height", req.Height, "err", err)
+		}
+	}
+
 	return res, err
 }