|
|
@ -388,12 +388,14 @@ defmodule Indexer.Block.Fetcher do |
|
|
|
def async_import_blobs(%{blocks: blocks}) do |
|
|
|
def async_import_blobs(%{blocks: blocks}) do |
|
|
|
timestamps = |
|
|
|
timestamps = |
|
|
|
blocks |
|
|
|
blocks |
|
|
|
|> Enum.filter(fn %{blob_gas_used: blob_gas_used} -> blob_gas_used > 0 end) |
|
|
|
|> Enum.filter(fn block -> block |> Map.get(:blob_gas_used, 0) > 0 end) |
|
|
|
|> Enum.map(&Map.get(&1, :timestamp)) |
|
|
|
|> Enum.map(&Map.get(&1, :timestamp)) |
|
|
|
|
|
|
|
|
|
|
|
Blob.async_fetch(timestamps) |
|
|
|
Blob.async_fetch(timestamps) |
|
|
|
end |
|
|
|
end |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def async_import_blobs(_), do: :ok |
|
|
|
|
|
|
|
|
|
|
|
defp block_reward_errors_to_block_numbers(block_reward_errors) when is_list(block_reward_errors) do |
|
|
|
defp block_reward_errors_to_block_numbers(block_reward_errors) when is_list(block_reward_errors) do |
|
|
|
Enum.map(block_reward_errors, &block_reward_error_to_block_number/1) |
|
|
|
Enum.map(block_reward_errors, &block_reward_error_to_block_number/1) |
|
|
|
end |
|
|
|
end |
|
|
|