Merge pull request #4531 from twt--/arbitrum

Add arbitrum support

CHANGELOG.md

@@ -1,6 +1,7 @@
 ## Current
 
 ### Features
+- [#4531](https://github.com/blockscout/blockscout/pull/4531) - Add Arbitrum support
 - [#4524](https://github.com/blockscout/blockscout/pull/4524) - Add index position of transaction in the block
 - [#4489](https://github.com/blockscout/blockscout/pull/4489) - Search results page
 - [#4475](https://github.com/blockscout/blockscout/pull/4475) - Tx page facelifting

apps/ethereum_jsonrpc/lib/ethereum_jsonrpc/arbitrum.ex

@@ -0,0 +1,47 @@
+defmodule EthereumJSONRPC.Arbitrum do
+  @moduledoc """
+  Ethereum JSONRPC methods that are only supported by [Arbitrum L2]https://github.com/OffchainLabs/arbitrum).
+  """
+
+  @behaviour EthereumJSONRPC.Variant
+
+  @doc """
+  Block reward contract beneficiary fetching is not supported currently for Arbitrum L2.
+
+  To signal to the caller that fetching is not supported, `:ignore` is returned.
+  """
+  @impl EthereumJSONRPC.Variant
+  def fetch_beneficiaries(_block_range, _json_rpc_named_arguments), do: :ignore
+
+  @doc """
+  Internal transaction fetching is not currently supported for Arbitrum L2.
+
+  To signal to the caller that fetching is not supported, `:ignore` is returned.
+  """
+  @impl EthereumJSONRPC.Variant
+  def fetch_internal_transactions(_transactions_params, _json_rpc_named_arguments), do: :ignore
+
+  @doc """
+  Internal transaction fetching is not currently supported for Arbitrum L2.
+
+  To signal to the caller that fetching is not supported, `:ignore` is returned.
+  """
+  @impl EthereumJSONRPC.Variant
+  def fetch_block_internal_transactions(_block_range, _json_rpc_named_arguments), do: :ignore
+
+  @doc """
+  Pending transaction fetching is not supported currently for Arbitrum L2.
+
+  To signal to the caller that fetching is not supported, `:ignore` is returned.
+  """
+  @impl EthereumJSONRPC.Variant
+  def fetch_pending_transactions(_json_rpc_named_arguments), do: :ignore
+
+  @doc """
+  Traces are not supported currently for Arbitrum L2.
+
+  To signal to the caller that fetching is not supported, `:ignore` is returned.
+  """
+  @impl EthereumJSONRPC.Variant
+  def fetch_first_trace(_transactions_params, _json_rpc_named_arguments), do: :ignore
+end

apps/ethereum_jsonrpc/lib/ethereum_jsonrpc/block.ex

@@ -505,4 +505,10 @@ defmodule EthereumJSONRPC.Block do
   defp entry_to_elixir({"transactions" = key, transactions}) do
     {key, Transactions.to_elixir(transactions)}
   end
+
+  # Arbitrum fields
+  defp entry_to_elixir({"l1BlockNumber", _}) do
+    {:ignore, :ignore}
+  end
+
 end

apps/ethereum_jsonrpc/lib/ethereum_jsonrpc/receipt.ex

@@ -299,6 +299,11 @@ defmodule EthereumJSONRPC.Receipt do
     :ignore
   end
 
+  # Arbitrum fields
+  defp entry_to_elixir({key, _}) when key in ~w(returnData returnCode feeStats l1BlockNumber) do
+    :ignore
+  end
+
   defp entry_to_elixir({key, value}) do
     {:error, {:unknown_key, %{key: key, value: value}}}
   end

apps/explorer/config/dev/arbitrum.exs

@@ -0,0 +1,20 @@
+use Mix.Config
+
+config :explorer,
+  json_rpc_named_arguments: [
+    transport: EthereumJSONRPC.HTTP,
+    transport_options: [
+      http: EthereumJSONRPC.HTTP.HTTPoison,
+      url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:7545",
+      http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: [pool: :ethereum_jsonrpc]]
+    ],
+    variant: EthereumJSONRPC.Arbitrum
+  ],
+  subscribe_named_arguments: [
+    transport: EthereumJSONRPC.WebSocket,
+    transport_options: [
+      web_socket: EthereumJSONRPC.WebSocket.WebSocketClient,
+      url: System.get_env("ETHEREUM_JSONRPC_WS_URL")
+    ],
+    variant: EthereumJSONRPC.Arbitrum
+  ]

apps/explorer/config/prod/arbitrum.exs

@@ -0,0 +1,20 @@
+use Mix.Config
+
+config :explorer,
+  json_rpc_named_arguments: [
+    transport: EthereumJSONRPC.HTTP,
+    transport_options: [
+      http: EthereumJSONRPC.HTTP.HTTPoison,
+      url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL"),
+      http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: [pool: :ethereum_jsonrpc]]
+    ],
+    variant: EthereumJSONRPC.Arbitrum
+  ],
+  subscribe_named_arguments: [
+    transport: EthereumJSONRPC.WebSocket,
+    transport_options: [
+      web_socket: EthereumJSONRPC.WebSocket.WebSocketClient,
+      url: System.get_env("ETHEREUM_JSONRPC_WS_URL")
+    ],
+    variant: EthereumJSONRPC.Arbitrum
+  ]

apps/explorer/config/test/arbitrum.exs

@@ -0,0 +1,13 @@
+use Mix.Config
+
+config :explorer,
+  json_rpc_named_arguments: [
+    transport: EthereumJSONRPC.Mox,
+    transport_options: [],
+    variant: EthereumJSONRPC.Arbitrum
+  ],
+  subscribe_named_arguments: [
+    transport: EthereumJSONRPC.Mox,
+    transport_options: [],
+    variant: EthereumJSONRPC.Arbitrum
+  ]

apps/explorer/lib/explorer/chain.ex

@@ -954,7 +954,7 @@ defmodule Explorer.Chain do
     json_rpc_named_arguments = Application.fetch_env!(:indexer, :json_rpc_named_arguments)
     variant = Keyword.fetch!(json_rpc_named_arguments, :variant)
 
-    if variant == EthereumJSONRPC.Ganache do
+    if variant == EthereumJSONRPC.Ganache || variant == EthereumJSONRPC.Arbitrum do
       true
     else
       with {:transactions_exist, true} <- {:transactions_exist, Repo.exists?(Transaction)},

apps/indexer/config/dev/arbitrum.exs

@@ -0,0 +1,26 @@
+use Mix.Config
+
+config :indexer,
+  block_interval: :timer.seconds(5),
+  json_rpc_named_arguments: [
+    transport:
+      if(System.get_env("ETHEREUM_JSONRPC_TRANSPORT", "http") == "http",
+        do: EthereumJSONRPC.HTTP,
+        else: EthereumJSONRPC.IPC
+      ),
+    transport_options: [
+      http: EthereumJSONRPC.HTTP.HTTPoison,
+      url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:7545",
+      http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: [pool: :ethereum_jsonrpc]]
+    ],
+    variant: EthereumJSONRPC.Arbitrum
+  ],
+  subscribe_named_arguments: [
+    transport:
+      System.get_env("ETHEREUM_JSONRPC_WS_URL") && System.get_env("ETHEREUM_JSONRPC_WS_URL") !== "" &&
+        EthereumJSONRPC.WebSocket,
+    transport_options: [
+      web_socket: EthereumJSONRPC.WebSocket.WebSocketClient,
+      url: System.get_env("ETHEREUM_JSONRPC_WS_URL")
+    ]
+  ]

apps/indexer/config/prod/arbitrum.exs

@@ -0,0 +1,26 @@
+use Mix.Config
+
+config :indexer,
+  block_interval: :timer.seconds(5),
+  json_rpc_named_arguments: [
+    transport:
+      if(System.get_env("ETHEREUM_JSONRPC_TRANSPORT", "http") == "http",
+        do: EthereumJSONRPC.HTTP,
+        else: EthereumJSONRPC.IPC
+      ),
+    transport_options: [
+      http: EthereumJSONRPC.HTTP.HTTPoison,
+      url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:7545",
+      http_options: [recv_timeout: :timer.minutes(5), timeout: :timer.minutes(5), hackney: [pool: :ethereum_jsonrpc]]
+    ],
+    variant: EthereumJSONRPC.Arbitrum
+  ],
+  subscribe_named_arguments: [
+    transport:
+      System.get_env("ETHEREUM_JSONRPC_WS_URL") && System.get_env("ETHEREUM_JSONRPC_WS_URL") !== "" &&
+        EthereumJSONRPC.WebSocket,
+    transport_options: [
+      web_socket: EthereumJSONRPC.WebSocket.WebSocketClient,
+      url: System.get_env("ETHEREUM_JSONRPC_WS_URL")
+    ]
+  ]

apps/indexer/config/test/arbitrum.exs

@@ -0,0 +1,8 @@
+use Mix.Config
+
+config :indexer,
+  json_rpc_named_arguments: [
+    transport: EthereumJSONRPC.Mox,
+    transport_options: [],
+    variant: EthereumJSONRPC.Arbitrum
+  ]