CipherLabs
/
blockscout
mirror of https://github.com/blockscout/blockscout
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ETHEREUM_JSONRPC_HTTP_TIMEOUT env variable

Browse Source
pull/7089/head
Qwerty5Uiop 2 years ago
parent 3aae7464b2
commit 622c2abffe
35 changed files with 106 additions and 30 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 1
      CHANGELOG.md
  2. 14
      apps/ethereum_jsonrpc/lib/ethereum_jsonrpc/geth.ex
  3. 23
      apps/ethereum_jsonrpc/lib/ethereum_jsonrpc/utility/common_helper.ex
  4. 3
      apps/explorer/config/dev/arbitrum.exs
  5. 3
      apps/explorer/config/dev/besu.exs
  6. 3
      apps/explorer/config/dev/erigon.exs
  7. 3
      apps/explorer/config/dev/ganache.exs
  8. 3
      apps/explorer/config/dev/geth.exs
  9. 3
      apps/explorer/config/dev/nethermind.exs
  10. 3
      apps/explorer/config/dev/rsk.exs
  11. 3
      apps/explorer/config/prod/arbitrum.exs
  12. 3
      apps/explorer/config/prod/besu.exs
  13. 3
      apps/explorer/config/prod/erigon.exs
  14. 3
      apps/explorer/config/prod/ganache.exs
  15. 3
      apps/explorer/config/prod/geth.exs
  16. 3
      apps/explorer/config/prod/nethermind.exs
  17. 3
      apps/explorer/config/prod/rsk.exs
  18. 3
      apps/indexer/config/dev/arbitrum.exs
  19. 3
      apps/indexer/config/dev/besu.exs
  20. 3
      apps/indexer/config/dev/erigon.exs
  21. 3
      apps/indexer/config/dev/ganache.exs
  22. 3
      apps/indexer/config/dev/geth.exs
  23. 3
      apps/indexer/config/dev/nethermind.exs
  24. 3
      apps/indexer/config/dev/rsk.exs
  25. 3
      apps/indexer/config/prod/arbitrum.exs
  26. 3
      apps/indexer/config/prod/besu.exs
  27. 3
      apps/indexer/config/prod/erigon.exs
  28. 3
      apps/indexer/config/prod/ganache.exs
  29. 3
      apps/indexer/config/prod/geth.exs
  30. 3
      apps/indexer/config/prod/nethermind.exs
  31. 3
      apps/indexer/config/prod/rsk.exs
  32. 8
      config/config_helper.exs
  33. 2
      deploy/testing/eth-goerli/values.yaml
  34. 1
      docker-compose/envs/common-blockscout.env
  35. 3
      docker/Makefile

1
CHANGELOG.md
Unescape View File

@ -6,6 +6,7 @@
- [#7068](https://github.com/blockscout/blockscout/pull/7068) - Add authenticate endpoint - [#7068](https://github.com/blockscout/blockscout/pull/7068) - Add authenticate endpoint
- [#6990](https://github.com/blockscout/blockscout/pull/6990) - Improved http requests logging, batch transfers pagination; New API v2 endpoint `/smart-contracts/counters`; And some refactoring - [#6990](https://github.com/blockscout/blockscout/pull/6990) - Improved http requests logging, batch transfers pagination; New API v2 endpoint `/smart-contracts/counters`; And some refactoring
- [#7089](https://github.com/blockscout/blockscout/pull/7089) - ETHEREUM_JSONRPC_HTTP_TIMEOUT env variable
### Fixes ### Fixes

14
apps/ethereum_jsonrpc/lib/ethereum_jsonrpc/geth.ex
Unescape View File

@ -7,7 +7,7 @@ defmodule EthereumJSONRPC.Geth do
import EthereumJSONRPC, only: [id_to_params: 1, integer_to_quantity: 1, json_rpc: 2, request: 1] import EthereumJSONRPC, only: [id_to_params: 1, integer_to_quantity: 1, json_rpc: 2, request: 1]
alias EthereumJSONRPC.{FetchedBalance, FetchedCode, PendingTransaction} alias EthereumJSONRPC.{FetchedBalance, FetchedCode, PendingTransaction, Utility.CommonHelper}
alias EthereumJSONRPC.Geth.{Calls, Tracer} alias EthereumJSONRPC.Geth.{Calls, Tracer}
@behaviour EthereumJSONRPC.Variant @behaviour EthereumJSONRPC.Variant
@ -27,10 +27,20 @@ defmodule EthereumJSONRPC.Geth do
def fetch_internal_transactions(transactions_params, json_rpc_named_arguments) when is_list(transactions_params) do def fetch_internal_transactions(transactions_params, json_rpc_named_arguments) when is_list(transactions_params) do
id_to_params = id_to_params(transactions_params) id_to_params = id_to_params(transactions_params)
debug_trace_transaction_timeout =
Application.get_env(:ethereum_jsonrpc, __MODULE__)[:debug_trace_transaction_timeout]
parsed_timeout = CommonHelper.parse_duration(debug_trace_transaction_timeout)
json_rpc_named_arguments_corrected_timeout =
json_rpc_named_arguments
|> put_in([:transport_options, :http_options, :timeout], parsed_timeout)
|> put_in([:transport_options, :http_options, :recv_timeout], parsed_timeout)
with {:ok, responses} <- with {:ok, responses} <-
id_to_params id_to_params
|> debug_trace_transaction_requests() |> debug_trace_transaction_requests()
|> json_rpc(json_rpc_named_arguments) do |> json_rpc(json_rpc_named_arguments_corrected_timeout) do
debug_trace_transaction_responses_to_internal_transactions_params( debug_trace_transaction_responses_to_internal_transactions_params(
responses, responses,
id_to_params, id_to_params,

23
apps/ethereum_jsonrpc/lib/ethereum_jsonrpc/utility/common_helper.ex
Unescape View File

@ -0,0 +1,23 @@
defmodule EthereumJSONRPC.Utility.CommonHelper do
@moduledoc """
Common helper functions
"""
# converts duration like "5s", "2m" to milliseconds
@duration_regex ~r/^(\d+)([smh]{1})$/
def parse_duration(duration) do
case Regex.run(@duration_regex, duration) do
[_, number, granularity] ->
number
|> String.to_integer()
|> convert_to_ms(granularity)
_ ->
{:error, :invalid_format}
end
end
defp convert_to_ms(number, "s"), do: :timer.seconds(number)
defp convert_to_ms(number, "m"), do: :timer.minutes(number)
defp convert_to_ms(number, "h"), do: :timer.hours(number)
end

3
apps/explorer/config/dev/arbitrum.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -12,7 +13,7 @@ config :explorer,
transport_options: [ transport_options: [
http: EthereumJSONRPC.HTTP.HTTPoison, http: EthereumJSONRPC.HTTP.HTTPoison,
url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:8545", url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:8545",
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Arbitrum variant: EthereumJSONRPC.Arbitrum
], ],

3
apps/explorer/config/dev/besu.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -17,7 +18,7 @@ config :explorer,
eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545", eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545",
trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545" trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545"
], ],
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Besu variant: EthereumJSONRPC.Besu
], ],

3
apps/explorer/config/dev/erigon.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -17,7 +18,7 @@ config :explorer,
eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545", eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545",
trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545" trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545"
], ],
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Erigon variant: EthereumJSONRPC.Erigon
], ],

3
apps/explorer/config/dev/ganache.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -12,7 +13,7 @@ config :explorer,
transport_options: [ transport_options: [
http: EthereumJSONRPC.HTTP.HTTPoison, http: EthereumJSONRPC.HTTP.HTTPoison,
url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:7545", url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:7545",
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Ganache variant: EthereumJSONRPC.Ganache
], ],

3
apps/explorer/config/dev/geth.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -12,7 +13,7 @@ config :explorer,
transport_options: [ transport_options: [
http: EthereumJSONRPC.HTTP.HTTPoison, http: EthereumJSONRPC.HTTP.HTTPoison,
url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:8545", url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:8545",
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Geth variant: EthereumJSONRPC.Geth
], ],

3
apps/explorer/config/dev/nethermind.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -17,7 +18,7 @@ config :explorer,
eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545", eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545",
trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545" trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545"
], ],
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Nethermind variant: EthereumJSONRPC.Nethermind
], ],

3
apps/explorer/config/dev/rsk.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -17,7 +18,7 @@ config :explorer,
eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545", eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545",
trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545" trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545"
], ],
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.RSK variant: EthereumJSONRPC.RSK
], ],

3
apps/explorer/config/prod/arbitrum.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -12,7 +13,7 @@ config :explorer,
transport_options: [ transport_options: [
http: EthereumJSONRPC.HTTP.HTTPoison, http: EthereumJSONRPC.HTTP.HTTPoison,
url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL"), url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL"),
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Arbitrum variant: EthereumJSONRPC.Arbitrum
], ],

3
apps/explorer/config/prod/besu.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -17,7 +18,7 @@ config :explorer,
eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"), eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"),
trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL")
], ],
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Besu variant: EthereumJSONRPC.Besu
], ],

3
apps/explorer/config/prod/erigon.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -17,7 +18,7 @@ config :explorer,
eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"), eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"),
trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL")
], ],
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Erigon variant: EthereumJSONRPC.Erigon
], ],

3
apps/explorer/config/prod/ganache.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -12,7 +13,7 @@ config :explorer,
transport_options: [ transport_options: [
http: EthereumJSONRPC.HTTP.HTTPoison, http: EthereumJSONRPC.HTTP.HTTPoison,
url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL"), url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL"),
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Ganache variant: EthereumJSONRPC.Ganache
], ],

3
apps/explorer/config/prod/geth.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -12,7 +13,7 @@ config :explorer,
transport_options: [ transport_options: [
http: EthereumJSONRPC.HTTP.HTTPoison, http: EthereumJSONRPC.HTTP.HTTPoison,
url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL"), url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL"),
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Geth variant: EthereumJSONRPC.Geth
], ],

3
apps/explorer/config/prod/nethermind.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -17,7 +18,7 @@ config :explorer,
eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"), eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"),
trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL")
], ],
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Nethermind variant: EthereumJSONRPC.Nethermind
], ],

3
apps/explorer/config/prod/rsk.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :explorer, config :explorer,
json_rpc_named_arguments: [ json_rpc_named_arguments: [
@ -17,7 +18,7 @@ config :explorer,
eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"), eth_getBalance: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"),
trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL")
], ],
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.RSK variant: EthereumJSONRPC.RSK
], ],

3
apps/indexer/config/dev/arbitrum.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -17,7 +18,7 @@ config :indexer,
transport_options: [ transport_options: [
http: EthereumJSONRPC.HTTP.HTTPoison, http: EthereumJSONRPC.HTTP.HTTPoison,
url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:8545", url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:8545",
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Arbitrum variant: EthereumJSONRPC.Arbitrum
], ],

3
apps/indexer/config/dev/besu.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(10)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -23,7 +24,7 @@ config :indexer,
trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545", trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545",
trace_replayBlockTransactions: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545" trace_replayBlockTransactions: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545"
], ],
http_options: [recv_timeout: :timer.minutes(10), timeout: :timer.minutes(10), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Besu variant: EthereumJSONRPC.Besu
], ],

3
apps/indexer/config/dev/erigon.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(10)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -23,7 +24,7 @@ config :indexer,
trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545", trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545",
trace_replayBlockTransactions: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545" trace_replayBlockTransactions: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545"
], ],
http_options: [recv_timeout: :timer.minutes(10), timeout: :timer.minutes(10), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Erigon variant: EthereumJSONRPC.Erigon
], ],

3
apps/indexer/config/dev/ganache.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -17,7 +18,7 @@ config :indexer,
transport_options: [ transport_options: [
http: EthereumJSONRPC.HTTP.HTTPoison, http: EthereumJSONRPC.HTTP.HTTPoison,
url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:7545", url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:7545",
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Ganache variant: EthereumJSONRPC.Ganache
], ],

3
apps/indexer/config/dev/geth.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -17,7 +18,7 @@ config :indexer,
transport_options: [ transport_options: [
http: EthereumJSONRPC.HTTP.HTTPoison, http: EthereumJSONRPC.HTTP.HTTPoison,
url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:8545", url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:8545",
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Geth variant: EthereumJSONRPC.Geth
], ],

3
apps/indexer/config/dev/nethermind.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(10)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -23,7 +24,7 @@ config :indexer,
trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545", trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545",
trace_replayBlockTransactions: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545" trace_replayBlockTransactions: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545"
], ],
http_options: [recv_timeout: :timer.minutes(10), timeout: :timer.minutes(10), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Nethermind variant: EthereumJSONRPC.Nethermind
], ],

3
apps/indexer/config/dev/rsk.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(10)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -24,7 +25,7 @@ config :indexer,
trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545", trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545",
trace_replayBlockTransactions: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545" trace_replayBlockTransactions: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") || "http://localhost:8545"
], ],
http_options: [recv_timeout: :timer.minutes(10), timeout: :timer.minutes(10), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.RSK variant: EthereumJSONRPC.RSK
], ],

3
apps/indexer/config/prod/arbitrum.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(5)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -17,7 +18,7 @@ config :indexer,
transport_options: [ transport_options: [
http: EthereumJSONRPC.HTTP.HTTPoison, http: EthereumJSONRPC.HTTP.HTTPoison,
url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:8545", url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:8545",
http_options: [recv_timeout: :timer.minutes(5), timeout: :timer.minutes(5), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Arbitrum variant: EthereumJSONRPC.Arbitrum
], ],

3
apps/indexer/config/prod/besu.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(10)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -22,7 +23,7 @@ config :indexer,
trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"), trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"),
trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL")
], ],
http_options: [recv_timeout: :timer.minutes(10), timeout: :timer.minutes(10), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Besu variant: EthereumJSONRPC.Besu
], ],

3
apps/indexer/config/prod/erigon.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(10)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -22,7 +23,7 @@ config :indexer,
trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"), trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"),
trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL")
], ],
http_options: [recv_timeout: :timer.minutes(10), timeout: :timer.minutes(10), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Erigon variant: EthereumJSONRPC.Erigon
], ],

3
apps/indexer/config/prod/ganache.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(1)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -17,7 +18,7 @@ config :indexer,
transport_options: [ transport_options: [
http: EthereumJSONRPC.HTTP.HTTPoison, http: EthereumJSONRPC.HTTP.HTTPoison,
url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:7545", url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL") || "http://localhost:7545",
http_options: [recv_timeout: :timer.minutes(1), timeout: :timer.minutes(1), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Ganache variant: EthereumJSONRPC.Ganache
], ],

3
apps/indexer/config/prod/geth.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(10)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -17,7 +18,7 @@ config :indexer,
transport_options: [ transport_options: [
http: EthereumJSONRPC.HTTP.HTTPoison, http: EthereumJSONRPC.HTTP.HTTPoison,
url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL"), url: System.get_env("ETHEREUM_JSONRPC_HTTP_URL"),
http_options: [recv_timeout: :timer.minutes(10), timeout: :timer.minutes(10), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Geth variant: EthereumJSONRPC.Geth
], ],

3
apps/indexer/config/prod/nethermind.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout()
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -22,7 +23,7 @@ config :indexer,
trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"), trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"),
trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL")
], ],
http_options: [recv_timeout: :timer.minutes(10), timeout: :timer.minutes(10), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.Nethermind variant: EthereumJSONRPC.Nethermind
], ],

3
apps/indexer/config/prod/rsk.exs
Unescape View File

@ -5,6 +5,7 @@ import Config
|> Code.eval_file() |> Code.eval_file()
hackney_opts = ConfigHelper.hackney_options() hackney_opts = ConfigHelper.hackney_options()
timeout = ConfigHelper.timeout(10)
config :indexer, config :indexer,
block_interval: :timer.seconds(5), block_interval: :timer.seconds(5),
@ -24,7 +25,7 @@ config :indexer,
trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"), trace_block: System.get_env("ETHEREUM_JSONRPC_TRACE_URL"),
trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL") trace_replayTransaction: System.get_env("ETHEREUM_JSONRPC_TRACE_URL")
], ],
http_options: [recv_timeout: :timer.minutes(10), timeout: :timer.minutes(10), hackney: hackney_opts] http_options: [recv_timeout: timeout, timeout: timeout, hackney: hackney_opts]
], ],
variant: EthereumJSONRPC.RSK variant: EthereumJSONRPC.RSK
], ],

8
config/config_helper.exs
Unescape View File

@ -10,4 +10,12 @@ defmodule ConfigHelper do
else: &1 else: &1
)).() )).()
end end
def timeout(default_minutes \\ 1) do
case Integer.parse(System.get_env("ETHEREUM_JSONRPC_HTTP_TIMEOUT", "#{default_minutes * 60}")) do
{seconds, ""} -> seconds
_ -> default_minutes * 60
end
|> :timer.seconds()
end
end end

2
deploy/testing/eth-goerli/values.yaml
Unescape View File

@ -97,6 +97,8 @@ blockscout:
_default: '[{"title": "Marketplace", "url": "/apps", "embedded?": true}]' _default: '[{"title": "Marketplace", "url": "/apps", "embedded?": true}]'
ETHEREUM_JSONRPC_DEBUG_TRACE_TRANSACTION_TIMEOUT: ETHEREUM_JSONRPC_DEBUG_TRACE_TRANSACTION_TIMEOUT:
_default: '20s' _default: '20s'
ETHEREUM_JSONRPC_HTTP_TIMEOUT:
_default: 60
INDEXER_INTERNAL_TRANSACTIONS_BATCH_SIZE: INDEXER_INTERNAL_TRANSACTIONS_BATCH_SIZE:
_default: 15 _default: 15
INDEXER_DISABLE_EMPTY_BLOCK_SANITIZER: INDEXER_DISABLE_EMPTY_BLOCK_SANITIZER:

1
docker-compose/envs/common-blockscout.env
Unescape View File

@ -3,6 +3,7 @@ ETHEREUM_JSONRPC_VARIANT=geth
ETHEREUM_JSONRPC_HTTP_URL=http://host.docker.internal:8545/ ETHEREUM_JSONRPC_HTTP_URL=http://host.docker.internal:8545/
DATABASE_URL=postgresql://postgres:@host.docker.internal:7432/blockscout?ssl=false DATABASE_URL=postgresql://postgres:@host.docker.internal:7432/blockscout?ssl=false
ETHEREUM_JSONRPC_TRACE_URL=http://host.docker.internal:8545/ ETHEREUM_JSONRPC_TRACE_URL=http://host.docker.internal:8545/
# ETHEREUM_JSONRPC_HTTP_TIMEOUT=
NETWORK= NETWORK=
SUBNETWORK=Awesome chain SUBNETWORK=Awesome chain
LOGO=/images/blockscout_logo.svg LOGO=/images/blockscout_logo.svg

3
docker/Makefile
Unescape View File

@ -376,6 +376,9 @@ endif
ifdef ETHEREUM_JSONRPC_DEBUG_TRACE_TRANSACTION_TIMEOUT ifdef ETHEREUM_JSONRPC_DEBUG_TRACE_TRANSACTION_TIMEOUT
BLOCKSCOUT_CONTAINER_PARAMS += -e 'ETHEREUM_JSONRPC_DEBUG_TRACE_TRANSACTION_TIMEOUT=$(ETHEREUM_JSONRPC_DEBUG_TRACE_TRANSACTION_TIMEOUT)' BLOCKSCOUT_CONTAINER_PARAMS += -e 'ETHEREUM_JSONRPC_DEBUG_TRACE_TRANSACTION_TIMEOUT=$(ETHEREUM_JSONRPC_DEBUG_TRACE_TRANSACTION_TIMEOUT)'
endif endif
ifdef ETHEREUM_JSONRPC_HTTP_TIMEOUT
BLOCKSCOUT_CONTAINER_PARAMS += -e 'ETHEREUM_JSONRPC_HTTP_TIMEOUT=$(ETHEREUM_JSONRPC_HTTP_TIMEOUT)'
endif
ifdef FETCH_REWARDS_WAY ifdef FETCH_REWARDS_WAY
BLOCKSCOUT_CONTAINER_PARAMS += -e 'FETCH_REWARDS_WAY=$(FETCH_REWARDS_WAY)' BLOCKSCOUT_CONTAINER_PARAMS += -e 'FETCH_REWARDS_WAY=$(FETCH_REWARDS_WAY)'
endif endif

Write Preview
Loading…
Cancel
Save