Merge pull request #8752 from blockscout/np-add-switcher-for-nft-migr…

…ator Add TOKEN_INSTANCE_OWNER_MIGRATION_ENABLED env
blockscout · Oct 31, 2023 · c472f7b · c472f7b
2 parents 964fbc8 + 2d9112c
commit c472f7b
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 5 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -6,6 +6,7 @@
 
 ### Fixes
 
+- [#8752](https://github.com/blockscout/blockscout/pull/8752) - Add `TOKEN_INSTANCE_OWNER_MIGRATION_ENABLED` env
 - [#8724](https://github.com/blockscout/blockscout/pull/8724) - Fix flaky account notifier test
 
 ### Chore

diff --git a/apps/explorer/lib/explorer/token_instance_owner_address_migration/supervisor.ex b/apps/explorer/lib/explorer/token_instance_owner_address_migration/supervisor.ex
@@ -5,17 +5,19 @@ defmodule Explorer.TokenInstanceOwnerAddressMigration.Supervisor do
 
   use Supervisor
 
-  alias Explorer.TokenInstanceOwnerAddressMigration.{Helper, Worker}
+  alias Explorer.TokenInstanceOwnerAddressMigration.Worker
 
   def start_link(init_arg) do
     Supervisor.start_link(__MODULE__, init_arg, name: __MODULE__)
   end
 
   @impl true
   def init(_init_arg) do
-    if Helper.unfilled_token_instances_exists?() do
+    params = Application.get_env(:explorer, Explorer.TokenInstanceOwnerAddressMigration)
+
+    if params[:enabled] do
       children = [
-        {Worker, Application.get_env(:explorer, Explorer.TokenInstanceOwnerAddressMigration)}
+        {Worker, params}
       ]
 
       Supervisor.init(children, strategy: :one_for_one)

diff --git a/apps/explorer/lib/explorer/token_instance_owner_address_migration/worker.ex b/apps/explorer/lib/explorer/token_instance_owner_address_migration/worker.ex
@@ -14,7 +14,7 @@ defmodule Explorer.TokenInstanceOwnerAddressMigration.Worker do
   alias Explorer.Repo
   alias Explorer.TokenInstanceOwnerAddressMigration.Helper
 
-  def start_link(concurrency: concurrency, batch_size: batch_size) do
+  def start_link(concurrency: concurrency, batch_size: batch_size, enabled: _) do
     GenServer.start_link(__MODULE__, %{concurrency: concurrency, batch_size: batch_size}, name: __MODULE__)
   end
 

diff --git a/config/runtime.exs b/config/runtime.exs
@@ -433,7 +433,8 @@ config :explorer, Explorer.Chain.Cache.MinMissingBlockNumber,
 
 config :explorer, Explorer.TokenInstanceOwnerAddressMigration,
   concurrency: ConfigHelper.parse_integer_env_var("TOKEN_INSTANCE_OWNER_MIGRATION_CONCURRENCY", 5),
-  batch_size: ConfigHelper.parse_integer_env_var("TOKEN_INSTANCE_OWNER_MIGRATION_BATCH_SIZE", 50)
+  batch_size: ConfigHelper.parse_integer_env_var("TOKEN_INSTANCE_OWNER_MIGRATION_BATCH_SIZE", 50),
+  enabled: ConfigHelper.parse_bool_env_var("TOKEN_INSTANCE_OWNER_MIGRATION_ENABLED")
 
 config :explorer, Explorer.Chain.Transaction,
   rootstock_remasc_address: System.get_env("ROOTSTOCK_REMASC_ADDRESS"),