Merge pull request #344 from OpenHub-Store/togglable-liquid

Author: rainxchzed

core/data/schemas/zed.rainxch.core.data.local.db.AppDatabase/4.json

@@ -7,6 +7,7 @@ import zed.rainxch.core.data.local.db.migrations.MIGRATION_1_2
 import zed.rainxch.core.data.local.db.migrations.MIGRATION_2_3
 import zed.rainxch.core.data.local.db.migrations.MIGRATION_3_4
 import zed.rainxch.core.data.local.db.migrations.MIGRATION_4_5
+import zed.rainxch.core.data.local.db.migrations.MIGRATION_5_6
 
 fun initDatabase(context: Context): AppDatabase {
     val appContext = context.applicationContext
@@ -21,5 +22,6 @@ fun initDatabase(context: Context): AppDatabase {
             MIGRATION_2_3,
             MIGRATION_3_4,
             MIGRATION_4_5,
+            MIGRATION_5_6,
         ).build()
 }

core/data/schemas/zed.rainxch.core.data.local.db.AppDatabase/5.json

@@ -0,0 +1,18 @@
+package zed.rainxch.core.data.local.db.migrations
+
+import androidx.room.migration.Migration
+import androidx.sqlite.db.SupportSQLiteDatabase
+
+val MIGRATION_5_6 =
+    object : Migration(5, 6) {
+        override fun migrate(db: SupportSQLiteDatabase) {
+            db.execSQL(
+                """
+                CREATE TABLE IF NOT EXISTS seen_repos (
+                    repoId INTEGER NOT NULL PRIMARY KEY,
+                    seenAt INTEGER NOT NULL
+                )
+                """.trimIndent(),
+            )
+        }
+    }

core/data/schemas/zed.rainxch.core.data.local.db.AppDatabase/6.json

@@ -15,6 +15,7 @@ import zed.rainxch.core.data.local.db.AppDatabase
 import zed.rainxch.core.data.local.db.dao.CacheDao
 import zed.rainxch.core.data.local.db.dao.FavoriteRepoDao
 import zed.rainxch.core.data.local.db.dao.InstalledAppDao
+import zed.rainxch.core.data.local.db.dao.SeenRepoDao
 import zed.rainxch.core.data.local.db.dao.StarredRepoDao
 import zed.rainxch.core.data.local.db.dao.UpdateHistoryDao
 import zed.rainxch.core.data.logging.KermitLogger
@@ -26,6 +27,7 @@ import zed.rainxch.core.data.repository.FavouritesRepositoryImpl
 import zed.rainxch.core.data.repository.InstalledAppsRepositoryImpl
 import zed.rainxch.core.data.repository.ProxyRepositoryImpl
 import zed.rainxch.core.data.repository.RateLimitRepositoryImpl
+import zed.rainxch.core.data.repository.SeenReposRepositoryImpl
 import zed.rainxch.core.data.repository.StarredRepositoryImpl
 import zed.rainxch.core.data.repository.TweaksRepositoryImpl
 import zed.rainxch.core.domain.getPlatform
@@ -37,6 +39,7 @@ import zed.rainxch.core.domain.repository.FavouritesRepository
 import zed.rainxch.core.domain.repository.InstalledAppsRepository
 import zed.rainxch.core.domain.repository.ProxyRepository
 import zed.rainxch.core.domain.repository.RateLimitRepository
+import zed.rainxch.core.domain.repository.SeenReposRepository
 import zed.rainxch.core.domain.repository.StarredRepository
 import zed.rainxch.core.domain.repository.TweaksRepository
 import zed.rainxch.core.domain.use_cases.SyncInstalledAppsUseCase
@@ -94,6 +97,12 @@ val coreModule =
             )
         }
 
+        single<SeenReposRepository> {
+            SeenReposRepositoryImpl(
+                seenRepoDao = get(),
+            )
+        }
+
         single<ProxyRepository> {
             ProxyRepositoryImpl(
                 preferences = get(),
@@ -203,4 +212,8 @@ val databaseModule =
         single<CacheDao> {
             get<AppDatabase>().cacheDao
         }
+
+        single<SeenRepoDao> {
+            get<AppDatabase>().seenRepoDao
+        }
     }

core/data/src/androidMain/kotlin/zed/rainxch/core/data/local/db/initDatabase.kt

@@ -5,11 +5,13 @@ import androidx.room.RoomDatabase
 import zed.rainxch.core.data.local.db.dao.CacheDao
 import zed.rainxch.core.data.local.db.dao.FavoriteRepoDao
 import zed.rainxch.core.data.local.db.dao.InstalledAppDao
+import zed.rainxch.core.data.local.db.dao.SeenRepoDao
 import zed.rainxch.core.data.local.db.dao.StarredRepoDao
 import zed.rainxch.core.data.local.db.dao.UpdateHistoryDao
 import zed.rainxch.core.data.local.db.entities.CacheEntryEntity
 import zed.rainxch.core.data.local.db.entities.FavoriteRepoEntity
 import zed.rainxch.core.data.local.db.entities.InstalledAppEntity
+import zed.rainxch.core.data.local.db.entities.SeenRepoEntity
 import zed.rainxch.core.data.local.db.entities.StarredRepositoryEntity
 import zed.rainxch.core.data.local.db.entities.UpdateHistoryEntity
 
@@ -20,8 +22,9 @@ import zed.rainxch.core.data.local.db.entities.UpdateHistoryEntity
         UpdateHistoryEntity::class,
         StarredRepositoryEntity::class,
         CacheEntryEntity::class,
+        SeenRepoEntity::class,
     ],
-    version = 5,
+    version = 6,
     exportSchema = true,
 )
 abstract class AppDatabase : RoomDatabase() {
@@ -30,4 +33,5 @@ abstract class AppDatabase : RoomDatabase() {
     abstract val updateHistoryDao: UpdateHistoryDao
     abstract val starredReposDao: StarredRepoDao
     abstract val cacheDao: CacheDao
+    abstract val seenRepoDao: SeenRepoDao
 }

core/data/src/androidMain/kotlin/zed/rainxch/core/data/local/db/migrations/MIGRATION_5_6.kt

@@ -0,0 +1,20 @@
+package zed.rainxch.core.data.local.db.dao
+
+import androidx.room.Dao
+import androidx.room.Insert
+import androidx.room.OnConflictStrategy
+import androidx.room.Query
+import kotlinx.coroutines.flow.Flow
+import zed.rainxch.core.data.local.db.entities.SeenRepoEntity
+
+@Dao
+interface SeenRepoDao {
+    @Query("SELECT repoId FROM seen_repos")
+    fun getAllSeenRepoIds(): Flow<List<Long>>
+
+    @Insert(onConflict = OnConflictStrategy.IGNORE)
+    suspend fun insert(entity: SeenRepoEntity)
+
+    @Query("DELETE FROM seen_repos")
+    suspend fun clearAll()
+}

core/data/src/commonMain/kotlin/zed/rainxch/core/data/di/SharedModule.kt

@@ -0,0 +1,11 @@
+package zed.rainxch.core.data.local.db.entities
+
+import androidx.room.Entity
+import androidx.room.PrimaryKey
+
+@Entity(tableName = "seen_repos")
+data class SeenRepoEntity(
+    @PrimaryKey
+    val repoId: Long,
+    val seenAt: Long,
+)

core/data/src/commonMain/kotlin/zed/rainxch/core/data/local/db/AppDatabase.kt

@@ -0,0 +1,27 @@
+package zed.rainxch.core.data.repository
+
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.map
+import zed.rainxch.core.data.local.db.dao.SeenRepoDao
+import zed.rainxch.core.data.local.db.entities.SeenRepoEntity
+import zed.rainxch.core.domain.repository.SeenReposRepository
+
+class SeenReposRepositoryImpl(
+    private val seenRepoDao: SeenRepoDao,
+) : SeenReposRepository {
+    override fun getAllSeenRepoIds(): Flow<Set<Long>> =
+        seenRepoDao.getAllSeenRepoIds().map { it.toSet() }
+
+    override suspend fun markAsSeen(repoId: Long) {
+        seenRepoDao.insert(
+            SeenRepoEntity(
+                repoId = repoId,
+                seenAt = System.currentTimeMillis(),
+            ),
+        )
+    }
+
+    override suspend fun clearAll() {
+        seenRepoDao.clearAll()
+    }
+}