feat: aligned proof aggregation model and contract interface

Author: MarcosNicolau

explorer/lib/explorer/contract_managers/aligned_proof_aggregation_service.ex

@@ -0,0 +1,61 @@
+defmodule AlignedProofAggregationService do
+  require Logger
+
+  @aligned_config_file System.get_env("ALIGNED_PROOF_AGG_CONFIG_FILE")
+
+  config_file_path =
+    case @aligned_config_file do
+      nil -> raise("ALIGNED_PROOF_AGG_CONFIG_FILE not set in .env")
+      file -> file
+    end
+
+  {status, config_json_string} = File.read(config_file_path)
+
+  case status do
+    :ok ->
+      Logger.debug("Aligned deployment file read successfully")
+
+    :error ->
+      raise(
+        "Config file not read successfully, make sure your .env is correctly created, and make sure Eigenlayer config file is correctly stored"
+      )
+  end
+
+  @contract_address Jason.decode!(config_json_string)
+                    |> Map.get("addresses")
+                    |> Map.get("alignedProofAggregationService")
+
+  use Ethers.Contract,
+    abi_file: "lib/abi/AlignedProofAggregationService.json",
+    default_address: @contract_address
+
+  def get_address() do
+    @contract_address
+  end
+
+  def get_aggregated_proof_event(%{from_block: number, to_block: number}) do
+    events =
+      AlignedProofAggregationService.EventFilters.new_batch_v3(nil)
+      |> Ethers.get_logs(fromBlock: fromBlock, toBlock: toBlock)
+
+    [
+      %{
+        number: 0,
+        status: 0,
+        merkle_root: "",
+        block_number: 0,
+        tx_hash: "",
+        tx_timestamp: "",
+        blob_versioned_hash: ""
+      }
+    ]
+  end
+
+  def get_blob_data_from_versioned_hash(versioned_hash) do
+    # Fetch blob data from a beacon client
+    "Getting blob data from blob versioned hash: #{versioned_hash}" |> Logger.debug()
+    # List of bytes
+    blob_data = []
+    blob_data
+  end
+end

explorer/lib/explorer/models/aggregated_proofs.ex

@@ -0,0 +1,82 @@
+defmodule AggregatedProofs do
+  require Logger
+  use Ecto.Schema
+  import Ecto.Changeset
+  import Ecto.Query
+
+  # Different from proofs.ex (we could use the same but the hashes are constructed differently)
+  @primary_key {:id, :integer, autogenerate: true}
+  schema "proofs_agg_mode" do
+    field(:aggregated_proof_number, :integer)
+    field(:proof_hash, :string)
+  end
+
+  def changeset_proof(proof, attrs) do
+    proofs
+    |> cast(attrs, [:aggregated_proof_number, :proof_hash])
+    |> validate_required([:aggregated_proof_number, :proof_hash])
+  end
+
+  @primary_key {:number, :integer, autogenerate: false}
+  schema "aggregated_proofs" do
+    field(:merkle_root, :string)
+    field(:status, :integer)
+    field(:tx_hash, :string)
+    field(:blob_versioned_hash, :string)
+    field(:blob_data, :binary)
+    field(:number_of_proofs, :integer)
+    field(:block_number, :integer)
+    field(:tx_timestamp, :utc_datetime)
+
+    timestamps()
+  end
+
+  @doc """
+  Creates a changeset based on the given `attrs`.
+  """
+  def changeset(aggregated_proof, attrs) do
+    aggregated_proof
+    |> cast(attrs, [
+      :number,
+      :merkle_root,
+      :status,
+      :tx_hash,
+      :blob_versioned_hash,
+      :blob_data,
+      :number_of_proofs,
+      :block_number,
+      :tx_timestamp
+    ])
+    |> validate_required([
+      :number,
+      :merkle_root,
+      :status,
+      :tx_hash,
+      :blob_versioned_hash,
+      :number_of_proofs,
+      :block_number,
+      :tx_timestamp
+    ])
+    |> unique_constraint(:number)
+  end
+
+  def insert_or_update(agg_proof) do
+    changeset = AggregatedProofs.changeset(%AggregatedProofs{}, Map.from_struct(agg_proof))
+
+    case Explorer.Repo.get_by(AggregatedProofs, number: agg_proof.number) do
+      nil ->
+        Explorer.Repo.insert(changeset)
+
+      existing_agg_proof ->
+        "Updating aggregated proof" |> Logger.debug()
+
+        Ecto.Changeset.change(existing_agg_proof, changeset.changes)
+        |> Explorer.Repo.update()
+    end
+  end
+
+  def insert_proof(proof) do
+    changeset = changeset_proof(proof)
+    Explorer.Repo.insert(changeset)
+  end
+end