feat: fetch aggregator from tx input signature for agg proofs

Author: MarcosNicolau

explorer/lib/explorer/contract_managers/aligned_proof_aggregation_service.ex

@@ -2,6 +2,8 @@ defmodule AlignedProofAggregationService do
   require Logger
 
   @aligned_config_file System.get_env("ALIGNED_PROOF_AGG_CONFIG_FILE")
+  @verifyRisc0_solidity_signature "0x015f8668"
+  @verifySp1_solidity_signature "0x39c94cbf"
 
   config_file_path =
     case @aligned_config_file do
@@ -66,6 +68,24 @@ defmodule AlignedProofAggregationService do
     end
   end
 
+  # From a given aggregated proof event, it fetches the transaction
+  # and returns the aggregator (:sp1, :risc0) based on the function signature
+  def get_aggregator!(agg_proof) do
+    tx_hash = agg_proof.tx_hash
+    {:ok, tx} = Explorer.EthClient.get_transaction_by_hash(tx_hash)
+    input = Map.get(tx, "input")
+    # In solidity, the function signatures are the first 4 bytes of the input
+    # Note: first two characters are the 0x
+    function_signature = String.slice(input, 0..9)
+    IO.inspect(function_signature, label: "SIGNATURE")
+
+    case function_signature do
+      @verifyRisc0_solidity_signature -> :risc0
+      @verifySp1_solidity_signature -> :sp1
+      _ -> nil
+    end
+  end
+
   def get_block_timestamp(block_number) do
     case Ethers.Utils.get_block_timestamp(block_number) do
       {:ok, timestamp} -> DateTime.from_unix!(timestamp)

explorer/lib/explorer/eth_client.ex

@@ -6,6 +6,10 @@ defmodule Explorer.EthClient do
     eth_send("eth_getBlockByNumber", [block_number, false])
   end
 
+  def get_transaction_by_hash(tx_hash) do
+    eth_send("eth_getTransactionByHash", [tx_hash])
+  end
+
   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})
@@ -15,9 +19,14 @@ defmodule Explorer.EthClient do
     case response do
       {:ok, %Finch.Response{status: 200, body: body}} ->
         case Jason.decode(body) do
-          {:ok, %{error: error} = _} -> {:error, error.message}
-          {:ok, body} -> {:ok, Map.get(body, "result")}
-          {:error, _} -> {:error, :invalid_json}
+          {:ok, %{"error" => %{"message" => message}}} ->
+            {:error, message}
+
+          {:ok, body} ->
+            {:ok, Map.get(body, "result")}
+
+          {:error, _} ->
+            {:error, :invalid_json}
         end
 
       {:ok, %Finch.Response{status: status}} ->

explorer/lib/explorer/periodically.ex

@@ -24,7 +24,7 @@ defmodule Explorer.Periodically do
     :timer.send_interval(one_second * seconds_in_an_hour, :restakings)
 
     # Fetch new aggregated proofs every 1 minute
-    :timer.send_interval(one_second * 60, :aggregated_proofs)
+    :timer.send_interval(one_second * 12, :aggregated_proofs)
   end
 
   # Reads and process last blocks for operators and restaking changes
@@ -78,11 +78,11 @@ defmodule Explorer.Periodically do
   def handle_info(:aggregated_proofs, state) do
     # 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
+    read_block_qty = 5000
     latest_block_number = AlignedLayerServiceManager.get_latest_block_number()
     read_from_block = max(0, latest_block_number - read_block_qty)
 
-    Task.start(fn -> process_aggregated_proofs(read_from_block, latest_block_number) end)
+    Task.start(fn -> process_aggregated_proofs(3_734_200, 3_734_500) end)
 
     {:noreply, state}
   end
@@ -113,8 +113,11 @@ defmodule Explorer.Periodically do
       proofs
       |> Enum.zip(proof_hashes)
       |> Enum.map(fn {agg_proof, hashes} ->
+        aggregator = AlignedProofAggregationService.get_aggregator!(agg_proof)
+
         agg_proof =
           agg_proof
+          |> Map.merge(%{aggregator: aggregator})
           |> Map.merge(%{number_of_proofs: length(hashes)})
 
         {:ok, %{id: id}} = AggregatedProofs.insert_or_update(agg_proof)

explorer/priv/repo/migrations/20250428144500_add_aggegator_to_agg_proofs.exs

@@ -0,0 +1,9 @@
+defmodule Explorer.Repo.Migrations.AddAggregatorToAggProofs do
+  use Ecto.Migration
+
+  def change do
+    alter table(:aggregated_proofs) do
+      add(:aggregator, :string, default: nil)
+    end
+  end
+end