From 178caffa7c54e8c0611f5ecae8fa474cbbf7faed Mon Sep 17 00:00:00 2001 From: Peyman Date: Sun, 16 Oct 2022 18:56:05 +0330 Subject: [PATCH] Fix market stat issue --- .../ports/binance/controller/LandingController.kt | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/api/api-ports/api-binance-rest/src/main/kotlin/co/nilin/opex/api/ports/binance/controller/LandingController.kt b/api/api-ports/api-binance-rest/src/main/kotlin/co/nilin/opex/api/ports/binance/controller/LandingController.kt index e5646cf80..51fdd3b30 100644 --- a/api/api-ports/api-binance-rest/src/main/kotlin/co/nilin/opex/api/ports/binance/controller/LandingController.kt +++ b/api/api-ports/api-binance-rest/src/main/kotlin/co/nilin/opex/api/ports/binance/controller/LandingController.kt @@ -1,5 +1,6 @@ package co.nilin.opex.api.ports.binance.controller +import co.nilin.opex.api.core.inout.PriceStat import co.nilin.opex.api.core.inout.TradeVolumeStat import co.nilin.opex.api.core.spi.GlobalMarketProxy import co.nilin.opex.api.core.spi.MarketDataProxy @@ -52,15 +53,15 @@ class LandingController( val symbols = symbolMapper.symbolToAliasMap() val mostIncreased = async { - marketStatProxy.getMostIncreasedInPricePairs(since, validLimit).onEach { - symbols[it.symbol]?.let { s -> it.symbol = s } - } + marketStatProxy.getMostIncreasedInPricePairs(since, validLimit) + .onEach { symbols[it.symbol]?.let { s -> it.symbol = s } } + .ifEmpty { symbols.entries.map { PriceStat(it.value, BigDecimal.ZERO, 0.0) } } } val mostDecreased = async { - marketStatProxy.getMostDecreasedInPricePairs(since, validLimit).onEach { - symbols[it.symbol]?.let { s -> it.symbol = s } - } + marketStatProxy.getMostDecreasedInPricePairs(since, validLimit) + .onEach { symbols[it.symbol]?.let { s -> it.symbol = s } } + .ifEmpty { symbols.entries.map { PriceStat(it.value, BigDecimal.ZERO, 0.0) } } } val highestVolume = async {