Update currencies only when cache is not available

This commit is contained in:
Sad Ellie 2023-09-28 13:27:08 +03:00
parent 5554de21fb
commit ecd06ec947

View File

@ -199,23 +199,28 @@ class UnitsRepository @Inject constructor(
} }
suspend fun updateRates(unit: AbstractUnit): LocalDate? = withContext(Dispatchers.IO) { suspend fun updateRates(unit: AbstractUnit): LocalDate? = withContext(Dispatchers.IO) {
var basedConversions = currencyRatesDao.getLatestRates(baseId = unit.id)
val epochDay = LocalDate.now().toEpochDay()
if (basedConversions.firstOrNull()?.date != epochDay) {
try { try {
val conversions = CurrencyApi.service.getCurrencyPairs(unit.id) val conversions = CurrencyApi.service.getCurrencyPairs(unit.id)
val rates = conversions.currency val rates = conversions.currency
.map { (pairId, pairValue) -> .map { (pairId, pairValue) ->
CurrencyRatesEntity( CurrencyRatesEntity(
baseUnitId = unit.id, baseUnitId = unit.id,
date = LocalDate.now().toEpochDay(), date = epochDay,
pairUnitId = pairId, pairUnitId = pairId,
pairUnitValue = BigDecimal.valueOf(pairValue) pairUnitValue = BigDecimal.valueOf(pairValue)
) )
} }
currencyRatesDao.insertRates(rates) currencyRatesDao.insertRates(rates)
basedConversions = currencyRatesDao.getLatestRates(baseId = unit.id)
} catch (e: Exception) { } catch (e: Exception) {
Log.d("UnitsRepository", "Skipped update: $e") Log.d("UnitsRepository", "Skipped update: $e")
} }
val basedConversions = currencyRatesDao.getLatestRates(baseId = unit.id) }
myUnits.update { units -> myUnits.update { units ->
units.map { localUnit -> units.map { localUnit ->
if (localUnit.group != UnitGroup.CURRENCY) return@map localUnit if (localUnit.group != UnitGroup.CURRENCY) return@map localUnit