StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

problem: unnecessary logging

Browse Source
This commit is contained in:
Igor Artamonov
2020-05-16 17:08:40 -04:00
parent 114f109722
commit 1d947aeb9d
4 changed files with 0 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/kotlin/io/emeraldpay/dshackle/rpc/TrackBitcoinAddress.kt
View File

@@ -118,8 +118,6 @@ class TrackBitcoinAddress(
override fun subscribe(request: BlockchainOuterClass.BalanceRequest): Flux<BlockchainOuterClass.AddressBalance> { override fun subscribe(request: BlockchainOuterClass.BalanceRequest): Flux<BlockchainOuterClass.AddressBalance> {
val chain = Chain.byId(request.asset.chainValue) val chain = Chain.byId(request.asset.chainValue)
println("up: ${multistreamHolder.getUpstream(chain)}")
println("up cast: ${multistreamHolder.getUpstream(chain)?.cast(BitcoinMultistream::class.java)}")
val upstream = multistreamHolder.getUpstream(chain)?.cast(BitcoinMultistream::class.java) val upstream = multistreamHolder.getUpstream(chain)?.cast(BitcoinMultistream::class.java)
?: return Flux.error(SilentException.UnsupportedBlockchain(request.asset.chainValue)) ?: return Flux.error(SilentException.UnsupportedBlockchain(request.asset.chainValue))
val addresses = allAddresses(request) ?: return Flux.error(SilentException("Unsupported address")) val addresses = allAddresses(request) ?: return Flux.error(SilentException("Unsupported address"))

1
src/main/kotlin/io/emeraldpay/dshackle/upstream/FilteredApis.kt
View File

@@ -97,7 +97,6 @@ class FilteredApis(
} }
override fun request(tries: Int) { override fun request(tries: Int) {
println("requested ${tries}")
//TODO check the buffer size before submitting //TODO check the buffer size before submitting
repeat(tries) { repeat(tries) {
control.onNext(true) control.onNext(true)

1
src/main/kotlin/io/emeraldpay/dshackle/upstream/bitcoin/BitcoinRpcHead.kt
View File

@@ -68,7 +68,6 @@ class BitcoinRpcHead(
.timeout(Defaults.timeout, Mono.error(Exception("Block data is not received"))) .timeout(Defaults.timeout, Mono.error(Exception("Block data is not received")))
} }
.onErrorContinue { err, _ -> .onErrorContinue { err, _ ->
err.printStackTrace()
log.debug("RPC error ${err.message}") log.debug("RPC error ${err.message}")
} }
refreshSubscription = super.follow(base) refreshSubscription = super.follow(base)

1
src/main/kotlin/io/emeraldpay/dshackle/upstream/rpcclient/JsonRpcParser.kt
View File

@@ -33,7 +33,6 @@ class JsonRpcParser() {
val parser: JsonParser = jsonFactory.createParser(json) val parser: JsonParser = jsonFactory.createParser(json)
parser.nextToken() parser.nextToken()
if (parser.currentToken != JsonToken.START_OBJECT) { if (parser.currentToken != JsonToken.START_OBJECT) {
println("token ${parser.currentToken}")
return JsonRpcResponse(null, JsonRpcResponse.ResponseError(RpcResponseError.CODE_UPSTREAM_INVALID_RESPONSE, "Invalid JSON")) return JsonRpcResponse(null, JsonRpcResponse.ResponseError(RpcResponseError.CODE_UPSTREAM_INVALID_RESPONSE, "Invalid JSON"))
} }
var nullResponse: JsonRpcResponse? = null var nullResponse: JsonRpcResponse? = null