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

subscribeNodeStatus should write fewer logs (#174)

Browse Source
This commit is contained in:
a10zn8
2023-03-19 17:21:26 +03:00
committed by GitHub
parent de9ac6a845
commit d281cd8857
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -16,7 +16,6 @@
*/ */
package io.emeraldpay.dshackle.rpc package io.emeraldpay.dshackle.rpc
import com.google.protobuf.util.JsonFormat
import io.emeraldpay.api.proto.BlockchainOuterClass import io.emeraldpay.api.proto.BlockchainOuterClass
import io.emeraldpay.api.proto.Common import io.emeraldpay.api.proto.Common
import io.emeraldpay.api.proto.ReactorBlockchainGrpc import io.emeraldpay.api.proto.ReactorBlockchainGrpc
@@ -232,13 +231,11 @@ class BlockchainRpc(
failMetric.increment() failMetric.increment()
} }
.doFinally { sig -> .doFinally { sig ->
log.info("Closing node status subscription named $subId with $sig") log.info("Closing node status subscription named [$subId] with $sig")
} }
.doOnNext { elem -> .doOnNext { elem ->
log.debug( log.debug(
"Emitted next node status to [$subId] with data [${ "Emitted next node status to [$subId] with [node: ${elem.nodeId}, chain: ${elem.description.chain.name}, status: ${elem.status.availability.name}, ]"
JsonFormat.printer().omittingInsignificantWhitespace().print(elem)
}]"
) )
} }
} }