Node: Add cutover feature flags to heartbeats (#4092)

node/pkg/node/options.go

@@ -103,6 +103,7 @@ func GuardianOptionP2P(
  ccqBootstrapPeers,
  ccqPort,
  ccqAllowedPeers),
+ p2p.WithProcessorFeaturesFunc(processor.GetFeatures),
  )
  if err != nil {
  return err

node/pkg/p2p/p2p.go

@@ -528,6 +528,15 @@ func Run(params *RunParams) func(ctx context.Context) error {
  }
 
  features := make([]string, 0)
+ if GossipCutoverComplete() {
+ features = append(features, "p2p:new_gossip")
+ }
+ if params.processorFeaturesFunc != nil {
+ flag := params.processorFeaturesFunc()
+ if flag != "" {
+ features = append(features, flag)
+ }
+ }
  if params.gov != nil {
  if params.gov.IsFlowCancelEnabled() {
  features = append(features, "governor:fc")

node/pkg/p2p/run_params.go

@@ -55,6 +55,7 @@ type (
  gov *governor.ChainGovernor
  components *Components
  ibcFeaturesFunc func() string
+ processorFeaturesFunc func() string
  gatewayRelayerEnabled bool
  ccqEnabled bool
  signedQueryReqC chan<- *gossipv1.SignedQueryRequest
@@ -108,6 +109,14 @@ func WithComponents(components *Components) RunOpt {
  }
 }
 
+// WithProcessorFeaturesFunc is used to set the processor features function.
+func WithProcessorFeaturesFunc(processorFeaturesFunc func() string) RunOpt {
+ return func(p *RunParams) error {
+ p.processorFeaturesFunc = processorFeaturesFunc
+ return nil
+ }
+}
+
 // WithSignedObservationListener is used to set the channel to receive `SignedObservation` messages.
 func WithSignedObservationListener(obsvRecvC chan<- *common.MsgWithTimeStamp[gossipv1.SignedObservation]) RunOpt {
  return func(p *RunParams) error {

node/pkg/processor/processor.go

@@ -471,3 +471,11 @@ func (p *Processor) vaaWriter(ctx context.Context) error {
  }
  }
 }
+
+// GetFeatures returns the processor feature string that can be published in heartbeat messages.
+func GetFeatures() string {
+ if batchCutoverComplete() {
+ return "processor:batching"
+ }
+ return ""
+}