Rework FreshRSS sync (#1495)

jocmp · web-flow · commit 8922f4428db3 · 2025-09-22T16:47:15.000-05:00
- Skip overfetching tagged items - Skip fetching all articles "since" using `ot` param Details: - <https://github.com/bazqux/bazqux-api?tab=readme-ov-file#the-right-way-to-sync>
diff --git a/capy/src/main/java/com/jocmp/capy/accounts/reader/ReaderAccountDelegate.kt b/capy/src/main/java/com/jocmp/capy/accounts/reader/ReaderAccountDelegate.kt
@@ -238,12 +238,9 @@ internal class ReaderAccountDelegate(
     }
 
     private suspend fun refreshTopLevelArticles() {
-        val since = articleRecords.maxArrivedAt().toEpochSecond()
-
         refreshFeeds()
         refreshAllSavedSearches()
         refreshArticleState()
-        fetchPaginatedArticles(since = since, stream = Stream.Read())
         fetchMissingArticles()
     }
 
@@ -295,15 +292,6 @@ internal class ReaderAccountDelegate(
                 savedSearchRecords.deleteOrphaned(excludedIDs = tags.map { it.id })
             }
         }
-
-        coroutineScope {
-            savedSearchRecords.allIDs()
-                .forEach { savedSearchID ->
-                    launch {
-                        fetchPaginatedArticles(stream = Stream.UserLabel(savedSearchID))
-                    }
-                }
-        }
     }
 
     private fun upsertSavedSearch(tag: Tag) {

Original file line number	Diff line number	Diff line change
`@@ -238,12 +238,9 @@ internal class ReaderAccountDelegate(`
`238`	`238`	`}`
`239`	`239`
`240`	`240`	`private suspend fun refreshTopLevelArticles() {`
`241`		`- val since = articleRecords.maxArrivedAt().toEpochSecond()`
`242`		`-`
`243`	`241`	`refreshFeeds()`
`244`	`242`	`refreshAllSavedSearches()`
`245`	`243`	`refreshArticleState()`
`246`		`- fetchPaginatedArticles(since = since, stream = Stream.Read())`
`247`	`244`	`fetchMissingArticles()`
`248`	`245`	`}`
`249`	`246`
`@@ -295,15 +292,6 @@ internal class ReaderAccountDelegate(`
`295`	`292`	`savedSearchRecords.deleteOrphaned(excludedIDs = tags.map { it.id })`
`296`	`293`	`}`
`297`	`294`	`}`
`298`		`-`
`299`		`- coroutineScope {`
`300`		`- savedSearchRecords.allIDs()`
`301`		`- .forEach { savedSearchID ->`
`302`		`- launch {`
`303`		`- fetchPaginatedArticles(stream = Stream.UserLabel(savedSearchID))`
`304`		`- }`
`305`		`- }`
`306`		`- }`
`307`	`295`	`}`
`308`	`296`
`309`	`297`	`private fun upsertSavedSearch(tag: Tag) {`