problem: fails to add another dshackle upstream if any of blockchain …

…is unsupported
emeraldpay · Sep 1, 2020 · c346c27 · c346c27
1 parent c14255d
commit c346c27
Showing 1 changed file with 12 additions and 5 deletions.
diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreams.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreams.kt
@@ -101,6 +101,8 @@ class GrpcUpstreams(
                         prev?.dispose()
                         subscription
                     }
+                }.doOnError { t ->
+                    log.error("Failed to process update from gRPC upstream $id", t)
                 }
 
         return updates
@@ -109,11 +111,16 @@ class GrpcUpstreams(
     fun processDescription(value: BlockchainOuterClass.DescribeResponse): Flux<UpstreamChange> {
         val current = value.chainsList.filter {
             Chain.byId(it.chain.number) != Chain.UNSPECIFIED
-        }.map { chainDetails ->
-            val chain = Chain.byId(chainDetails.chain.number)
-            val up = getOrCreate(chain)
-            (up.upstream as EthereumGrpcUpstream).init(chainDetails)
-            up
+        }.mapNotNull { chainDetails ->
+            try {
+                val chain = Chain.byId(chainDetails.chain.number)
+                val up = getOrCreate(chain)
+                (up.upstream as EthereumGrpcUpstream).init(chainDetails)
+                up
+            } catch (e: Throwable) {
+                log.warn("Skip unsupported upstream ${chainDetails.chain} on $id: ${e.message}")
+                null
+            }
         }
 
         val added = current.filter {