Add support for searching feeds

resources/strings/src/commonMain/kotlin/dev/sasikanth/rss/reader/resources/strings/EnTwineStrings.kt

@@ -45,7 +45,7 @@ val EnTwineStrings =
     errorTooManyRedirects = "The given URL has too many redirects. Please use a different URL.",
     errorUnAuthorized = { "($it): You are not authorized to access content at this link." },
     errorUnknownHttpStatus = { "Failed to load content with HTTP code: ($it)" },
-    searchHint = "Search posts",
+    postsSearchHint = "Search posts",
     searchSortNewest = "Newest",
     searchSortNewestFirst = "Newest first",
     searchSortOldest = "Oldest",
@@ -81,4 +81,5 @@ val EnTwineStrings =
     aboutSocialThreads = "Threads",
     aboutSocialGitHub = "GitHub",
     aboutSocialWebsite = "Website",
+    feedsSearchHint = "Search feeds"
   )

resources/strings/src/commonMain/kotlin/dev/sasikanth/rss/reader/resources/strings/TwineStrings.kt

@@ -39,7 +39,7 @@ data class TwineStrings(
   val errorTooManyRedirects: String,
   val errorUnAuthorized: (Int) -> String,
   val errorUnknownHttpStatus: (Int) -> String,
-  val searchHint: String,
+  val postsSearchHint: String,
   val searchSortNewest: String,
   val searchSortNewestFirst: String,
   val searchSortOldest: String,
@@ -73,6 +73,7 @@ data class TwineStrings(
   val aboutSocialGitHub: String,
   // don't translate
   val aboutSocialWebsite: String,
+  val feedsSearchHint: String,
 )
 
 object Locales {

shared/src/commonMain/kotlin/dev/sasikanth/rss/reader/di/DataComponent.kt

@@ -49,4 +49,7 @@ internal interface DataComponent : SqlDriverPlatformComponent, DataStorePlatform
   fun providesPostSearchFTSQueries(database: ReaderDatabase) = database.postSearchFTSQueries
 
   @Provides fun providesBookmarkQueries(database: ReaderDatabase) = database.bookmarkQueries
+
+  @Provides
+  fun providesFeedSearchFTSQueries(database: ReaderDatabase) = database.feedSearchFTSQueries
 }

shared/src/commonMain/kotlin/dev/sasikanth/rss/reader/feeds/FeedsEvent.kt

@@ -15,6 +15,7 @@
  */
 package dev.sasikanth.rss.reader.feeds
 
+import androidx.compose.ui.text.input.TextFieldValue
 import dev.sasikanth.rss.reader.models.local.Feed
 
 sealed interface FeedsEvent {
@@ -30,4 +31,8 @@ sealed interface FeedsEvent {
   data class OnFeedNameUpdated(val newFeedName: String, val feedLink: String) : FeedsEvent
 
   data class OnFeedPinClicked(val feed: Feed) : FeedsEvent
+
+  data class SearchQueryChanged(val searchQuery: TextFieldValue) : FeedsEvent
+
+  object ClearSearchQuery : FeedsEvent
 }

shared/src/commonMain/kotlin/dev/sasikanth/rss/reader/feeds/FeedsPresenter.kt

@@ -15,10 +15,14 @@
  */
 package dev.sasikanth.rss.reader.feeds
 
+import androidx.compose.runtime.getValue
+import androidx.compose.runtime.mutableStateOf
+import androidx.compose.runtime.setValue
+import androidx.compose.runtime.snapshotFlow
+import androidx.compose.ui.text.input.TextFieldValue
 import app.cash.paging.cachedIn
 import app.cash.paging.createPager
 import app.cash.paging.createPagingConfig
-import app.cash.paging.map
 import com.arkivanov.decompose.ComponentContext
 import com.arkivanov.essenty.instancekeeper.InstanceKeeper
 import com.arkivanov.essenty.instancekeeper.getOrCreate
@@ -27,14 +31,17 @@ import dev.sasikanth.rss.reader.models.local.Feed
 import dev.sasikanth.rss.reader.repository.ObservableSelectedFeed
 import dev.sasikanth.rss.reader.repository.RssRepository
 import dev.sasikanth.rss.reader.utils.DispatchersProvider
+import kotlin.time.Duration.Companion.milliseconds
 import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.FlowPreview
 import kotlinx.coroutines.SupervisorJob
 import kotlinx.coroutines.cancel
 import kotlinx.coroutines.flow.MutableSharedFlow
 import kotlinx.coroutines.flow.MutableStateFlow
 import kotlinx.coroutines.flow.SharingStarted
 import kotlinx.coroutines.flow.StateFlow
 import kotlinx.coroutines.flow.asSharedFlow
+import kotlinx.coroutines.flow.debounce
 import kotlinx.coroutines.flow.distinctUntilChanged
 import kotlinx.coroutines.flow.flatMapLatest
 import kotlinx.coroutines.flow.launchIn
@@ -65,6 +72,8 @@ class FeedsPresenter(
 
   internal val state: StateFlow<FeedsState> = presenterInstance.state
   internal val effects = presenterInstance.effects.asSharedFlow()
+  internal val searchQuery
+    get() = presenterInstance.searchQuery
 
   init {
     lifecycle.doOnCreate { presenterInstance.dispatch(FeedsEvent.Init) }
@@ -78,6 +87,9 @@ class FeedsPresenter(
     private val observableSelectedFeed: ObservableSelectedFeed
   ) : InstanceKeeper.Instance {
 
+    var searchQuery by mutableStateOf(TextFieldValue())
+      private set
+
     private val coroutineScope = CoroutineScope(SupervisorJob() + dispatchersProvider.main)
 
     private val _state = MutableStateFlow(FeedsState.DEFAULT)
@@ -98,9 +110,19 @@ class FeedsPresenter(
         is FeedsEvent.OnFeedSelected -> onFeedSelected(event.feed)
         is FeedsEvent.OnFeedNameUpdated -> onFeedNameUpdated(event.newFeedName, event.feedLink)
         is FeedsEvent.OnFeedPinClicked -> onFeedPinClicked(event.feed)
+        FeedsEvent.ClearSearchQuery -> clearSearchQuery()
+        is FeedsEvent.SearchQueryChanged -> onSearchQueryChanged(event.searchQuery)
       }
     }
 
+    private fun onSearchQueryChanged(searchQuery: TextFieldValue) {
+      this.searchQuery = searchQuery
+    }
+
+    private fun clearSearchQuery() {
+      searchQuery = TextFieldValue()
+    }
+
     private fun onFeedPinClicked(feed: Feed) {
       coroutineScope.launch { rssRepository.toggleFeedPinStatus(feed) }
     }
@@ -129,6 +151,7 @@ class FeedsPresenter(
       coroutineScope.launch { effects.emit(FeedsEffect.MinimizeSheet) }
     }
 
+    @OptIn(FlowPreview::class)
     private fun init() {
       observableSelectedFeed.selectedFeed
         .flatMapLatest { selectedFeed ->
@@ -152,6 +175,29 @@ class FeedsPresenter(
           }
         }
         .launchIn(coroutineScope)
+
+      val searchQueryFlow = snapshotFlow { searchQuery }.debounce(500.milliseconds)
+      searchQueryFlow
+        .distinctUntilChanged()
+        .onEach { searchQuery ->
+          val searchQueryText = searchQuery.text
+          val transformedSearchQuery =
+            if (searchQueryText.length >= 3) {
+              searchQueryText
+            } else {
+              ""
+            }
+
+          val feedSearchResults =
+            createPager(config = createPagingConfig(pageSize = 20)) {
+                rssRepository.searchFeed(transformedSearchQuery)
+              }
+              .flow
+              .cachedIn(coroutineScope)
+
+          _state.update { it.copy(feedsSearchResults = feedSearchResults) }
+        }
+        .launchIn(coroutineScope)
     }
 
     override fun onDestroy() {

shared/src/commonMain/kotlin/dev/sasikanth/rss/reader/feeds/FeedsState.kt

@@ -28,12 +28,13 @@ import kotlinx.coroutines.flow.map
 @Immutable
 internal data class FeedsState(
   val feeds: Flow<PagingData<Feed>>,
+  val feedsSearchResults: Flow<PagingData<Feed>>,
   val selectedFeed: Feed?,
   val numberOfPinnedFeeds: Long
 ) {
 
   val feedsListInExpandedState: Flow<PagingData<FeedsListItemType>> =
-    feeds.map { feeds ->
+    feedsSearchResults.map { feeds ->
       feeds
         .map { feed -> FeedsListItemType.FeedListItem(feed = feed) }
         .insertSeparators { before, after ->
@@ -56,6 +57,12 @@ internal data class FeedsState(
 
   companion object {
 
-    val DEFAULT = FeedsState(feeds = emptyFlow(), selectedFeed = null, numberOfPinnedFeeds = 0)
+    val DEFAULT =
+      FeedsState(
+        feeds = emptyFlow(),
+        feedsSearchResults = emptyFlow(),
+        selectedFeed = null,
+        numberOfPinnedFeeds = 0
+      )
   }
 }