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

fix formatting

Browse Source
This commit is contained in:
Termina1
2025-07-14 16:59:37 +02:00
parent b940ce9efa
commit f59212e55c
1 changed files with 16 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/EthereumUpstreamValidator.kt
View File

@@ -248,14 +248,15 @@ class ErigonBuggedValidator(
val pastBlock = latest.subtract(FIVE_THOUSAND).max(BigInteger.ZERO) val pastBlock = latest.subtract(FIVE_THOUSAND).max(BigInteger.ZERO)
Mono.zip( Mono.zip(
balanceOkAt(pastBlock), // must succeed balanceOkAt(pastBlock), // must succeed
balanceOkAt(BigInteger.ONE) // must fail balanceOkAt(BigInteger.ONE), // must fail
).map { checks -> ).map { checks ->
val isBugged = checks.t1 && !checks.t2 val isBugged = checks.t1 && !checks.t2
if (isBugged) { if (isBugged) {
log.warn( log.warn(
"Erigon balance-bug detected on upstream {}: ok @ {}, error @ 0x1", "Erigon balance-bug detected on upstream {}: ok @ {}, error @ 0x1",
upstream.getId(), pastBlock upstream.getId(),
pastBlock,
) )
ValidateUpstreamSettingsResult.UPSTREAM_FATAL_SETTINGS_ERROR ValidateUpstreamSettingsResult.UPSTREAM_FATAL_SETTINGS_ERROR
} else { } else {
@@ -267,7 +268,8 @@ class ErigonBuggedValidator(
}.onErrorResume { ex -> }.onErrorResume { ex ->
log.error( log.error(
"Irrecoverable error during Erigon bug validation for {}, reason - {}", "Irrecoverable error during Erigon bug validation for {}, reason - {}",
upstream.getId(), ex.message upstream.getId(),
ex.message,
) )
Mono.just(ValidateUpstreamSettingsResult.UPSTREAM_FATAL_SETTINGS_ERROR) Mono.just(ValidateUpstreamSettingsResult.UPSTREAM_FATAL_SETTINGS_ERROR)
} }
@@ -279,7 +281,9 @@ class ErigonBuggedValidator(
.retryRandomBackoff(3, Duration.ofMillis(100), Duration.ofMillis(500)) { ctx -> .retryRandomBackoff(3, Duration.ofMillis(100), Duration.ofMillis(500)) { ctx ->
log.warn( log.warn(
"error during clientVersion retrieving for {}, iteration {}, reason - {}", "error during clientVersion retrieving for {}, iteration {}, reason - {}",
upstream.getId(), ctx.iteration(), ctx.exception().message upstream.getId(),
ctx.iteration(),
ctx.exception().message,
) )
} }
.flatMap(ChainResponse::requireStringResult) .flatMap(ChainResponse::requireStringResult)
@@ -292,7 +296,9 @@ class ErigonBuggedValidator(
.retryRandomBackoff(3, Duration.ofMillis(100), Duration.ofMillis(500)) { ctx -> .retryRandomBackoff(3, Duration.ofMillis(100), Duration.ofMillis(500)) { ctx ->
log.warn( log.warn(
"error during blockNumber retrieving for {}, iteration {}, reason - {}", "error during blockNumber retrieving for {}, iteration {}, reason - {}",
upstream.getId(), ctx.iteration(), ctx.exception().message upstream.getId(),
ctx.iteration(),
ctx.exception().message,
) )
} }
.flatMap(ChainResponse::requireStringResult) .flatMap(ChainResponse::requireStringResult)
@@ -306,7 +312,10 @@ class ErigonBuggedValidator(
.retryRandomBackoff(3, Duration.ofMillis(100), Duration.ofMillis(500)) { ctx -> .retryRandomBackoff(3, Duration.ofMillis(100), Duration.ofMillis(500)) { ctx ->
log.warn( log.warn(
"error during balance retrieving for {}, block {}, iteration {}, reason - {}", "error during balance retrieving for {}, block {}, iteration {}, reason - {}",
upstream.getId(), tag, ctx.iteration(), ctx.exception().message upstream.getId(),
tag,
ctx.iteration(),
ctx.exception().message,
) )
} }
.flatMap { resp -> resp.requireStringResult().map { true } } .flatMap { resp -> resp.requireStringResult().map { true } }