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

Fix sol head detection (#808)

Browse Source
This commit is contained in:
KirillPamPam
2026-04-07 12:14:18 +04:00
committed by GitHub
parent 93b8ad0aeb
commit 2432e2567c
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/kotlin/io/emeraldpay/dshackle/upstream/solana/SolanaChainSpecific.kt
View File

@@ -55,8 +55,10 @@ object SolanaChainSpecific : AbstractChainSpecific() {
private val lastKnownHeights = ConcurrentHashMap<String, Long>() private val lastKnownHeights = ConcurrentHashMap<String, Long>()
private val lastCheckedSlots = ConcurrentHashMap<String, Long>() private val lastCheckedSlots = ConcurrentHashMap<String, Long>()
private val getEpochInfoReq = ChainRequest("getEpochInfo", ListParams(mapOf("commitment" to "confirmed")))
override fun getLatestBlock(api: ChainReader, upstreamId: String): Mono<BlockContainer> { override fun getLatestBlock(api: ChainReader, upstreamId: String): Mono<BlockContainer> {
return api.read(ChainRequest("getEpochInfo", ListParams())) return api.read(getEpochInfoReq)
.map { response -> .map { response ->
val epochInfo = Global.objectMapper.readValue( val epochInfo = Global.objectMapper.readValue(
response.getResult(), response.getResult(),
@@ -90,7 +92,7 @@ object SolanaChainSpecific : AbstractChainSpecific() {
if (shouldCheckHeight || estimatedHeight == null) { if (shouldCheckHeight || estimatedHeight == null) {
// Verify actual height using getEpochInfo (single call for both slot and height) // Verify actual height using getEpochInfo (single call for both slot and height)
api.read(ChainRequest("getEpochInfo", ListParams())) api.read(getEpochInfoReq)
.map { response -> .map { response ->
val epochInfo = Global.objectMapper.readValue( val epochInfo = Global.objectMapper.readValue(
response.getResult(), response.getResult(),