consensus: remove reactor options (#7526)

internal/consensus/reactor.go

@@ -82,8 +82,6 @@ const (
 	listenerIDConsensus = "consensus-reactor"
 )
 
-type ReactorOption func(*Reactor)
-
 // NOTE: Temporary interface for switching to block sync, we should get rid of v0.
 // See: https://github.com/tendermint/tendermint/issues/4595
 type BlockSyncReactor interface {
@@ -141,7 +139,7 @@ func NewReactor(
 	voteSetBitsCh *p2p.Channel,
 	peerUpdates *p2p.PeerUpdates,
 	waitSync bool,
-	options ...ReactorOption,
+	metrics *Metrics,
 ) *Reactor {
 
 	r := &Reactor{
@@ -149,7 +147,7 @@ func NewReactor(
 		state:         cs,
 		waitSync:      waitSync,
 		peers:         make(map[types.NodeID]*PeerState),
-		Metrics:       NopMetrics(),
+		Metrics:       metrics,
 		stateCh:       stateCh,
 		dataCh:        dataCh,
 		voteCh:        voteCh,
@@ -158,10 +156,6 @@ func NewReactor(
 	}
 	r.BaseService = *service.NewBaseService(logger, "Consensus", r)
 
-	for _, opt := range options {
-		opt(r)
-	}
-
 	return r
 }
 
@@ -236,11 +230,6 @@ func (r *Reactor) WaitSync() bool {
 	return r.waitSync
 }
 
-// ReactorMetrics sets the reactor's metrics as an option function.
-func ReactorMetrics(metrics *Metrics) ReactorOption {
-	return func(r *Reactor) { r.Metrics = metrics }
-}
-
 // SwitchToConsensus switches from block-sync mode to consensus mode. It resets
 // the state, turns off block-sync, and starts the consensus state-machine.
 func (r *Reactor) SwitchToConsensus(ctx context.Context, state sm.State, skipWAL bool) {

internal/consensus/reactor_test.go

@@ -96,6 +96,7 @@ func setup(
 			rts.voteSetBitsChannels[nodeID],
 			node.MakePeerUpdates(ctx, t),
 			true,
+			NopMetrics(),
 		)
 
 		reactor.SetEventBus(state.eventBus)

node/setup.go

@@ -334,7 +334,7 @@ func createConsensusReactor(
 		channels[consensus.VoteSetBitsChannel],
 		peerManager.Subscribe(ctx),
 		waitSync,
-		consensus.ReactorMetrics(csMetrics),
+		csMetrics,
 	)
 
 	// Services which will be publishing and/or subscribing for messages (events)