Bridged tokens status fetcher refactoring

CHANGELOG.md

@@ -6,6 +6,7 @@
 - [#3261](https://github.com/poanetwork/blockscout/pull/3261) - Bridged tokens table
 
 ### Fixes
+- [#3276](https://github.com/poanetwork/blockscout/pull/3276) - Bridged tokens status/metadata fetcher refactoring
 - [#3264](https://github.com/poanetwork/blockscout/pull/3264) - Fix encoding of address output if function input exists
 - [#3259](https://github.com/poanetwork/blockscout/pull/3259), [#3269](https://github.com/poanetwork/blockscout/pull/3269) - Contract interaction: array input type parsing fix
 - [#3257](https://github.com/poanetwork/blockscout/pull/3257) - Contracts read/write: method_id instead function_name as a key

apps/explorer/lib/explorer/chain.ex

@@ -3581,11 +3581,11 @@ defmodule Explorer.Chain do
   end
 
   @doc """
-  Fetches bridges status for tokens.
+  Fetches bridged status for tokens and metadata.
   """
   def fetch_tokens_bridged_status(token_addresses) do
     Enum.each(token_addresses, fn token_address_hash ->
-      created_from_factory_query =
+      created_from_int_tx_success_query =
         from(
           it in InternalTransaction,
           inner_join: t in assoc(it, :transaction),
@@ -3593,13 +3593,53 @@ defmodule Explorer.Chain do
           where: t.status == ^1
         )
 
-      created_from_factory =
-        created_from_factory_query
+      created_from_int_tx_success =
+        created_from_int_tx_success_query
         |> Repo.one()
 
-      if created_from_factory do
+      created_from_tx_query =
+        from(
+          t in Transaction,
+          where: t.created_contract_address_hash == ^token_address_hash
+        )
+
+      created_from_tx =
+        created_from_tx_query
+        |> Repo.all()
+        |> Enum.count() > 0
+
+      created_from_int_tx_query =
+        from(
+          it in InternalTransaction,
+          where: it.created_contract_address_hash == ^token_address_hash
+        )
+
+      created_from_int_tx =
+        created_from_int_tx_query
+        |> Repo.all()
+        |> Enum.count() > 0
+
+      cond do
+        created_from_tx ->
+          set_token_bridged_status(token_address_hash, false)
+
+        created_from_int_tx && !created_from_int_tx_success ->
+          set_token_bridged_status(token_address_hash, false)
+
+        created_from_int_tx && created_from_int_tx_success ->
+          extract_bridged_token_metadata_wrapper(token_address_hash, created_from_int_tx_success)
+
+        true ->
+          :ok
+      end
+    end)
+
+    :ok
+  end
+
+  defp extract_bridged_token_metadata_wrapper(token_address_hash, created_from_int_tx_success) do
     multi_token_bridge_mediator = Application.get_env(:block_scout_web, :multi_token_bridge_mediator)
-        %{transaction_hash: transaction_hash} = created_from_factory
+    %{transaction_hash: transaction_hash} = created_from_int_tx_success
 
     if multi_token_bridge_mediator && multi_token_bridge_mediator !== "" do
       {:ok, multi_token_bridge_mediator_hash} = Chain.string_to_address_hash(multi_token_bridge_mediator)
@@ -3616,6 +3656,18 @@ defmodule Explorer.Chain do
         |> Repo.all()
 
       if Enum.count(created_by_amb_mediator) > 0 do
+        extract_bridged_token_metadata(
+          token_address_hash,
+          multi_token_bridge_mediator,
+          multi_token_bridge_mediator_hash
+        )
+      else
+        set_token_bridged_status(token_address_hash, false)
+      end
+    end
+  end
+
+  defp extract_bridged_token_metadata(token_address_hash, multi_token_bridge_mediator, multi_token_bridge_mediator_hash) do
     json_rpc_named_arguments = Application.get_env(:explorer, :json_rpc_named_arguments)
     # keccak 256 from getTokenInterfacesVersion()
     get_token_interfaces_version_signature = "0x859ba28c"
@@ -3652,8 +3704,7 @@ defmodule Explorer.Chain do
            |> json_rpc(json_rpc_named_arguments) do
       "0x" <> foreign_token_address_no_prefix = foreign_token_address_abi_encoded
 
-              <<_prefix::binary-size(24), foreign_token_address_hash_string_raw::binary()>> =
-                foreign_token_address_no_prefix
+      <<_prefix::binary-size(24), foreign_token_address_hash_string_raw::binary()>> = foreign_token_address_no_prefix
 
       foreign_token_address_hash_string = "0x" <> foreign_token_address_hash_string_raw
 
@@ -3679,16 +3730,6 @@ defmodule Explorer.Chain do
 
       set_token_bridged_status(token_address_hash, true)
     end
-          else
-            set_token_bridged_status(token_address_hash, false)
-          end
-        end
-      else
-        set_token_bridged_status(token_address_hash, false)
-      end
-    end)
-
-    :ok
   end
 
   defp set_token_bridged_status(token_address_hash, status) do

apps/explorer/lib/explorer/chain/block/reward.ex

@@ -171,8 +171,13 @@ defmodule Explorer.Chain.Block.Reward do
             if payout_key_hash == @empty_address do
               mining_key
             else
-              {:ok, payout_key} = Chain.string_to_address_hash(payout_key_hash)
+              case Chain.string_to_address_hash(payout_key_hash) do
+                {:ok, payout_key} ->
                   payout_key
+
+                _ ->
+                  mining_key
+              end
             end
           else
             mining_key

apps/explorer/lib/explorer/chain/token.ex

@@ -35,6 +35,7 @@ defmodule Explorer.Chain.Token do
   * `contract_address_hash` - Address hash foreign key
   * `holder_count` - the number of `t:Explorer.Chain.Address.t/0` (except the burn address) that have a
     `t:Explorer.Chain.CurrentTokenBalance.t/0` `value > 0`.  Can be `nil` when data not migrated.
+  * `bridged` - Flag for bridged tokens from other chain
   """
   @type t :: %Token{
           name: String.t(),