Added recent data update info
This commit is contained in:
1 parent
e531eb85e3
commit
1685691d2f
9 files changed
+57
-9
No files matched your search
@@ -75,6 +75,10 @@ interface ISettingsManager {
|
||||
|
||||
fun setUseUTC(value: Boolean)
|
||||
|
||||
fun getUpdateTime(): Long
|
||||
|
||||
fun setUpdateTime(updateTime: Long)
|
||||
|
||||
fun getUpdateEnabled(): Boolean
|
||||
|
||||
fun setUpdateEnabled(value: Boolean)
|
||||
|
||||
@@ -62,7 +62,7 @@ class DataRepository(
|
||||
delay(updateStateDelay)
|
||||
entrySource.insertEntries(importSatellites(stream))
|
||||
}
|
||||
_updateState.value = DataState.Success(0L)
|
||||
setUpdateSuccessful()
|
||||
}
|
||||
}
|
||||
|
||||
@@ -102,7 +102,7 @@ class DataRepository(
|
||||
}
|
||||
}
|
||||
entrySource.insertEntries(importedEntries)
|
||||
_updateState.value = DataState.Success(0L)
|
||||
setUpdateSuccessful()
|
||||
}
|
||||
repositoryScope.launch(exceptionHandler) {
|
||||
remoteSource.getDataStream(remoteSource.radioApi)?.let { stream ->
|
||||
@@ -121,10 +121,15 @@ class DataRepository(
|
||||
delay(updateStateDelay)
|
||||
entrySource.deleteEntries()
|
||||
radioSource.deleteRadios()
|
||||
_updateState.value = DataState.Success(0L)
|
||||
setUpdateSuccessful(0L)
|
||||
}
|
||||
}
|
||||
|
||||
private fun setUpdateSuccessful(updateTime: Long = System.currentTimeMillis()) {
|
||||
settingsManager.setUpdateTime(updateTime)
|
||||
_updateState.value = DataState.Success(updateTime)
|
||||
}
|
||||
|
||||
private suspend fun importSatellites(stream: InputStream): List<SatEntry> {
|
||||
return dataParser.parseTLEStream(stream).map { data -> SatEntry(data) }
|
||||
}
|
||||
|
||||
Reference in new issue
Block a user