feat: script to update operator names in telemetry

Author: uri-99

Makefile

@@ -1116,6 +1116,10 @@ telemetry_compile_bls_verifier:
 	@cd telemetry_api/priv && \
 	go build ../bls_verifier/bls_verify.go
 
+telemetry_fetch_operators_metadata:
+	@cd telemetry_api && \
+		./scripts/fetch_operators_metadata.sh $(FROM_BLOCK)
+
 setup_local_aligned_all:
 	tmux kill-session -t aligned_layer || true
 	tmux new-session -d -s aligned_layer

telemetry_api/lib/scripts/fetch_operators_metadata.ex

@@ -0,0 +1,45 @@
+defmodule Scripts.FetchOperatorsMetadata do
+  require Logger
+  alias TelemetryApi.ContractManagers.OperatorStateRetriever
+  alias TelemetryApi.Operators.Operator
+  alias TelemetryApi.Repo
+
+  # This Script is to fetch operators metadata from the blockchain activity
+  # and insert/update them into the Ecto database
+
+  def run(fromBlock) do
+    "Fetching old operators changes" |> Logger.debug()
+    update_operators_metadata(fromBlock)
+
+    "Done" |> Logger.debug()
+  end
+
+  def update_operators_metadata(fromBlock) do
+    with {:ok, operators} <- OperatorStateRetriever.get_operators() do
+      # Construct tuple {%Operator{}, op_data}
+      operators = Enum.map(operators, fn op_data ->
+        {Repo.get(Operator, op_data.address), op_data}
+      end)
+
+      # Fetch metadata for all operators
+      operators = Enum.map(operators, fn {op, op_data} ->
+        case TelemetryApi.Operators.add_operator_metadata(op_data) do
+          {:ok, data} -> {:ok, {op, data}}
+          {:error, msg} -> {:error, msg}
+        end
+      end)
+        |> tap(&dbg/1)
+      # Filter status ok and map to {op, op_data}
+        |> Enum.filter(fn {status, _} -> status == :ok end)
+        |> Enum.map(fn {_, data} -> data end)
+
+      dbg(operators)
+
+      # Insert in db
+      Enum.map(operators, fn {op, op_data} ->
+        Operator.changeset(op, op_data) |> Repo.insert_or_update()
+      end)
+      end
+    :ok
+  end
+end

telemetry_api/lib/telemetry_api/operators.ex

@@ -116,7 +116,7 @@ defmodule TelemetryApi.Operators do
   #    iex> add_operator_metadata(operator)
   #    {:error, string}
   #
-  defp add_operator_metadata(op_data) do
+  def add_operator_metadata(op_data) do
     with {:ok, url} <- DelegationManager.get_operator_url(op_data.address),
          {:ok, metadata} <- TelemetryApi.Utils.fetch_json_data(url) do
       operator = %{

telemetry_api/scripts/fetch_operators_metadata.sh

@@ -0,0 +1,31 @@
+#!/bin/bash
+
+source .env
+
+export ENVIRONMENT=$ENVIRONMENT
+export RPC_URL=$RPC_URL
+ELIXIR_HOSTNAME=$(elixir -e 'IO.puts(:inet.gethostname() |> elem(1))')
+export ELIXIR_HOSTNAME=$ELIXIR_HOSTNAME
+export ALIGNED_CONFIG_FILE=$ALIGNED_CONFIG_FILE
+export OPERATOR_FETCHER_WAIT_TIME_MS=$OPERATOR_FETCHER_WAIT_TIME_MS
+
+if [ "$#" -eq 0 ]; then
+    echo "Error, No arguments provided."
+    echo "Try running the make target with FROM_BLOCK=<n>"
+    exit 1
+elif [ "$#" -eq 1 ]; then
+    # argument provided, use it
+    FROM=$1
+else
+    echo "Please provide 1 arguments."
+    exit 1
+fi
+
+echo "Running fetch_operators_metadata.sh from block: $FROM"
+
+mix compile --force #force recompile to get the latest .env values
+
+echo "You will now connect to the Telemetry Node, make sure you run the following command inside it:"
+echo "Scripts.FetchOperatorsMetadata.run($FROM)"
+
+iex --sname fetch_operators_metadata --remsh telemetry@$ELIXIR_HOSTNAME