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

Log errors and info about node status subscription (#168)

Browse Source
This commit is contained in:
a10zn8
2023-03-17 17:00:12 +03:00
committed by GitHub
parent 298b281eff
commit d34848fb87
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/kotlin/io/emeraldpay/dshackle/rpc/BlockchainRpc.kt
View File

@@ -227,11 +227,17 @@ class BlockchainRpc(
return request.flatMapMany { return request.flatMapMany {
val subId = it.traceId.takeIf { it.isNotBlank() } ?: RandomStringUtils.randomAlphanumeric(8) val subId = it.traceId.takeIf { it.isNotBlank() } ?: RandomStringUtils.randomAlphanumeric(8)
subscribeNodeStatus.subscribe(it).subscribeOn(scheduler) subscribeNodeStatus.subscribe(it).subscribeOn(scheduler)
.doOnError { failMetric.increment() } .doOnError { err ->
.doOnNext { log.error("Error during processing node subscription [$subId], closing", err)
failMetric.increment()
}
.doFinally { sig ->
log.info("Closing node status subscription named $subId with $sig")
}
.doOnNext { elem ->
log.debug( log.debug(
"Emitted next node status to [$subId] with data [${ "Emitted next node status to [$subId] with data [${
JsonFormat.printer().omittingInsignificantWhitespace().print(it) JsonFormat.printer().omittingInsignificantWhitespace().print(elem)
}]" }]"
) )
} }