yan/archived-matedroid
1
0
Fork 0
mirror of https://github.com/vide/matedroid.git synced 2026-01-20 00:03:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(stats): add per-item progress logging for sync

Browse Source 
Logs now show each drive/charge as it's synced with remaining count:
- "Drive 123 synced (45 remaining)"
- "Charge 456 synced (12 remaining)"

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
Davide Ferrari
2026-01-05 10:10:55 +01:00
co-authored by Claude Opus 4.5
parent c872d34c7c
commit 0cb28c5f0a
1 changed files with 12 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/src/main/java/com/matedroid/data/sync/SyncRepository.kt
+12 -6
View File
@@ -126,17 +126,20 @@ class SyncRepository @Inject constructor(
*/
suspend fun syncDriveDetails(carId: Int): Boolean {
val unprocessedIds = driveSummaryDao.getUnprocessedDriveIds(carId, SchemaVersion.CURRENT)
log("Processing ${unprocessedIds.size} drive details for car $carId")
val total = unprocessedIds.size
log("Processing $total drive details for car $carId")
for (driveId in unprocessedIds) {
unprocessedIds.forEachIndexed { index, driveId ->
val remaining = total - index - 1
when (val result = teslamateRepository.getDriveDetail(carId, driveId)) {
is ApiResult.Success -> {
val aggregate = computeDriveAggregate(carId, result.data)
aggregateDao.upsertDriveAggregate(aggregate)
syncManager.updateDriveDetailProgress(carId, driveId)
log("Drive $driveId synced ($remaining remaining)")
}
is ApiResult.Error -> {
logError("Failed to fetch drive $driveId: ${result.message}")
logError("Drive $driveId failed: ${result.message} ($remaining remaining)")
// Continue with next drive instead of failing entirely
}
}
@@ -154,17 +157,20 @@ class SyncRepository @Inject constructor(
*/
suspend fun syncChargeDetails(carId: Int): Boolean {
val unprocessedIds = chargeSummaryDao.getUnprocessedChargeIds(carId, SchemaVersion.CURRENT)
log("Processing ${unprocessedIds.size} charge details for car $carId")
val total = unprocessedIds.size
log("Processing $total charge details for car $carId")
for (chargeId in unprocessedIds) {
unprocessedIds.forEachIndexed { index, chargeId ->
val remaining = total - index - 1
when (val result = teslamateRepository.getChargeDetail(carId, chargeId)) {
is ApiResult.Success -> {
val aggregate = computeChargeAggregate(carId, result.data)
aggregateDao.upsertChargeAggregate(aggregate)
syncManager.updateChargeDetailProgress(carId, chargeId)
log("Charge $chargeId synced ($remaining remaining)")
}
is ApiResult.Error -> {
logError("Failed to fetch charge $chargeId: ${result.message}")
logError("Charge $chargeId failed: ${result.message} ($remaining remaining)")
// Continue with next charge instead of failing entirely
}
}