Add SQL TaskCollection

Author: Gerrit Garbereder

.github/workflows/build.yml

@@ -52,6 +52,12 @@ jobs:
         ./gradlew check &&
         ./gradlew publishToMavenLocal &&
 
+        cd ../Task-Tracker-Usecases-SQLite-Impl &&
+        ln -s ../gradle &&
+        ln -s ../gradlew &&
+        ./gradlew check &&
+        ./gradlew publishToMavenLocal &&
+
         cd ../Task-Tracker-CLI &&
         ln -s ../gradle &&
         ln -s ../gradlew &&

Task-Tracker-Usecases-SQLite-Impl/build.gradle.kts

@@ -0,0 +1,67 @@
+plugins {
+    kotlin("multiplatform") version "1.8.22"
+    id("maven-publish")
+    id("app.cash.sqldelight") version "2.0.0-rc01"
+}
+
+group = "com.garbereder.tasktracker.usecases.sqlite"
+version = "1.0-SNAPSHOT"
+
+repositories {
+    mavenLocal()
+    mavenCentral()
+}
+
+sqldelight {
+    databases {
+        create("Database") {
+            packageName.set("com.garbereder.tasktracker.usecases.sqlite")
+        }
+    }
+}
+
+kotlin {
+    jvm {
+        jvmToolchain(17)
+        withJava()
+        testRuns["test"].executionTask.configure {
+            useJUnitPlatform()
+        }
+    }
+    val hostOs = System.getProperty("os.name")
+    val isMingwX64 = hostOs.startsWith("Windows")
+    val nativeTarget = when {
+        hostOs == "Mac OS X" -> macosX64("native")
+        hostOs == "Linux" -> linuxX64("native")
+        isMingwX64 -> mingwX64("native")
+        else -> throw GradleException("Host OS is not supported in Kotlin/Native.")
+    }
+
+    
+    sourceSets {
+        val commonMain by getting {
+            dependencies {
+                implementation("com.garbereder.tasktracker.usecases:Task-Tracker-Usecases:1.0-SNAPSHOT")
+                implementation("com.garbereder.tasktracker.entities:Task-Tracker-Entities:1.0-SNAPSHOT")
+                implementation("com.garbereder.tasktracker.entities-impl:Task-Tracker-Entities-Impl:1.0-SNAPSHOT")
+            }
+        }
+        val commonTest by getting {
+            dependencies {
+                implementation(kotlin("test"))
+            }
+        }
+        val jvmMain by getting{
+            dependencies {
+                implementation("app.cash.sqldelight:sqlite-driver:2.0.0-rc01")
+            }
+        }
+        val jvmTest by getting
+        val nativeMain by getting {
+            dependencies {
+                implementation("app.cash.sqldelight:native-driver:2.0.0-rc01")
+            }
+        }
+        val nativeTest by getting
+    }
+}

Task-Tracker-Usecases-SQLite-Impl/gradle.properties

@@ -0,0 +1,2 @@
+kotlin.code.style=official
+kotlin.js.compiler=ir

Task-Tracker-Usecases-SQLite-Impl/settings.gradle.kts

@@ -0,0 +1,3 @@
+
+rootProject.name = "Task-Tracker-Usecases-SQLite-Impl"
+

Task-Tracker-Usecases-SQLite-Impl/src/commonMain/kotlin/com/garbereder/tasktracker/usecases/DBAwareTaskCollection.kt

@@ -0,0 +1,25 @@
+package com.garbereder.tasktracker.usecases
+
+import com.garbereder.tasktracker.entities.Task
+import com.garbereder.tasktracker.entities.TaskCollection
+import com.garbereder.tasktracker.usecases.sqlite.Database
+
+class DBAwareTaskCollection(private val baseCollection: TaskCollection, private val database: Database):
+    TaskCollection {
+    override fun add(task: Task) {
+        database.transaction {
+            database.tasksQueries.insert(task.id, task.name)
+            baseCollection.add(task)
+        }
+    }
+
+    override fun iterator(): Iterator<Task> = baseCollection.iterator()
+
+    override fun remove(task: Task) {
+        database.transaction {
+            database.tasksQueries.deleteById(task.id)
+            baseCollection.remove(task)
+        }
+    }
+    override fun size(): Int = baseCollection.size()
+}

Task-Tracker-Usecases-SQLite-Impl/src/commonMain/kotlin/com/garbereder/tasktracker/usecases/DBTaskCollectionReader.kt

@@ -0,0 +1,20 @@
+package com.garbereder.tasktracker.usecases
+
+import com.garbereder.tasktracker.entities.Task
+import com.garbereder.tasktracker.entities.TaskCollection
+import com.garbereder.tasktracker.entities.TaskCollectionImpl
+import com.garbereder.tasktracker.usecases.sqlite.Database
+import com.garbereder.tasktracker.usecases.sqlite.DriverFactory
+import com.garbereder.tasktracker.usecases.tasks.TaskCollectionReader
+
+class DBTaskCollectionReader internal constructor(private val driverFactory: DriverFactory) : TaskCollectionReader {
+    override fun read(): TaskCollection {
+        val database = Database(driverFactory.createDriver())
+        val tasks = database.tasksQueries.selectAll()
+        val taskList = tasks.executeAsList()
+        val collection = TaskCollectionImpl()
+        taskList.forEach { t -> collection.add(Task(t.task_id, t.name)) }
+        return DBAwareTaskCollection(collection, database)
+    }
+}
+

Task-Tracker-Usecases-SQLite-Impl/src/commonMain/kotlin/com/garbereder/tasktracker/usecases/DBTaskCollectionReaderFactory.kt

@@ -0,0 +1,8 @@
+package com.garbereder.tasktracker.usecases
+
+import com.garbereder.tasktracker.usecases.tasks.TaskCollectionReader
+import com.garbereder.tasktracker.usecases.tasks.TaskCollectionReaderFactory
+
+expect class DBTaskCollectionReaderFactory : TaskCollectionReaderFactory {
+    override fun create(): TaskCollectionReader
+}

Task-Tracker-Usecases-SQLite-Impl/src/commonMain/kotlin/com/garbereder/tasktracker/usecases/sqlite/DriverFactory.kt

@@ -0,0 +1,13 @@
+package com.garbereder.tasktracker.usecases.sqlite
+
+import app.cash.sqldelight.db.SqlDriver
+
+expect class DriverFactory {
+  fun createDriver(): SqlDriver
+}
+
+fun createDatabase(driverFactory: DriverFactory): Database {
+  val driver = driverFactory.createDriver()
+  val database = Database(driver)
+  return database
+}

Task-Tracker-Usecases-SQLite-Impl/src/commonMain/sqldelight/com/garbereder/tasktracker/usecases/sqlite/sqldelight/tasktracker/data/Tasks.sq

@@ -0,0 +1,18 @@
+CREATE TABLE IF NOT EXISTS Task (
+  task_id TEXT NOT NULL,
+  name TEXT NOT NULL
+);
+
+CREATE UNIQUE INDEX IF NOT EXISTS task_id_ix ON Task(task_id);
+
+selectAll:
+SELECT *
+FROM Task;
+
+insert:
+INSERT INTO Task(task_id, name)
+VALUES (?, ?);
+
+deleteById:
+DELETE FROM Task
+WHERE task_id = ?;

Task-Tracker-Usecases-SQLite-Impl/src/jvmMain/kotlin/com/garbereder/tasktracker/usecases/DBTaskCollectionReaderFactory.kt

@@ -0,0 +1,9 @@
+package com.garbereder.tasktracker.usecases
+
+import com.garbereder.tasktracker.usecases.sqlite.DriverFactory
+import com.garbereder.tasktracker.usecases.tasks.TaskCollectionReader
+import com.garbereder.tasktracker.usecases.tasks.TaskCollectionReaderFactory
+
+actual class DBTaskCollectionReaderFactory : TaskCollectionReaderFactory {
+    actual override fun create(): TaskCollectionReader = DBTaskCollectionReader(DriverFactory())
+}