add rss source db

Tlaster · Tlaster · commit 57ab9a772a8e · 2025-01-15T11:39:16.000+08:00
diff --git a/shared/schemas/dev.dimension.flare.data.database.app.AppDatabase/4.json b/shared/schemas/dev.dimension.flare.data.database.app.AppDatabase/4.json
@@ -2,7 +2,7 @@
   "formatVersion": 1,
   "database": {
     "version": 4,
-    "identityHash": "254782b3237e8fbc34a2e5f26647a2fb",
+    "identityHash": "7f851509975964fb11a67225ecd00f90",
     "entities": [
       {
         "tableName": "DbAccount",
@@ -143,39 +143,38 @@
         }
       },
       {
-        "tableName": "DbGuestData",
-        "createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`id` INTEGER NOT NULL, `host` TEXT NOT NULL, `platformType` TEXT NOT NULL, PRIMARY KEY(`id`))",
+        "tableName": "DbRssSources",
+        "createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`url` TEXT NOT NULL, `title` TEXT, `lastUpdate` INTEGER NOT NULL, PRIMARY KEY(`url`))",
         "fields": [
           {
-            "fieldPath": "id",
-            "columnName": "id",
-            "affinity": "INTEGER",
+            "fieldPath": "url",
+            "columnName": "url",
+            "affinity": "TEXT",
             "notNull": true
           },
           {
-            "fieldPath": "host",
-            "columnName": "host",
-            "affinity": "TEXT",
-            "notNull": true
+            "fieldPath": "title",
+            "columnName": "title",
+            "affinity": "TEXT"
           },
           {
-            "fieldPath": "platformType",
-            "columnName": "platformType",
-            "affinity": "TEXT",
+            "fieldPath": "lastUpdate",
+            "columnName": "lastUpdate",
+            "affinity": "INTEGER",
             "notNull": true
           }
         ],
         "primaryKey": {
           "autoGenerate": false,
           "columnNames": [
-            "id"
+            "url"
           ]
         }
       }
     ],
     "setupQueries": [
       "CREATE TABLE IF NOT EXISTS room_master_table (id INTEGER PRIMARY KEY,identity_hash TEXT)",
-      "INSERT OR REPLACE INTO room_master_table (id,identity_hash) VALUES(42, '254782b3237e8fbc34a2e5f26647a2fb')"
+      "INSERT OR REPLACE INTO room_master_table (id,identity_hash) VALUES(42, '7f851509975964fb11a67225ecd00f90')"
     ]
   }
 }
diff --git a/shared/src/commonMain/kotlin/dev/dimension/flare/common/PagingState.kt b/shared/src/commonMain/kotlin/dev/dimension/flare/common/PagingState.kt
@@ -1,12 +1,17 @@
 package dev.dimension.flare.common
 
+import androidx.compose.runtime.Composable
 import androidx.compose.runtime.Immutable
+import androidx.compose.runtime.State
+import androidx.compose.runtime.produceState
 import androidx.paging.LoadState
 import androidx.paging.compose.LazyPagingItems
 import androidx.paging.compose.itemContentType
 import androidx.paging.compose.itemKey
 import dev.dimension.flare.ui.model.UiState
 import kotlinx.collections.immutable.ImmutableList
+import kotlinx.collections.immutable.toImmutableList
+import kotlinx.coroutines.flow.Flow
 import kotlin.contracts.ExperimentalContracts
 import kotlin.contracts.contract
 
@@ -47,6 +52,28 @@ public sealed class PagingState<T> {
 
         public abstract fun itemContentType(contentType: ((item: T) -> Any?)? = null): (index: Int) -> Any?
 
+        @Immutable
+        internal data class ImmutableSuccess<T : Any>(
+            private val data: ImmutableList<T>,
+            override val itemCount: Int = data.size,
+            override val isRefreshing: Boolean = false,
+            override val appendState: LoadState = LoadState.NotLoading(endOfPaginationReached = true),
+        ) : Success<T>() {
+            override fun get(index: Int): T? = data.getOrNull(index)
+
+            override fun peek(index: Int): T? = data.getOrNull(index)
+
+            override suspend fun refreshSuspend() {
+            }
+
+            override fun retry() {
+            }
+
+            override fun itemContentType(contentType: ((item: T) -> Any?)?): (index: Int) -> Any? = { null }
+
+            override fun itemKey(key: ((item: T) -> Any)?): (index: Int) -> Any = { it }
+        }
+
         @Immutable
         internal data class SingleSuccess<T : Any>(
             private val data: CacheableState<ImmutableList<T>>,
@@ -221,3 +248,11 @@ internal fun <T : Any> UiState<PagingState<T>>.flatten(): PagingState<T> =
         is UiState.Error -> PagingState.Error(throwable)
         is UiState.Success -> data
     }
+
+@Composable
+internal fun <T : Any> Flow<List<T>>.collectPagingState(): State<PagingState<T>> =
+    produceState<PagingState<T>>(initialValue = PagingState.Loading<T>()) {
+        collect {
+            value = PagingState.Success.ImmutableSuccess(it.toImmutableList())
+        }
+    }
diff --git a/shared/src/commonMain/kotlin/dev/dimension/flare/data/database/app/AppDatabase.kt b/shared/src/commonMain/kotlin/dev/dimension/flare/data/database/app/AppDatabase.kt
@@ -1,5 +1,6 @@
 package dev.dimension.flare.data.database.app
 
+import androidx.room.AutoMigration
 import androidx.room.ConstructedBy
 import androidx.room.Database
 import androidx.room.RoomDatabase
@@ -8,6 +9,7 @@ import androidx.room.TypeConverters
 import dev.dimension.flare.data.database.app.dao.AccountDao
 import dev.dimension.flare.data.database.app.dao.ApplicationDao
 import dev.dimension.flare.data.database.app.dao.KeywordFilterDao
+import dev.dimension.flare.data.database.app.dao.RssSourceDao
 import dev.dimension.flare.data.database.app.dao.SearchHistoryDao
 
 @Database(
@@ -16,8 +18,15 @@ import dev.dimension.flare.data.database.app.dao.SearchHistoryDao
         dev.dimension.flare.data.database.app.model.DbApplication::class,
         dev.dimension.flare.data.database.app.model.DbKeywordFilter::class,
         dev.dimension.flare.data.database.app.model.DbSearchHistory::class,
+        dev.dimension.flare.data.database.app.model.DbRssSources::class,
+    ],
+    version = 4,
+    autoMigrations = [
+        AutoMigration(
+            from = 3,
+            to = 4,
+        ),
     ],
-    version = 3,
 )
 @TypeConverters(
     dev.dimension.flare.data.database.adapter.MicroBlogKeyConverter::class,
@@ -32,6 +41,8 @@ internal abstract class AppDatabase : RoomDatabase() {
     abstract fun keywordFilterDao(): KeywordFilterDao
 
     abstract fun searchHistoryDao(): SearchHistoryDao
+
+    abstract fun rssSourceDao(): RssSourceDao
 }
 
 // The Room compiler generates the `actual` implementations.
diff --git a/shared/src/commonMain/kotlin/dev/dimension/flare/data/database/app/dao/RssSourceDao.kt b/shared/src/commonMain/kotlin/dev/dimension/flare/data/database/app/dao/RssSourceDao.kt
@@ -0,0 +1,19 @@
+package dev.dimension.flare.data.database.app.dao
+
+import androidx.room.Dao
+import androidx.room.Insert
+import androidx.room.Query
+import dev.dimension.flare.data.database.app.model.DbRssSources
+import kotlinx.coroutines.flow.Flow
+
+@Dao
+internal interface RssSourceDao {
+    @Insert
+    suspend fun insert(data: DbRssSources)
+
+    @Query("SELECT * FROM DbRssSources")
+    fun getAll(): Flow<List<DbRssSources>>
+
+    @Query("DELETE FROM DbRssSources WHERE url = :url")
+    suspend fun delete(url: String)
+}
diff --git a/shared/src/commonMain/kotlin/dev/dimension/flare/data/database/app/model/DbRssSources.kt b/shared/src/commonMain/kotlin/dev/dimension/flare/data/database/app/model/DbRssSources.kt
@@ -0,0 +1,12 @@
+package dev.dimension.flare.data.database.app.model
+
+import androidx.room.Entity
+import androidx.room.PrimaryKey
+
+@Entity
+internal data class DbRssSources(
+    @PrimaryKey
+    val url: String,
+    val title: String?,
+    val lastUpdate: Long,
+)
diff --git a/shared/src/commonMain/kotlin/dev/dimension/flare/ui/model/UiRssSource.kt b/shared/src/commonMain/kotlin/dev/dimension/flare/ui/model/UiRssSource.kt
@@ -0,0 +1,9 @@
+package dev.dimension.flare.ui.model
+
+import dev.dimension.flare.ui.render.UiDateTime
+
+public data class UiRssSource(
+    val url: String,
+    val title: String?,
+    val lastUpdate: UiDateTime,
+)
diff --git a/shared/src/commonMain/kotlin/dev/dimension/flare/ui/model/mapper/Render.kt b/shared/src/commonMain/kotlin/dev/dimension/flare/ui/model/mapper/Render.kt
@@ -1,6 +1,7 @@
 package dev.dimension.flare.ui.model.mapper
 
 import com.fleeksoft.ksoup.nodes.Element
+import dev.dimension.flare.data.database.app.model.DbRssSources
 import dev.dimension.flare.data.database.cache.model.DbDirectMessageTimelineWithRoom
 import dev.dimension.flare.data.database.cache.model.DbMessageItemWithUser
 import dev.dimension.flare.data.database.cache.model.DbPagingTimelineWithStatus
@@ -14,6 +15,7 @@ import dev.dimension.flare.model.MicroBlogKey
 import dev.dimension.flare.model.ReferenceType
 import dev.dimension.flare.ui.model.UiDMItem
 import dev.dimension.flare.ui.model.UiDMRoom
+import dev.dimension.flare.ui.model.UiRssSource
 import dev.dimension.flare.ui.model.UiTimeline
 import dev.dimension.flare.ui.render.toUi
 import kotlinx.collections.immutable.toImmutableList
@@ -163,3 +165,10 @@ internal fun DbMessageItemWithUser.render(accountKey: MicroBlogKey) =
                 is MessageContent.Bluesky -> null
             },
     )
+
+internal fun DbRssSources.render() =
+    UiRssSource(
+        url = url,
+        title = title,
+        lastUpdate = Instant.fromEpochMilliseconds(lastUpdate).toUi(),
+    )
diff --git a/shared/src/commonMain/kotlin/dev/dimension/flare/ui/presenter/home/rss/RssSourcesPresenter.kt b/shared/src/commonMain/kotlin/dev/dimension/flare/ui/presenter/home/rss/RssSourcesPresenter.kt
@@ -0,0 +1,60 @@
+package dev.dimension.flare.ui.presenter.home.rss
+
+import androidx.compose.runtime.Composable
+import androidx.compose.runtime.getValue
+import androidx.compose.runtime.remember
+import androidx.compose.runtime.rememberCoroutineScope
+import dev.dimension.flare.common.PagingState
+import dev.dimension.flare.common.collectPagingState
+import dev.dimension.flare.data.database.app.AppDatabase
+import dev.dimension.flare.ui.model.UiRssSource
+import dev.dimension.flare.ui.model.mapper.render
+import dev.dimension.flare.ui.presenter.PresenterBase
+import kotlinx.coroutines.flow.map
+import kotlinx.coroutines.launch
+import org.koin.core.component.KoinComponent
+import org.koin.core.component.inject
+
+public class RssSourcesPresenter :
+    PresenterBase<RssSourcesPresenter.State>(),
+    KoinComponent {
+    private val appDatabase by inject<AppDatabase>()
+
+    public interface State {
+        public val sources: PagingState<UiRssSource>
+
+        public fun add(
+            url: String,
+            title: String,
+        )
+
+        public fun delete(url: String)
+    }
+
+    @Composable
+    override fun body(): State {
+        val scope = rememberCoroutineScope()
+        val sources by remember {
+            appDatabase.rssSourceDao().getAll().map {
+                it.map {
+                    it.render()
+                }
+            }
+        }.collectPagingState()
+        return object : State {
+            override val sources: PagingState<UiRssSource> = sources
+
+            override fun add(
+                url: String,
+                title: String,
+            ) {
+            }
+
+            override fun delete(url: String) {
+                scope.launch {
+                    appDatabase.rssSourceDao().delete(url)
+                }
+            }
+        }
+    }
+}

Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,7 @@`
`2`	`2`	`"formatVersion": 1,`
`3`	`3`	`"database": {`
`4`	`4`	`"version": 4,`
`5`		`- "identityHash": "254782b3237e8fbc34a2e5f26647a2fb",`
	`5`	`+ "identityHash": "7f851509975964fb11a67225ecd00f90",`
`6`	`6`	`"entities": [`
`7`	`7`	`{`
`8`	`8`	`"tableName": "DbAccount",`
`@@ -143,39 +143,38 @@`
`143`	`143`	`}`
`144`	`144`	`},`
`145`	`145`	`{`
`146`		`- "tableName": "DbGuestData",`
`147`		- "createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`id` INTEGER NOT NULL, `host` TEXT NOT NULL, `platformType` TEXT NOT NULL, PRIMARY KEY(`id`))",
	`146`	`+ "tableName": "DbRssSources",`
	`147`	+ "createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`url` TEXT NOT NULL, `title` TEXT, `lastUpdate` INTEGER NOT NULL, PRIMARY KEY(`url`))",
`148`	`148`	`"fields": [`
`149`	`149`	`{`
`150`		`- "fieldPath": "id",`
`151`		`- "columnName": "id",`
`152`		`- "affinity": "INTEGER",`
	`150`	`+ "fieldPath": "url",`
	`151`	`+ "columnName": "url",`
	`152`	`+ "affinity": "TEXT",`
`153`	`153`	`"notNull": true`
`154`	`154`	`},`
`155`	`155`	`{`
`156`		`- "fieldPath": "host",`
`157`		`- "columnName": "host",`
`158`		`- "affinity": "TEXT",`
`159`		`- "notNull": true`
	`156`	`+ "fieldPath": "title",`
	`157`	`+ "columnName": "title",`
	`158`	`+ "affinity": "TEXT"`
`160`	`159`	`},`
`161`	`160`	`{`
`162`		`- "fieldPath": "platformType",`
`163`		`- "columnName": "platformType",`
`164`		`- "affinity": "TEXT",`
	`161`	`+ "fieldPath": "lastUpdate",`
	`162`	`+ "columnName": "lastUpdate",`
	`163`	`+ "affinity": "INTEGER",`
`165`	`164`	`"notNull": true`
`166`	`165`	`}`
`167`	`166`	`],`
`168`	`167`	`"primaryKey": {`
`169`	`168`	`"autoGenerate": false,`
`170`	`169`	`"columnNames": [`
`171`		`- "id"`
	`170`	`+ "url"`
`172`	`171`	`]`
`173`	`172`	`}`
`174`	`173`	`}`
`175`	`174`	`],`
`176`	`175`	`"setupQueries": [`
`177`	`176`	`"CREATE TABLE IF NOT EXISTS room_master_table (id INTEGER PRIMARY KEY,identity_hash TEXT)",`
`178`		`- "INSERT OR REPLACE INTO room_master_table (id,identity_hash) VALUES(42, '254782b3237e8fbc34a2e5f26647a2fb')"`
	`177`	`+ "INSERT OR REPLACE INTO room_master_table (id,identity_hash) VALUES(42, '7f851509975964fb11a67225ecd00f90')"`
`179`	`178`	`]`
`180`	`179`	`}`
`181`	`180`	`}`