refactor: move subscriptions directly to operations_collector (#1052)

Author: avilagaston9

lib/lambda_ethereum_consensus/beacon/beacon_node.ex

@@ -50,10 +50,10 @@ defmodule LambdaEthereumConsensus.Beacon.BeaconNode do
         LambdaEthereumConsensus.P2P.IncomingRequests,
         LambdaEthereumConsensus.Beacon.PendingBlocks,
         LambdaEthereumConsensus.Beacon.SyncBlocks,
-        LambdaEthereumConsensus.P2P.GossipSub,
         LambdaEthereumConsensus.P2P.Gossip.Attestation,
         LambdaEthereumConsensus.P2P.Gossip.BeaconBlock,
-        LambdaEthereumConsensus.P2P.Gossip.BlobSideCar
+        LambdaEthereumConsensus.P2P.Gossip.BlobSideCar,
+        LambdaEthereumConsensus.P2P.Gossip.OperationsCollector
       ] ++ validator_children
 
     Supervisor.init(children, strategy: :one_for_all)

lib/lambda_ethereum_consensus/beacon/sync_blocks.ex

@@ -73,14 +73,19 @@ defmodule LambdaEthereumConsensus.Beacon.SyncBlocks do
 
     if Enum.empty?(chunks) do
       Logger.info("[Optimistic Sync] Sync completed")
-      Gossip.BeaconBlock.start()
-      Gossip.BlobSideCar.start()
+      start_subscriptions()
     else
       Process.sleep(1000)
       perform_sync(remaining_chunks)
     end
   end
 
+  defp start_subscriptions() do
+    Gossip.BeaconBlock.start()
+    Gossip.BlobSideCar.start()
+    Gossip.OperationsCollector.start()
+  end
+
   @spec fetch_blocks_by_slot(Types.slot(), non_neg_integer()) ::
           {:ok, [SignedBeaconBlock.t()]} | {:error, String.t()}
   def fetch_blocks_by_slot(from, count) do