Merge pull request #1445 from poanetwork/disable-replaced-transaction-fetcher

feat: make replaced transactions disabled

apps/indexer/config/config.exs

@@ -35,6 +35,8 @@ config :indexer,
   # bytes
   memory_limit: 1 <<< 30
 
+# config :indexer, Indexer.ReplacedTransaction.Supervisor, disabled?: true
+
 config :indexer, Indexer.Tracer,
   service: :indexer,
   adapter: SpandexDatadog.Adapter,

apps/indexer/lib/indexer/replaced_transaction/fetcher.ex

@@ -10,6 +10,7 @@ defmodule Indexer.ReplacedTransaction.Fetcher do
   alias Explorer.Chain
   alias Explorer.Chain.Hash
   alias Indexer.{BufferedTask, Tracer}
+  alias Indexer.ReplacedTransaction.Supervisor, as: ReplacedTransactionSupervisor
 
   @behaviour BufferedTask
 
@@ -31,9 +32,12 @@ defmodule Indexer.ReplacedTransaction.Fetcher do
           }
         ]) :: :ok
   def async_fetch(transactions_fields, timeout \\ 5000) when is_list(transactions_fields) do
-    entries = Enum.map(transactions_fields, &entry/1)
-
-    BufferedTask.buffer(__MODULE__, entries, timeout)
+    if ReplacedTransactionSupervisor.disabled?() do
+      :ok
+    else
+      entries = Enum.map(transactions_fields, &entry/1)
+      BufferedTask.buffer(__MODULE__, entries, timeout)
+    end
   end
 
   @doc false

apps/indexer/lib/indexer/replaced_transaction/supervisor.ex

@@ -23,7 +23,15 @@ defmodule Indexer.ReplacedTransaction.Supervisor do
   end
 
   def start_link(arguments, gen_server_options \\ []) do
-    Supervisor.start_link(__MODULE__, arguments, Keyword.put_new(gen_server_options, :name, __MODULE__))
+    if disabled?() do
+      :ignore
+    else
+      Supervisor.start_link(__MODULE__, arguments, Keyword.put_new(gen_server_options, :name, __MODULE__))
+    end
+  end
+
+  def disabled?() do
+    Application.get_env(:indexer, __MODULE__, [])[:disabled?] == true
   end
 
   @impl Supervisor