fixed labels grouping

2022-12-20 15:00:23 +03:00
parent 8f0c9d1187
commit 5894501f0c
2 changed files with 13 additions and 9 deletions
--- 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())