Merge pull request #75 from kirill-markin/codex/progress-review-schedule

Add cross-platform review-schedule progress

Author: kirill-markin

apps/android/app/src/androidTest/java/com/flashcardsopensourceapp/app/RepositorySeedExecutor.kt

@@ -165,7 +165,11 @@ internal class RepositorySeedExecutor(
                 cardId = cardId,
                 tags = seedCard.tags
             )
-            appGraph.syncLocalStore.enqueueCardUpsert(card = card, tags = resolvedTags)
+            appGraph.syncLocalStore.enqueueCardUpsert(
+                card = card,
+                tags = resolvedTags,
+                affectsReviewSchedule = true
+            )
             resolvedTags
         }
         return RepositorySeededCard(

apps/android/app/src/main/java/com/flashcardsopensourceapp/app/ProgressContextRefreshController.kt

@@ -60,6 +60,17 @@ class ProgressContextRefreshController(
                         error = error
                     )
                 }
+
+                try {
+                    progressRepository.refreshReviewScheduleIfInvalidated()
+                } catch (error: CancellationException) {
+                    throw error
+                } catch (error: Exception) {
+                    logProgressContextRefreshFailure(
+                        message = "Failed to refresh invalidated progress review schedule.",
+                        error = error
+                    )
+                }
             }
         }
     }

apps/android/app/src/test/java/com/flashcardsopensourceapp/app/ProgressContextRefreshControllerTest.kt

@@ -1,6 +1,7 @@
 package com.flashcardsopensourceapp.app
 
 import com.flashcardsopensourceapp.core.ui.VisibleAppScreen
+import com.flashcardsopensourceapp.data.local.model.ProgressReviewScheduleSnapshot
 import com.flashcardsopensourceapp.data.local.model.ProgressSeriesSnapshot
 import com.flashcardsopensourceapp.data.local.model.ProgressSummarySnapshot
 import com.flashcardsopensourceapp.data.local.repository.ProgressRepository
@@ -36,10 +37,11 @@ class ProgressContextRefreshControllerTest {
 
         assertEquals(1, repository.summaryRefreshCallCount)
         assertEquals(0, repository.seriesRefreshCallCount)
+        assertEquals(0, repository.reviewScheduleRefreshCallCount)
     }
 
     @Test
-    fun refreshIfInvalidatedRefreshesSummaryAndSeriesOnProgressScreen() = runBlocking {
+    fun refreshIfInvalidatedRefreshesAllProgressSectionsOnProgressScreen() = runBlocking {
         val repository = FakeProgressRepository()
         val appScope = CoroutineScope(context = Dispatchers.Default)
         val controller = ProgressContextRefreshController(
@@ -52,14 +54,16 @@ class ProgressContextRefreshControllerTest {
 
             awaitUntil {
                 repository.summaryRefreshCallCount == 1 &&
-                    repository.seriesRefreshCallCount == 1
+                    repository.seriesRefreshCallCount == 1 &&
+                    repository.reviewScheduleRefreshCallCount == 1
             }
         } finally {
             appScope.cancel()
         }
 
         assertEquals(1, repository.summaryRefreshCallCount)
         assertEquals(1, repository.seriesRefreshCallCount)
+        assertEquals(1, repository.reviewScheduleRefreshCallCount)
     }
 
     @Test
@@ -81,19 +85,22 @@ class ProgressContextRefreshControllerTest {
 
             assertEquals(1, repository.summaryRefreshCallCount)
             assertEquals(0, repository.seriesRefreshCallCount)
+            assertEquals(0, repository.reviewScheduleRefreshCallCount)
 
             repository.releaseFirstSummaryRefresh()
 
             awaitUntil {
                 repository.summaryRefreshCallCount == 2 &&
-                    repository.seriesRefreshCallCount == 0
+                    repository.seriesRefreshCallCount == 0 &&
+                    repository.reviewScheduleRefreshCallCount == 0
             }
         } finally {
             appScope.cancel()
         }
 
         assertEquals(2, repository.summaryRefreshCallCount)
         assertEquals(0, repository.seriesRefreshCallCount)
+        assertEquals(0, repository.reviewScheduleRefreshCallCount)
     }
 
     @Test
@@ -109,20 +116,23 @@ class ProgressContextRefreshControllerTest {
             controller.refreshIfInvalidated(visibleScreen = VisibleAppScreen.PROGRESS)
             awaitUntil {
                 repository.summaryRefreshCallCount == 1 &&
-                    repository.seriesRefreshCallCount == 1
+                    repository.seriesRefreshCallCount == 1 &&
+                    repository.reviewScheduleRefreshCallCount == 1
             }
 
             controller.refreshIfInvalidated(visibleScreen = VisibleAppScreen.PROGRESS)
             awaitUntil {
                 repository.summaryRefreshCallCount == 2 &&
-                    repository.seriesRefreshCallCount == 2
+                    repository.seriesRefreshCallCount == 2 &&
+                    repository.reviewScheduleRefreshCallCount == 2
             }
         } finally {
             appScope.cancel()
         }
 
         assertEquals(2, repository.summaryRefreshCallCount)
         assertEquals(2, repository.seriesRefreshCallCount)
+        assertEquals(2, repository.reviewScheduleRefreshCallCount)
     }
 }
 
@@ -138,6 +148,9 @@ private class FakeProgressRepository(
     @Volatile
     var seriesRefreshCallCount: Int = 0
 
+    @Volatile
+    var reviewScheduleRefreshCallCount: Int = 0
+
     override fun observeSummarySnapshot(): Flow<ProgressSummarySnapshot?> {
         return emptyFlow()
     }
@@ -146,6 +159,10 @@ private class FakeProgressRepository(
         return emptyFlow()
     }
 
+    override fun observeReviewScheduleSnapshot(): Flow<ProgressReviewScheduleSnapshot?> {
+        return emptyFlow()
+    }
+
     override suspend fun refreshSummaryIfInvalidated() {
         summaryRefreshCallCount += 1
         if (failFirstSummaryRefresh && summaryRefreshCallCount == 1) {
@@ -160,6 +177,10 @@ private class FakeProgressRepository(
         seriesRefreshCallCount += 1
     }
 
+    override suspend fun refreshReviewScheduleIfInvalidated() {
+        reviewScheduleRefreshCallCount += 1
+    }
+
     override suspend fun refreshSummaryManually() {
         throw UnsupportedOperationException("Not used in ProgressContextRefreshControllerTest.")
     }
@@ -168,6 +189,10 @@ private class FakeProgressRepository(
         throw UnsupportedOperationException("Not used in ProgressContextRefreshControllerTest.")
     }
 
+    override suspend fun refreshReviewScheduleManually() {
+        throw UnsupportedOperationException("Not used in ProgressContextRefreshControllerTest.")
+    }
+
     fun releaseFirstSummaryRefresh() {
         releaseFirstSummaryRefreshSignal.complete(value = Unit)
     }