Add schemas and queries.

android/app/src/main/java/io/github/reactivecircus/kstreamlined/android/di/PersistenceModule.kt

@@ -7,6 +7,8 @@ import dagger.Provides
 import dagger.hilt.InstallIn
 import dagger.hilt.android.qualifiers.ApplicationContext
 import dagger.hilt.components.SingletonComponent
+import io.github.reactivecircus.kstreamlined.kmp.persistence.database.FeedItemEntity
+import io.github.reactivecircus.kstreamlined.kmp.persistence.database.InstantAdapter
 import io.github.reactivecircus.kstreamlined.kmp.persistence.database.KStreamlinedDatabase
 import javax.inject.Singleton
 
@@ -24,6 +26,9 @@ object PersistenceModule {
                 schema = KStreamlinedDatabase.Schema,
                 context = context,
                 name = "kstreamlined.db",
+            ),
+            feedItemEntityAdapter = FeedItemEntity.Adapter(
+                publishTimeAdapter = InstantAdapter
             )
         )
     }

kmp/persistence/build.gradle.kts

@@ -17,6 +17,7 @@ kotlin {
         commonMain {
             dependencies {
                 implementation(libs.androidx.dataStore)
+                api(libs.kotlinx.datetime)
             }
         }
     }

kmp/persistence/src/commonMain/kotlin/io/github/reactivecircus/kstreamlined/kmp/persistence/database/adapters.kt

@@ -0,0 +1,15 @@
+package io.github.reactivecircus.kstreamlined.kmp.persistence.database
+
+import app.cash.sqldelight.ColumnAdapter
+import kotlinx.datetime.Instant
+import kotlinx.datetime.toInstant
+
+public val InstantAdapter: ColumnAdapter<Instant, String> = object : ColumnAdapter<Instant, String> {
+    override fun decode(databaseValue: String): Instant {
+        return databaseValue.toInstant()
+    }
+
+    override fun encode(value: Instant): String {
+        return value.toString()
+    }
+}

kmp/persistence/src/commonMain/sqldelight/io/github/reactivecircus/kstreamlined/kmp/persistence/database/FeedIOriginEntity.sq

@@ -0,0 +1,17 @@
+import kotlin.Boolean;
+
+CREATE TABLE feedOriginEntity (
+    key TEXT NOT NULL PRIMARY KEY,
+    title TEXT NOT NULL,
+    description TEXT NOT NULL,
+    selected INTEGER AS Boolean NOT NULL
+);
+
+CREATE INDEX index_feedOriginEntity_selected ON feedOriginEntity(selected);
+
+allFeedOrigins:
+SELECT * FROM feedOriginEntity;
+
+upsertFeedOrigin:
+INSERT OR REPLACE INTO feedOriginEntity
+VALUES (:key, :title, :description, :selected);

kmp/persistence/src/commonMain/sqldelight/io/github/reactivecircus/kstreamlined/kmp/persistence/database/FeedItemEntity.sq

@@ -1,11 +1,29 @@
 import kotlin.Boolean;
+import kotlinx.datetime.Instant;
 
 CREATE TABLE feedItemEntity (
     id TEXT NOT NULL PRIMARY KEY,
+    feedOriginKey TEXT NOT NULL,
     title TEXT NOT NULL,
-    publishTime TEXT NOT NULL,
-    savedForLater INTEGER AS Boolean NOT NULL
+    publishTime TEXT AS Instant NOT NULL,
+    contentUrl TEXT NOT NULL,
+    imageUrl TEXT,
+    savedForLater INTEGER AS Boolean NOT NULL,
+    FOREIGN KEY(feedOriginKey) REFERENCES feedOriginEntity(key) ON DELETE CASCADE
 );
 
-findAllFeedItems:
-SELECT * FROM feedItemEntity;
+CREATE INDEX index_feedItemEntity_feedOriginKey ON feedItemEntity(feedOriginKey);
+CREATE INDEX index_feedItemEntity_savedForLater ON feedItemEntity(savedForLater);
+
+feedItemsForSelectedOrigins:
+SELECT feedItemEntity.* FROM feedItemEntity
+JOIN feedOriginEntity ON feedItemEntity.feedOriginKey = feedOriginEntity.key
+WHERE feedOriginEntity.selected = 1
+ORDER BY feedItemEntity.publishTime DESC;
+
+savedFeedItems:
+SELECT * FROM feedItemEntity WHERE savedForLater = 1 ORDER BY publishTime DESC;
+
+upsertFeedItem:
+INSERT OR REPLACE INTO feedItemEntity
+VALUES (:id, :feedOriginKey, :title, :publishTime, :contentUrl, :imageUrl, :savedForLater);