subscribe to topic

beacon-chain/sync/payload_attestations.go

@@ -18,7 +18,6 @@ import (
 )
 
 var (
-	errInvalidValidatorIndex         = errors.New("invalid validator index")
 	errAlreadySeenPayloadAttestation = errors.New("payload attestation already seen for validator index")
 )
 

beacon-chain/sync/subscriber.go

@@ -145,6 +145,16 @@ func (s *Service) registerSubscribers(epoch primitives.Epoch, digest [4]byte) {
 			params.BeaconConfig().BlobsidecarSubnetCount,
 		)
 	}
+
+	// New Gossip Topic for ePBS
+	if epoch >= params.BeaconConfig().EPBSForkEpoch {
+		s.subscribe(
+			p2p.PayloadAttestationMessageTopicFormat,
+			s.validatePayloadAttestation,
+			s.payloadAttestationSubscriber,
+			digest,
+		)
+	}
 }
 
 // subscribe to a given topic with a given validator and subscription handler.