problem: dev code committed
This commit is contained in:
@@ -198,7 +198,6 @@ class TrackBitcoinAddress(
|
|||||||
val chain = Chain.byId(request.asset.chainValue)
|
val chain = Chain.byId(request.asset.chainValue)
|
||||||
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))
|
||||||
println("call get balance")
|
|
||||||
return if (isBalanceAvailable(chain)) {
|
return if (isBalanceAvailable(chain)) {
|
||||||
val addresses = allAddresses(upstream, request)
|
val addresses = allAddresses(upstream, request)
|
||||||
requestBalances(chain, upstream, addresses, request.includeUtxo)
|
requestBalances(chain, upstream, addresses, request.includeUtxo)
|
||||||
@@ -207,16 +206,9 @@ class TrackBitcoinAddress(
|
|||||||
log.error("Failed to get balance", t)
|
log.error("Failed to get balance", t)
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
println("call remote balance")
|
|
||||||
getRemoteBalance(upstream, request)
|
getRemoteBalance(upstream, request)
|
||||||
.doOnEach {
|
|
||||||
println("each ${it.type}")
|
|
||||||
}
|
|
||||||
.doOnError { t ->
|
.doOnError { t ->
|
||||||
t.printStackTrace()
|
log.error("Failed to get balance from remote", t)
|
||||||
}
|
|
||||||
.doOnComplete {
|
|
||||||
println("received all")
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -196,7 +196,7 @@ class TrackBitcoinAddressSpec extends Specification {
|
|||||||
.setAddressXpub(
|
.setAddressXpub(
|
||||||
// seed: chimney battle code relief era plug finish video patch dream pumpkin govern destroy fresh color
|
// seed: chimney battle code relief era plug finish video patch dream pumpkin govern destroy fresh color
|
||||||
Common.XpubAddress.newBuilder()
|
Common.XpubAddress.newBuilder()
|
||||||
.setXpub(ByteString.copyFromUtf8("zpub6tz4F49K5B4m7r7EyBKYM9K44eGECaQ2AfrCybq1w7ALFatz9856vrXxAPSrteDA4d5sjUPW3ACNq8wB2V3ugXVJxvAPAYPAYHsVm3VAncL"))
|
.setXpub("zpub6tz4F49K5B4m7r7EyBKYM9K44eGECaQ2AfrCybq1w7ALFatz9856vrXxAPSrteDA4d5sjUPW3ACNq8wB2V3ugXVJxvAPAYPAYHsVm3VAncL")
|
||||||
.setLimit(25)
|
.setLimit(25)
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user