save progress, add helpers

Author: agnxsh

beacon_chain/gossip_processing/gossip_validation.nim

@@ -241,6 +241,17 @@ proc check_data_column_sidecar_kzg_proofs(
 
   ok()
 
+proc check_partial_data_column_sidecar_kzg_proofs(
+    p_data_column: fulu.PartialDataColumnSidecar,
+    all_commitments: deneb.KzgCommitments):
+    Result[void, ValidationError] =
+  let res = p_data_column.verify_partial_data_column_sidecar_kzg_proofs(
+      all_commitments)
+  if res.isErr:
+    return errReject(res.error)
+
+  ok()
+
 # Gossip Validation
 # ----------------------------------------------------------------
 

beacon_chain/networking/eth2_network.nim

@@ -2856,6 +2856,15 @@ proc broadcastDataColumnSidecar*(
       node.forkDigestAtEpoch(contextEpoch), subnet_id)
   node.broadcast(topic, data_column)
 
+proc broadcastPartialDataColumnHeader*(
+    node: Eth2Node, subnet_id: uint64, p_data_column: fulu.PartialDataColumnHeader):
+    Future[SendResult] {.async: (raises: [CancelledError], raw: true).} =
+  let
+    contextEpoch = p_data_column.signed_block_header.message.slot.epoch
+    topic = getDataColumnSidecarTopic(
+      node.forkDigestAtEpoch(contextEpoch), subnet_id)
+  node.broadcast(topic, p_data_column)
+
 proc broadcastSyncCommitteeMessage*(
     node: Eth2Node, msg: SyncCommitteeMessage,
     subcommitteeIdx: SyncSubcommitteeIndex):

beacon_chain/spec/datatypes/fulu.nim

@@ -117,7 +117,7 @@ type
     kzg_proofs*: deneb.KzgProofs
 
   # https://github.com/MarcoPolo/consensus-specs/blob/ffee0018e44ba83da90ff41523a3ab88262e5a57/specs/fulu/p2p-interface.md#partialdatacolumnpartsmetadata
-  PartialDataColumnPartsMetadat* = object
+  PartialDataColumnPartsMetadata* = object
     available*: BitArray[int(MAX_BLOB_COMMITMENTS_PER_BLOCK)]
     requests*: BitArray[int(MAX_BLOB_COMMITMENTS_PER_BLOCK)]