From d34848fb871b69b94e4f359f0a419341eed2b0ce Mon Sep 17 00:00:00 2001 From: a10zn8 Date: Fri, 17 Mar 2023 17:00:12 +0300 Subject: [PATCH] Log errors and info about node status subscription (#168) --- .../io/emeraldpay/dshackle/rpc/BlockchainRpc.kt | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/rpc/BlockchainRpc.kt b/src/main/kotlin/io/emeraldpay/dshackle/rpc/BlockchainRpc.kt index c9f048ee..2f0b3a3d 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/rpc/BlockchainRpc.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/rpc/BlockchainRpc.kt @@ -227,11 +227,17 @@ class BlockchainRpc( return request.flatMapMany { val subId = it.traceId.takeIf { it.isNotBlank() } ?: RandomStringUtils.randomAlphanumeric(8) subscribeNodeStatus.subscribe(it).subscribeOn(scheduler) - .doOnError { failMetric.increment() } - .doOnNext { + .doOnError { err -> + 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( "Emitted next node status to [$subId] with data [${ - JsonFormat.printer().omittingInsignificantWhitespace().print(it) + JsonFormat.printer().omittingInsignificantWhitespace().print(elem) }]" ) }