status-im/nimbus-eth2
2
0
Fork 0
mirror of https://github.com/status-im/nimbus-eth2.git synced 2025-01-27 14:58:46 +00:00
Code Issues Projects Releases Wiki Activity

better web3monitor error message (#3260)

Browse Source 
```
WRN 2022-01-08 11:35:00.963+01:00 Eth1 chain monitoring failure,
restarting  topics="eth1" err="Failed to setup web3 connection: (111)
Connection refused"
```
This commit is contained in:
Jacek Sieka 2022-01-08 14:35:36 +01:00 committed by GitHub
parent 18d83e0ece
commit 25bb927e62
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
beacon_chain/eth1/eth1_monitor.nim
View File

@ -864,7 +864,10 @@ proc new*(T: type Web3DataProvider,
yield web3Fut or sleepAsync(chronos.seconds(10)) yield web3Fut or sleepAsync(chronos.seconds(10))
if (not web3Fut.finished) or web3Fut.failed: if (not web3Fut.finished) or web3Fut.failed:
await cancelAndWait(web3Fut) await cancelAndWait(web3Fut)
return err "Failed to setup web3 connection" if web3Fut.failed:
return err "Failed to setup web3 connection: " & web3Fut.readError.msg
else:
return err "Failed to setup web3 connection"
let let
web3 = web3Fut.read web3 = web3Fut.read
@ -1141,11 +1144,12 @@ proc startEth1Syncing(m: Eth1Monitor, delayBeforeStart: Duration) {.async.} =
info "Starting Eth1 deposit contract monitoring", info "Starting Eth1 deposit contract monitoring",
contract = $m.depositContractAddress, url = web3Url contract = $m.depositContractAddress, url = web3Url
let dataProviderRes = await Web3DataProvider.new( m.dataProvider = block:
m.depositContractAddress, let v = await Web3DataProvider.new(m.depositContractAddress, web3Url)
web3Url) if v.isErr():
raise (ref CatchableError)(msg: v.error())
v.get()
m.dataProvider = dataProviderRes.tryGet()
let web3 = m.dataProvider.web3 let web3 = m.dataProvider.web3
if m.state == Initialized and m.eth1Network.isSome: if m.state == Initialized and m.eth1Network.isSome:
@ -1338,6 +1342,7 @@ when hasGenesisDetection:
error "Failed to obtain details for the starting block " & error "Failed to obtain details for the starting block " &
"of the deposit contract sync. The Web3 provider " & "of the deposit contract sync. The Web3 provider " &
"may still be not fully synced", error = err.msg "may still be not fully synced", error = err.msg
await sleepAsync(chronos.seconds(10)) await sleepAsync(chronos.seconds(10))
# TODO: After a single failure, the web3 object may enter a state # TODO: After a single failure, the web3 object may enter a state
# where it's no longer possible to make additional requests. # where it's no longer possible to make additional requests.
@ -1345,9 +1350,13 @@ when hasGenesisDetection:
# the web3 provider before retrying. In case this fails, # the web3 provider before retrying. In case this fails,
# the Eth1Monitor will be restarted. # the Eth1Monitor will be restarted.
inc urlIdx inc urlIdx
dataProvider = tryGet( dataProvider = block:
await Web3DataProvider.new(cfg.DEPOSIT_CONTRACT_ADDRESS, let v = await Web3DataProvider.new(
web3Urls[urlIdx mod web3Urls.len])) cfg.DEPOSIT_CONTRACT_ADDRESS,
web3Urls[urlIdx mod web3Urls.len])
if v.isErr(): raise (ref CatchableError)(msg: v.error())
v.get()
blk.hash.asEth2Digest blk.hash.asEth2Digest
let depositContractSnapshot = DepositContractSnapshot( let depositContractSnapshot = DepositContractSnapshot(