Merge pull request #2904 from poanetwork/revert-2901-ab-fix-address-sum-cache

Revert "fix address sum cache"
pull/2916/head
Victor Baranov 5 years ago committed by GitHub
commit d7d242e44b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 1
      CHANGELOG.md
  2. 2
      apps/block_scout_web/test/block_scout_web/controllers/api/rpc/stats_controller_test.exs
  3. 16
      apps/explorer/lib/explorer/chain/cache/address_sum.ex
  4. 2
      apps/explorer/test/explorer/chain/cache/address_sum_test.exs
  5. 2
      apps/explorer/test/explorer/chain/import/runner/address/token_balances_test.exs

@ -3,7 +3,6 @@
### Features
### Fixes
- [#2901](https://github.com/poanetwork/blockscout/pull/2901) - fix address sum cache
### Chore

@ -106,8 +106,6 @@ defmodule BlockScoutWeb.API.RPC.StatsControllerTest do
describe "ethsupply" do
test "returns total supply from DB", %{conn: conn} do
insert(:address, fetched_coin_balance: 6)
params = %{
"module" => "stats",
"action" => "ethsupply"

@ -16,13 +16,11 @@ defmodule Explorer.Chain.Cache.AddressSum do
alias Explorer.Chain
defp handle_fallback(:sum) do
result = fetch_from_db()
# This will get the task PID if one exists and launch a new task if not
# See next `handle_fallback` definition
get_async_task()
if Application.get_env(:explorer, __MODULE__)[:enabled] do
{:update, result}
else
{:return, result}
end
{:return, nil}
end
defp handle_fallback(:async_task) do
@ -31,7 +29,7 @@ defmodule Explorer.Chain.Cache.AddressSum do
{:ok, task} =
Task.start(fn ->
try do
result = fetch_from_db()
result = Chain.fetch_sum_coin_total_supply()
set_sum(result)
rescue
@ -47,10 +45,6 @@ defmodule Explorer.Chain.Cache.AddressSum do
{:update, task}
end
defp fetch_from_db do
Chain.fetch_sum_coin_total_supply()
end
# By setting this as a `callback` an async task will be started each time the
# `sum` expires (unless there is one already running)
defp async_task_on_deletion({:delete, _, :sum}), do: get_async_task()

@ -12,7 +12,7 @@ defmodule Explorer.Chain.Cache.AddressSumTest do
test "returns default address sum" do
result = AddressSum.get_sum()
assert result == 0
assert is_nil(result)
end
test "updates cache if initial value is zero" do

@ -93,7 +93,7 @@ defmodule Explorer.Chain.Import.Runner.Address.TokenBalancesTest do
value_fetched_at: DateTime.utc_now()
}
run_changes(new_changes, options)
run_changes(new_changes, options) |> IO.inspect()
end
end

Loading…
Cancel
Save