Gossip DAS related changes

ethereum/spec/src/main/java/tech/pegasys/teku/spec/datastructures/networking/libp2p/rpc/GoodbyeMessage.java

@@ -48,6 +48,8 @@ public GoodbyeMessage createFromBackingNode(final TreeNode node) {
   public static final UInt64 REASON_UNABLE_TO_VERIFY_NETWORK = UInt64.valueOf(128);
   public static final UInt64 REASON_TOO_MANY_PEERS = UInt64.valueOf(129);
   public static final UInt64 REASON_RATE_LIMITING = UInt64.valueOf(130);
+  public static final UInt64 REASON_BAD_SCORE = UInt64.valueOf(250);
+  public static final UInt64 REASON_BANNED = UInt64.valueOf(251);
 
   private GoodbyeMessage(final GoodbyeMessageSchema type, final TreeNode backingNode) {
     super(type, backingNode);

ethereum/statetransition/src/main/java/tech/pegasys/teku/statetransition/CustodyGroupCountChannel.java

@@ -0,0 +1,32 @@
+/*
+ * Copyright Consensys Software Inc., 2025
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+
+package tech.pegasys.teku.statetransition;
+
+import tech.pegasys.teku.infrastructure.events.VoidReturningChannelInterface;
+
+public interface CustodyGroupCountChannel extends VoidReturningChannelInterface {
+
+  CustodyGroupCountChannel NOOP =
+      new CustodyGroupCountChannel() {
+        @Override
+        public void onCustodyGroupCountUpdate(final int groupCount) {}
+
+        @Override
+        public void onCustodyGroupCountSynced(final int groupCount) {}
+      };
+
+  void onCustodyGroupCountUpdate(int groupCount);
+
+  void onCustodyGroupCountSynced(int groupCount);
+}

ethereum/statetransition/src/main/java/tech/pegasys/teku/statetransition/datacolumns/CustodyGroupCountManager.java

@@ -0,0 +1,48 @@
+/*
+ * Copyright Consensys Software Inc., 2025
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+
+package tech.pegasys.teku.statetransition.datacolumns;
+
+import java.util.List;
+import tech.pegasys.teku.infrastructure.unsigned.UInt64;
+
+public interface CustodyGroupCountManager {
+  CustodyGroupCountManager NOOP =
+      new CustodyGroupCountManager() {
+        @Override
+        public int getCustodyGroupCount() {
+          return 0;
+        }
+
+        @Override
+        public List<UInt64> getCustodyColumnIndices() {
+          return List.of();
+        }
+
+        @Override
+        public int getCustodyGroupSyncedCount() {
+          return 0;
+        }
+
+        @Override
+        public void setCustodyGroupSyncedCount(int custodyGroupSyncedCount) {}
+      };
+
+  int getCustodyGroupCount();
+
+  List<UInt64> getCustodyColumnIndices();
+
+  int getCustodyGroupSyncedCount();
+
+  void setCustodyGroupSyncedCount(int custodyGroupSyncedCount);
+}

ethereum/statetransition/src/main/java/tech/pegasys/teku/statetransition/datacolumns/DataColumnSidecarByRootCustody.java

@@ -0,0 +1,59 @@
+/*
+ * Copyright Consensys Software Inc., 2024
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+
+package tech.pegasys.teku.statetransition.datacolumns;
+
+import java.util.Optional;
+import tech.pegasys.teku.infrastructure.async.SafeFuture;
+import tech.pegasys.teku.infrastructure.async.stream.AsyncStream;
+import tech.pegasys.teku.spec.datastructures.blobs.versions.fulu.DataColumnSidecar;
+import tech.pegasys.teku.spec.datastructures.util.DataColumnIdentifier;
+import tech.pegasys.teku.spec.datastructures.util.DataColumnSlotAndIdentifier;
+
+public interface DataColumnSidecarByRootCustody extends DataColumnSidecarCustody {
+
+  DataColumnSidecarByRootCustody NOOP =
+      new DataColumnSidecarByRootCustody() {
+        @Override
+        public SafeFuture<Optional<DataColumnSidecar>> getCustodyDataColumnSidecarByRoot(
+            DataColumnIdentifier columnId) {
+          return SafeFuture.completedFuture(Optional.empty());
+        }
+
+        @Override
+        public SafeFuture<Boolean> hasCustodyDataColumnSidecar(
+            DataColumnSlotAndIdentifier columnId) {
+          return SafeFuture.completedFuture(false);
+        }
+
+        @Override
+        public SafeFuture<Optional<DataColumnSidecar>> getCustodyDataColumnSidecar(
+            DataColumnSlotAndIdentifier columnId) {
+          return SafeFuture.completedFuture(Optional.empty());
+        }
+
+        @Override
+        public SafeFuture<Void> onNewValidatedDataColumnSidecar(
+            DataColumnSidecar dataColumnSidecar) {
+          return SafeFuture.COMPLETE;
+        }
+
+        @Override
+        public AsyncStream<DataColumnSlotAndIdentifier> retrieveMissingColumns() {
+          return AsyncStream.empty();
+        }
+      };
+
+  SafeFuture<Optional<DataColumnSidecar>> getCustodyDataColumnSidecarByRoot(
+      DataColumnIdentifier columnId);
+}

ethereum/statetransition/src/main/java/tech/pegasys/teku/statetransition/datacolumns/DataColumnSidecarCustody.java

@@ -0,0 +1,32 @@
+/*
+ * Copyright Consensys Software Inc., 2024
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+
+package tech.pegasys.teku.statetransition.datacolumns;
+
+import java.util.Optional;
+import tech.pegasys.teku.infrastructure.async.SafeFuture;
+import tech.pegasys.teku.infrastructure.async.stream.AsyncStream;
+import tech.pegasys.teku.spec.datastructures.blobs.versions.fulu.DataColumnSidecar;
+import tech.pegasys.teku.spec.datastructures.util.DataColumnSlotAndIdentifier;
+
+public interface DataColumnSidecarCustody {
+
+  SafeFuture<Optional<DataColumnSidecar>> getCustodyDataColumnSidecar(
+      DataColumnSlotAndIdentifier columnId);
+
+  SafeFuture<Boolean> hasCustodyDataColumnSidecar(DataColumnSlotAndIdentifier columnId);
+
+  SafeFuture<Void> onNewValidatedDataColumnSidecar(DataColumnSidecar dataColumnSidecar);
+
+  AsyncStream<DataColumnSlotAndIdentifier> retrieveMissingColumns();
+}