StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

solution: warn if WS is not configured for an upstream

Browse Source
This commit is contained in:
Igor Artamonov
2020-02-23 22:01:11 -05:00
parent 3c2e61af7d
commit 81ccfef068
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/EthereumUpstream.kt
View File

@@ -88,13 +88,15 @@ open class EthereumUpstream(
val ws = EthereumWsHead(ethereumWs).apply { val ws = EthereumWsHead(ethereumWs).apply {
this.start() this.start()
} }
val rpc = EthereumRpcHead(api, Duration.ofSeconds(20)).apply { // receive bew blocks through Websockets, but periodically verify with RPC
val rpc = EthereumRpcHead(api, Duration.ofSeconds(30)).apply {
this.start() this.start()
} }
EthereumHeadMerge(listOf(rpc.getFlux(), ws.getFlux())).apply { EthereumHeadMerge(listOf(rpc.getFlux(), ws.getFlux())).apply {
this.start() this.start()
} }
} else { } else {
log.warn("Setting up upstream $id with RPC-only access, less effective than WS+RPC")
EthereumRpcHead(api).apply { EthereumRpcHead(api).apply {
this.start() this.start()
} }