implement execution_payload_available event (#8043)

* implement execution payload available event

* review

* Revert "review"

This reverts commit 02b4686.

Author: Tomi-3-0

beacon_chain/consensus_object_pools/envelope_quarantine.nim

@@ -11,6 +11,9 @@ import std/tables
 import ../spec/[digest, forks]
 
 type
+  OnExecutionPayloadCallback* = proc(
+    data: ExecutionPayloadInfoObject) {.gcsafe, raises: [].}
+
   EnvelopeQuarantine* = object
     orphans*: Table[Eth2Digest, Table[uint64, SignedExecutionPayloadEnvelope]]
       ## Envelopes that we have received but did not have a block yet. In the
@@ -22,12 +25,19 @@ type
       ## have not got yet. Missing envelopes should usually be found when we
       ## received a block, blob or data column.
 
-func init*(T: typedesc[EnvelopeQuarantine]): T =
-  T()
+    onEnvelopeCallback*: OnExecutionPayloadCallback
+
+func init*(T: typedesc[EnvelopeQuarantine],
+    onEnvelopeCallback: OnExecutionPayloadCallback = nil): T =
+  T(onEnvelopeCallback: onEnvelopeCallback)
 
 template root(v: SignedExecutionPayloadEnvelope): Eth2Digest =
   v.message.beacon_block_root
 
+template onExecutionPayloadCallback*(
+    quarantine: EnvelopeQuarantine): OnExecutionPayloadCallback =
+  quarantine.onEnvelopeCallback
+
 func addMissing*(
     self: var EnvelopeQuarantine,
     root: Eth2Digest) =

beacon_chain/gossip_processing/gossip_validation.nim

@@ -1119,6 +1119,13 @@ proc validateExecutionPayload*(
       return dag.checkedReject("ExecutionPayload: invalid builder signature")
   else:
     return dag.checkedReject("ExecutionPayload: invalid fork")
+  
+  let onExecutionPayloadCallback =
+    envelopeQuarantine[].onExecutionPayloadCallback()
+  if not isNil(onExecutionPayloadCallback):
+    onExecutionPayloadCallback ExecutionPayloadInfoObject(
+      slot: envelope.slot,
+      block_root: envelope.beacon_block_root)
 
   ok()
 

beacon_chain/nimbus_beacon_node.nim

@@ -493,6 +493,8 @@ proc initFullNode(
       else:
         data
     node.eventBus.reorgQueue.emit(eventData)
+  proc onEnvelopeAdded(data: ExecutionPayloadInfoObject) =
+    node.eventBus.execPayloadAvlQueue.emit(data)
   proc makeOnFinalizationCb(
       # This `nimcall` functions helps for keeping track of what
       # needs to be captured by the onFinalization closure.
@@ -552,7 +554,7 @@ proc initFullNode(
   let
     quarantine = newClone(
       Quarantine.init(dag.cfg))
-    envelopeQuarantine = newClone(EnvelopeQuarantine.init())
+    envelopeQuarantine = newClone(EnvelopeQuarantine.init(onEnvelopeAdded))
     attestationPool = newClone(AttestationPool.init(
       dag, quarantine, getBeaconTime(), onSingleAttestationReceived))
     syncCommitteeMsgPool = newClone(