Tidying

eth/node_config.go

@@ -381,7 +381,6 @@ func desiredPubSubBaseTopics() []string {
  // we unfortunatelly can't validate the messages (yet)
  // thus, better not to forward invalid messages
  // p2p.GossipExitMessage,
- p2p.GossipExitMessage,
  p2p.GossipAttesterSlashingMessage,
  p2p.GossipProposerSlashingMessage,
  p2p.GossipContributionAndProofMessage,

eth/pubsub.go

@@ -110,8 +110,6 @@ func (p *PubSub) Serve(ctx context.Context) error {
 func (p *PubSub) mapPubSubTopicWithHandlers(topic string) host.TopicHandler {
  switch {
  // Ensure hotter topics are at the top of the switch statement.
- case strings.Contains(topic, p2p.GossipAttestationMessage):
- return p.handleBeaconAttestation
  case strings.Contains(topic, p2p.GossipDataColumnSidecarMessage):
  return p.handleBeaconDataColumnSidecar
  case strings.Contains(topic, p2p.GossipBlockMessage):
@@ -157,37 +155,6 @@ func (n *Node) FilterIncomingSubscriptions(id peer.ID, subs []*pubsubpb.RPC_SubO
  return pubsub.FilterSubscriptions(subs, n.CanSubscribe), nil
 }
 
-func (p *PubSub) handleBeaconAttestation(ctx context.Context, msg *pubsub.Message) error {
- now := time.Now()
-
- attestation := &ethtypes.Attestation{}
- if err := p.cfg.Encoder.DecodeGossip(msg.Data, attestation); err != nil {
- return fmt.Errorf("error decoding phase0 attestation gossip message: %w", err)
- }
-
- evt := &host.TraceEvent{
- Type: "HANDLE_MESSAGE",
- PeerID: p.host.ID(),
- Timestamp: now,
- Payload: map[string]any{
- "PeerID": msg.ReceivedFrom.String(),
- "MsgID": hex.EncodeToString([]byte(msg.ID)),
- "MsgSize": len(msg.Data),
- "Topic": msg.GetTopic(),
- "Seq": msg.GetSeqno(),
- "Attestation": attestation,
- "Timestamp": now,
- },
- }
-
- if err := p.cfg.DataStream.PutRecord(ctx, evt); err != nil {
- slog.Warn("failed putting topic handler event", tele.LogAttrError(err))
- }
-
- return nil
-
-}
-
 func (p *PubSub) handleBeaconDataColumnSidecar(ctx context.Context, msg *pubsub.Message) error {
  now := time.Now()