From d18d96513d7571ff29130d5810a8ac3c66221d04 Mon Sep 17 00:00:00 2001 From: a10zn8 Date: Thu, 19 Jan 2023 16:06:37 +0400 Subject: [PATCH] Added log for grpc upstreams processing --- .../io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreams.kt | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreams.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreams.kt index 30485f60..78d31d18 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreams.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreams.kt @@ -125,6 +125,7 @@ class GrpcUpstreams( } fun processDescription(value: BlockchainOuterClass.DescribeResponse): Flux { + log.info("Start processing grpc upstream description for $id with chains ${value.chainsList.map { it.chain.name }}") val current = value.chainsList.filter { Chain.byId(it.chain.number) != Chain.UNSPECIFIED }.mapNotNull { chainDetails -> @@ -149,6 +150,7 @@ class GrpcUpstreams( }.map { UpstreamChangeEvent(it.key, known.remove(it.key)!!, UpstreamChangeEvent.ChangeType.REMOVED) } + log.info("Finished processing of grpc upstream description for $id with content delta added [${added.map { it.chain }}] and removed [${removed.map { it.chain }}]") return Flux.fromIterable(removed + added) }