Merge branch 'develop' into peerDAS

prysmaticlabs · Jan 22, 2025 · 632a060 · 632a060
2 parents 242c2b0 + 7872223
commit 632a060
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 0 deletions.
diff --git a/beacon-chain/p2p/subnets.go b/beacon-chain/p2p/subnets.go
@@ -63,6 +63,8 @@ func (s *Service) nodeFilter(topic string, index uint64) (func(node *enode.Node)
 		return s.filterPeerForAttSubnet(index), nil
 	case strings.Contains(topic, GossipSyncCommitteeMessage):
 		return s.filterPeerForSyncSubnet(index), nil
+	case strings.Contains(topic, GossipBlobSidecarMessage):
+		return s.filterPeerForBlobSubnet(), nil
 	case strings.Contains(topic, GossipDataColumnSidecarMessage):
 		return s.filterPeerForDataColumnsSubnet(index), nil
 	default:
@@ -277,6 +279,14 @@ func (s *Service) filterPeerForSyncSubnet(index uint64) func(node *enode.Node) b
 	}
 }
 
+// returns a method with filters peers specifically for a particular blob subnet.
+// All peers are supposed to be subscribed to all blob subnets.
+func (s *Service) filterPeerForBlobSubnet() func(_ *enode.Node) bool {
+	return func(_ *enode.Node) bool {
+		return true
+	}
+}
+
 // returns a method with filters peers specifically for a particular data column subnet.
 func (s *Service) filterPeerForDataColumnsSubnet(index uint64) func(node *enode.Node) bool {
 	return func(node *enode.Node) bool {

diff --git a/changelog/manu_blob_subnets_node_filter.md b/changelog/manu_blob_subnets_node_filter.md
@@ -0,0 +1,3 @@
+### Fixed
+
+- `nodeFilter`: Implement `filterPeerForBlobSubnet` to avoid error logs.
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,3 @@
		### Fixed

		- `nodeFilter`: Implement `filterPeerForBlobSubnet` to avoid error logs.