solana support - remove debug garbage

drpcorg · Nov 13, 2023 · e30f097 · e30f097
1 parent 46e3a03
commit e30f097
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 8 deletions.
diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnectionImpl.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/WsConnectionImpl.kt
@@ -337,7 +337,7 @@ open class WsConnectionImpl(
         val status = subscriptionResponses.tryEmitNext(subscription)
         if (status.isFailure) {
             if (status == Sinks.EmitResult.FAIL_ZERO_SUBSCRIBER) {
-                log.debug("No subscribers to WS response - ${msg.value?.let { String(it) }}")
+                log.debug("No subscribers to WS response")
             } else {
                 log.warn("Failed to proceed with a WS message: $status")
             }

diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/generic/GenericEgressSubscription.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/generic/GenericEgressSubscription.kt
@@ -21,7 +21,6 @@ class GenericEgressSubscription(
             .shuffled()
             .first { matcher.matches(it) } as GenericUpstream
 
-        val x = up.getIngressSubscription().get<ByteArray>(topic, params)?.connect(matcher) ?: Flux.empty()
-        return x
+        return up.getIngressSubscription().get<ByteArray>(topic, params)?.connect(matcher) ?: Flux.empty()
     }
 }
diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/generic/GenericIngressSubscription.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/generic/GenericIngressSubscription.kt
@@ -19,8 +19,7 @@ class GenericIngressSubscription(val conn: WsSubscriptions) : IngressSubscriptio
 
     @Suppress("UNCHECKED_CAST")
     override fun <T> get(topic: String, params: Any?): SubscriptionConnect<T> {
-        val x = holders.computeIfAbsent(topic to params, { key -> GenericSubscriptionConnect(conn, key.first, key.second) }) as SubscriptionConnect<T>
-        return x
+        return holders.computeIfAbsent(topic to params, { key -> GenericSubscriptionConnect(conn, key.first, key.second) }) as SubscriptionConnect<T>
     }
 }
 

diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/generic/GenericUpstream.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/generic/GenericUpstream.kt
@@ -186,9 +186,7 @@ open class GenericUpstream(
     }
 
     fun getIngressSubscription(): IngressSubscription {
-        val x = connector.getIngressSubscription()
-        println(x)
-        return x
+        return connector.getIngressSubscription()
     }
 
     override fun isRunning() = connector.isRunning() && validationSettingsSubscription == null