Merge branch 'feat/aggregation-mode-explorer' into feat/aggregation-mode-explorer-views

Author: MarcosNicolau

explorer/lib/explorer/beacon_client.ex

@@ -53,7 +53,7 @@ defmodule Explorer.BeaconClient do
     beacon_get("/eth/v1/beacon/blob_sidecars/#{slot}")
   end
 
-  def beacon_get(method) do
+  defp beacon_get(method) do
     headers = [{"Content-Type", "application/json"}]
     request = Finch.build(:get, "#{@beacon_url}#{method}", headers)
     response = Finch.request(request, Explorer.Finch)

explorer/lib/explorer/eth_client.ex

@@ -6,7 +6,7 @@ defmodule Explorer.EthClient do
     eth_send("eth_getBlockByNumber", [block_number, false])
   end
 
-  def eth_send(method, params, id \\ 1) do
+  defp eth_send(method, params, id \\ 1) do
     headers = [{"Content-Type", "application/json"}]
     body = Jason.encode!(%{jsonrpc: "2.0", method: method, params: params, id: id})
     request = Finch.build(:post, @rpc_url, headers, body)

explorer/lib/explorer/periodically.ex

@@ -22,7 +22,7 @@ defmodule Explorer.Periodically do
     :timer.send_interval(one_second * 12, :batches)
     # every 1 hour
     :timer.send_interval(one_second * seconds_in_an_hour, :restakings)
-    :timer.send_interval(one_second * 12, :aggregated_proofs)
+    :timer.send_interval(one_second * seconds_in_an_hour, :aggregated_proofs)
   end
 
   # Reads and process last blocks for operators and restaking changes
@@ -74,7 +74,9 @@ defmodule Explorer.Periodically do
   end
 
   def handle_info(:aggregated_proofs, state) do
-    read_block_qty = 50000
+    # This task runs every hour
+    # We read a bit more than 300 blocks (1hr) to make sure we don't lose any event
+    read_block_qty = 310
     latest_block_number = AlignedLayerServiceManager.get_latest_block_number()
     read_from_block = max(0, latest_block_number - read_block_qty)