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

lower block detection on filecoin (#546)

Browse Source
This commit is contained in:
a10zn8
2024-08-12 00:04:46 +03:00
committed by GitHub
parent f5d75e133b
commit ef9c2e42a8
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/EthereumLowerBoundBlockDetector.kt
View File

@@ -1,5 +1,7 @@
package io.emeraldpay.dshackle.upstream.ethereum package io.emeraldpay.dshackle.upstream.ethereum
import io.emeraldpay.dshackle.upstream.ChainCallError
import io.emeraldpay.dshackle.upstream.ChainCallUpstreamException
import io.emeraldpay.dshackle.upstream.ChainRequest import io.emeraldpay.dshackle.upstream.ChainRequest
import io.emeraldpay.dshackle.upstream.ChainResponse import io.emeraldpay.dshackle.upstream.ChainResponse
import io.emeraldpay.dshackle.upstream.Upstream import io.emeraldpay.dshackle.upstream.Upstream
@@ -18,6 +20,11 @@ class EthereumLowerBoundBlockDetector(
companion object { companion object {
private const val NO_BLOCK_DATA = "No block data" private const val NO_BLOCK_DATA = "No block data"
private val NO_BLOCK_ERRORS = listOf(
"error loading messages for tipset",
"bad tipset height",
)
} }
private val recursiveLowerBound = RecursiveLowerBound(upstream, LowerBoundType.BLOCK, setOf(NO_BLOCK_DATA), lowerBounds) private val recursiveLowerBound = RecursiveLowerBound(upstream, LowerBoundType.BLOCK, setOf(NO_BLOCK_DATA), lowerBounds)
@@ -42,11 +49,19 @@ class EthereumLowerBoundBlockDetector(
if (it.hasResult() && it.getResult().contentEquals("null".toByteArray())) { if (it.hasResult() && it.getResult().contentEquals("null".toByteArray())) {
throw IllegalStateException(NO_BLOCK_DATA) throw IllegalStateException(NO_BLOCK_DATA)
} }
}.doOnError {
if (it is ChainCallUpstreamException && handleError(it.error)) {
throw IllegalStateException(NO_BLOCK_DATA)
}
} }
} }
} }
} }
private fun handleError(error: ChainCallError): Boolean {
return NO_BLOCK_ERRORS.any { error.message.contains(it) }
}
override fun types(): Set<LowerBoundType> { override fun types(): Set<LowerBoundType> {
return setOf(LowerBoundType.BLOCK) return setOf(LowerBoundType.BLOCK)
} }