Create BroadcastImportedBlock event.

trinity/components/builtin/new_block/component.py

@@ -31,7 +31,7 @@
     ETHProxyPeerPool,
     ETHProxyPeer,
 )
-from trinity.sync.common.events import StatelessBlockImportDone
+from trinity.sync.common.events import BroadcastImportedBlock
 from trinity._utils.logging import get_logger
 
 
@@ -71,13 +71,7 @@ async def run(self) -> None:
             self.manager.run_task(self._handle_new_block, event.session, event.command.payload)
 
     async def _handle_imported_blocks(self) -> None:
-        async for event in self._event_bus.stream(StatelessBlockImportDone):
-            if not event.completed:
-                self.logger.info(
-                    "Stateless block import was not completed, skipping broadcast to peers."
-                )
-                return
-
+        async for event in self._event_bus.stream(BroadcastImportedBlock):
             await self._broadcast_imported_block(event.block)
 
     async def _handle_new_block(self, sender: SessionAPI, block: NewBlockPayload) -> None:

trinity/sync/beam/importer.py

@@ -53,6 +53,7 @@
 
 from trinity._utils.timer import Timer
 from trinity.chains.full import FullChain
+from trinity.constants import FIRE_AND_FORGET_BROADCASTING
 from trinity.exceptions import StateUnretrievable
 from trinity.sync.beam.constants import (
     BLOCK_IMPORT_MISSING_STATE_TIMEOUT,
@@ -61,6 +62,7 @@
     NUM_PREVIEW_SHARDS,
 )
 from trinity.sync.common.events import (
+    BroadcastImportedBlock,
     CollectMissingAccount,
     CollectMissingBytecode,
     CollectMissingStorage,
@@ -491,8 +493,15 @@ def _broadcast_import_complete(
             future.result() if completed else None,
             future.exception() if completed else None,
         ),
-        # broadcast_config,
+        broadcast_config,
     )
+    if completed:
+        event_bus.broadcast_nowait(
+            BroadcastImportedBlock(
+                block,
+            ),
+            FIRE_AND_FORGET_BROADCASTING,
+        )
 
 
 def partial_import_block(beam_chain: BeamChain,

trinity/sync/common/events.py

@@ -140,6 +140,17 @@ class StatelessBlockImportDone(BaseEvent):
     exception: BaseException
 
 
+@dataclass
+class BroadcastImportedBlock(BaseEvent):
+    """
+    Event that is only emitted after a new block has been successfully imported.
+    This event communicates to the `NewBlockComponent` that a block is ready to
+    be broadcast to eligible peers.
+    """
+
+    block: BlockAPI
+
+
 @dataclass
 class DoStatelessBlockImport(BaseRequestResponseEvent[StatelessBlockImportDone]):
     """