pr: dag init (#8090)

Author: ahshum

beacon_chain/consensus_object_pools/blockchain_dag.nim

@@ -1187,10 +1187,17 @@ proc init*(T: type ChainDAGRef, cfg: RuntimeConfig, db: BeaconChainDB,
     var info: ForkedEpochInfo
 
     while headBlocks.len > 0:
+      let blck = headBlocks.pop()
       dag.applyBlock(
-        dag.headState, headBlocks.pop().bid, cache,
+        dag.headState, blck.bid, cache,
         info, dag.updateFlags).expect("head blocks should apply")
 
+      dag.applyExecutionPayloadEnvelope(dag.headState, blck.bid, cache).isOkOr:
+        # Since Gloas, envelopes can only be missing at the head block.
+        if blck != headRef:
+          error "Envelope is missing for non-head block. Database may be corrupted"
+          quit 1
+
     dag.head = headRef
     dag.heads = @[headRef]
 

beacon_chain/consensus_object_pools/envelope_quarantine.nim

@@ -7,8 +7,11 @@
 
 {.push raises: [], gcsafe.}
 
-import std/tables
-import ../spec/[digest, forks]
+import
+  std/tables,
+  ./block_dag,
+  ../beacon_chain_db,
+  ../spec/[digest, forks]
 from std/sequtils import addUnique, keepItIf
 
 type
@@ -91,3 +94,8 @@ func cleanupOrphans*(self: var EnvelopeQuarantine, finalizedSlot: Slot) =
 
   for k in toDel:
     self.orphans.del(k)
+
+proc checkIfMissingHeadEnvelope*(
+    self: var EnvelopeQuarantine, db: BeaconChainDB, head: BlockRef) =
+  if not db.containsExecutionPayloadEnvelope(head.root()):
+    self.addMissing(head.root())

beacon_chain/nimbus_beacon_node.nim

@@ -921,6 +921,11 @@ proc initFullNode(
                                                 node.dataColumnQuarantine)
   node.router = router
 
+  # DAG doesn't have access to quarantine. So checking for missing head
+  # envelope in beacon node start up process.
+  if dag.cfg.consensusForkAtEpoch(dag.head.slot().epoch()) >= ConsensusFork.Gloas:
+    envelopeQuarantine[].checkIfMissingHeadEnvelope(dag.db, dag.head)
+
   await node.addValidators()
 
   block: