diff --git a/emerald-grpc b/emerald-grpc index 6b012f3c..812e9e6d 160000 --- a/emerald-grpc +++ b/emerald-grpc @@ -1 +1 @@ -Subproject commit 6b012f3c89f3b311113b3f7a71cdba3f4fee0a3d +Subproject commit 812e9e6ddbbd0fb3f21936b26b82fc76475bce1c diff --git a/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt b/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt index 633c90f3..1f814661 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt @@ -116,14 +116,18 @@ class SubscribeNodeStatus( private fun buildDescription(chain: Chain, up: Upstream): NodeDescription.Builder = NodeDescription.newBuilder() .setChain(Common.ChainRef.forNumber(chain.id)) - .addAllLabels( - up.getLabels().flatMap { labels -> - labels.map { - BlockchainOuterClass.Label.newBuilder() - .setName(it.key) - .setValue(it.value) - .build() - } + .addAllNodeLabels( + up.getLabels().map { nodeLabels -> + BlockchainOuterClass.NodeLabels.newBuilder() + .addAllLabels( + nodeLabels.map { + BlockchainOuterClass.Label.newBuilder() + .setName(it.key) + .setValue(it.value) + .build() + } + ) + .build() } ) .addAllSupportedMethods(up.getMethods().getSupportedMethods())