fix: pass FinalizeBlock request and response to ABCIListener

cosmos · Nov 16, 2023 · 9143e38 · 9143e38
1 parent c106c56
commit 9143e38
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/baseapp/abci.go b/baseapp/abci.go
@@ -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 {
+			panic(fmt.Errorf("ListenFinalizeBlock listening hook failed, height: %d, err: %w", req.Height, err))
+		}
+	}
+
 	return res, err
 }