Fix issue with wrong updated token balances (#506)

* Fix issue with wrong updated token balances * Update mistake * Only update balances
celo-org · Dec 10, 2021 · a4b80bd · a4b80bd
1 parent fbbe83a
commit a4b80bd
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 6 deletions.
diff --git a/apps/indexer/lib/indexer/fetcher/internal_transaction.ex b/apps/indexer/lib/indexer/fetcher/internal_transaction.ex
@@ -269,8 +269,13 @@ defmodule Indexer.Fetcher.InternalTransaction do
         _ -> []
       end
 
+    token_transfers_addresses_params =
+      Addresses.extract_addresses(%{
+        token_transfers: token_transfers
+      })
+
     address_hash_to_block_number =
-      Enum.into(addresses_params, %{}, fn %{fetched_coin_balance_block_number: block_number, hash: hash} ->
+      Enum.into(token_transfers_addresses_params, %{}, fn %{fetched_coin_balance_block_number: block_number, hash: hash} ->
         {hash, block_number}
       end)
 
@@ -293,10 +298,10 @@ defmodule Indexer.Fetcher.InternalTransaction do
 
     case imports do
       {:ok, imported} ->
-        Accounts.drop(imported[:addreses])
+        Accounts.drop(imported[:addresses])
         Blocks.drop_nonconsensus(imported[:remove_consensus_of_missing_transactions_blocks])
 
-        async_import_coin_balances(imported, %{
+        async_import_coin_balances(token_transfers_addresses_params, %{
           address_hash_to_fetched_balance_block_number: address_hash_to_block_number
         })
 

diff --git a/apps/indexer/test/indexer/block/fetcher_test.exs b/apps/indexer/test/indexer/block/fetcher_test.exs
@@ -309,7 +309,7 @@ defmodule Indexer.Block.FetcherTest do
               unprefixed_celo_token_address_hash,
               event_first_topic,
               event_data,
-              22
+              18
             )
 
           variant ->
@@ -544,7 +544,7 @@ defmodule Indexer.Block.FetcherTest do
               unprefixed_celo_token_address_hash,
               event_first_topic,
               event_data,
-              22
+              18
             )
 
           variant ->
@@ -658,7 +658,7 @@ defmodule Indexer.Block.FetcherTest do
               unprefixed_celo_token_address_hash,
               event_first_topic,
               event_data,
-              22
+              18
             )
 
           variant ->