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

use lower bounds with offsets for beacon chain (#647)

Browse Source
This commit is contained in:
msizov
2025-04-02 15:49:04 +07:00
committed by GitHub
parent 074c22924b
commit a79d64c066
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/kotlin/io/emeraldpay/dshackle/upstream/beaconchain/BeaconChainLowerBoundBlockDetector.kt
View File

@@ -24,6 +24,7 @@ class BeaconChainLowerBoundBlockDetector(
private val recursiveLowerBound = RecursiveLowerBound(upstream, LowerBoundType.BLOCK, stateErrors, lowerBounds) private val recursiveLowerBound = RecursiveLowerBound(upstream, LowerBoundType.BLOCK, stateErrors, lowerBounds)
companion object { companion object {
const val MAX_OFFSET = 30
val notFoundError = "NOT_FOUND:" // e.g. {"message":"NOT_FOUND: beacon block at slot 1086646","code":404} val notFoundError = "NOT_FOUND:" // e.g. {"message":"NOT_FOUND: beacon block at slot 1086646","code":404}
val notFoundError2 = "Could not find requested block" // {"message":"Could not find requested block: signed beacon block can't be nil","code":404} val notFoundError2 = "Could not find requested block" // {"message":"Could not find requested block: signed beacon block can't be nil","code":404}
val notFoundError3 = "has not been found" // Block header/data has not been found val notFoundError3 = "has not been found" // Block header/data has not been found
@@ -35,7 +36,7 @@ class BeaconChainLowerBoundBlockDetector(
} }
override fun internalDetectLowerBound(): Flux<LowerBoundData> { override fun internalDetectLowerBound(): Flux<LowerBoundData> {
return recursiveLowerBound.recursiveDetectLowerBound { block -> return recursiveLowerBound.recursiveDetectLowerBoundWithOffset(MAX_OFFSET) { block ->
val restParams = RestParams(emptyList(), emptyList(), listOf(block.toString()), ByteArray(0)) val restParams = RestParams(emptyList(), emptyList(), listOf(block.toString()), ByteArray(0))
upstream.getIngressReader() upstream.getIngressReader()