chore: add ktlint for linting and formatting

.editorconfig

@@ -0,0 +1,3 @@
+[*.{kt,kts}]
+ktlint_code_style = ktlint_official
+ktlint_standard_property-naming = disabled

PowerSync/build.gradle.kts

@@ -1,6 +1,5 @@
 import co.touchlab.faktory.artifactmanager.ArtifactManager
 import co.touchlab.faktory.capitalized
-import co.touchlab.skie.configuration.SuspendInterop
 import org.jetbrains.kotlin.gradle.plugin.mpp.KotlinNativeTarget
 import java.net.URL
 import java.security.MessageDigest
@@ -10,14 +9,15 @@ plugins {
     alias(libs.plugins.kmmbridge)
     alias(libs.plugins.skie)
     alias(libs.plugins.mavenPublishPlugin)
+    alias(libs.plugins.kotlinter)
     id("com.powersync.plugins.sonatype")
 }
 
 kotlin {
     listOf(
         iosX64(),
         iosArm64(),
-        iosSimulatorArm64()
+        iosSimulatorArm64(),
     ).forEach {
         it.binaries.framework {
             export(project(":core"))
@@ -40,16 +40,6 @@ kotlin {
     }
 }
 
-skie {
-    features {
-        group {
-            // We turn this off as the suspend interop feature results in
-            // threading issues when implementing SDK in Swift
-            SuspendInterop.Enabled(false)
-        }
-    }
-}
-
 kmmbridge {
     artifactManager.set(SonatypePortalPublishArtifactManager(project, repositoryName = null))
     artifactManager.finalizeValue()
@@ -70,19 +60,22 @@ class SonatypePortalPublishArtifactManager(
     val project: Project,
     private val publicationName: String = "KMMBridgeFramework",
     artifactSuffix: String = "kmmbridge",
-    private val repositoryName: String?,
+    private val repositoryName: String?
 ) : ArtifactManager {
     private val group: String = project.group.toString().replace(".", "/")
     private val kmmbridgeArtifactId =
-        "${project.name}-${artifactSuffix}"
+        "${project.name}-$artifactSuffix"
     private val LIBRARY_VERSION: String by project
+
     // This is the URL that will be added to Package.swift in Github package so that
     // KMMBridge is downloaded when a user includes the package in XCode
     private val MAVEN_CENTRAL_PACKAGE_ZIP_URL = "https://repo1.maven.org/maven2/com/powersync/${kmmbridgeArtifactId.lowercase()}/${LIBRARY_VERSION}/${kmmbridgeArtifactId.lowercase()}-${LIBRARY_VERSION}.zip"
 
-    override fun deployArtifact(project: Project, zipFilePath: File, version: String): String {
-        return MAVEN_CENTRAL_PACKAGE_ZIP_URL
-    }
+    override fun deployArtifact(
+        project: Project,
+        zipFilePath: File,
+        version: String
+    ): String = MAVEN_CENTRAL_PACKAGE_ZIP_URL
 
     override fun configure(
         project: Project,
@@ -91,12 +84,14 @@ class SonatypePortalPublishArtifactManager(
         kmmPublishTask: TaskProvider<Task>
     ) {
         project.extensions.getByType<PublishingExtension>().publications.create(
-            publicationName, MavenPublication::class.java
+            publicationName,
+            MavenPublication::class.java,
         ) {
             this.version = version
-            val archiveProvider = project.tasks.named("zipXCFramework", Zip::class.java).flatMap {
-                it.archiveFile
-            }
+            val archiveProvider =
+                project.tasks.named("zipXCFramework", Zip::class.java).flatMap {
+                    it.archiveFile
+                }
             artifact(archiveProvider) {
                 extension = "zip"
             }
@@ -136,11 +131,14 @@ class SonatypePortalPublishArtifactManager(
 
         // Either the user has supplied a correct name, or we use the default. If neither is found, fail.
         val publicationNameCap =
-            publishingExtension.publications.getByName(
-                publicationName
-            ).name.capitalized()
-
-        return publishingExtension.repositories.filterIsInstance<MavenArtifactRepository>()
+            publishingExtension.publications
+                .getByName(
+                    publicationName,
+                ).name
+                .capitalized()
+
+        return publishingExtension.repositories
+            .filterIsInstance<MavenArtifactRepository>()
             .map { repo ->
                 val repositoryName = repo.name.capitalized()
                 val publishTaskName =
@@ -175,26 +173,27 @@ abstract class UpdatePackageSwiftChecksumTask : DefaultTask() {
         }
 
         // Compute the checksum
-        val checksum = zipFile.inputStream().use { input ->
-            val digest = MessageDigest.getInstance("SHA-256")
-            val buffer = ByteArray(8192)
-            var bytes = input.read(buffer)
-            while (bytes >= 0) {
-                digest.update(buffer, 0, bytes)
-                bytes = input.read(buffer)
+        val checksum =
+            zipFile.inputStream().use { input ->
+                val digest = MessageDigest.getInstance("SHA-256")
+                val buffer = ByteArray(8192)
+                var bytes = input.read(buffer)
+                while (bytes >= 0) {
+                    digest.update(buffer, 0, bytes)
+                    bytes = input.read(buffer)
+                }
+                digest.digest().joinToString("") { "%02x".format(it) }
             }
-            digest.digest().joinToString("") { "%02x".format(it) }
-        }
 
         // Update Package.swift
         val packageSwiftFile = project.rootProject.file("Package.swift")
-        val updatedContent = packageSwiftFile.readText().replace(
-            Regex("let remoteKotlinChecksum = \"[a-f0-9]+\""),
-            "let remoteKotlinChecksum = \"$checksum\""
-        )
+        val updatedContent =
+            packageSwiftFile.readText().replace(
+                Regex("let remoteKotlinChecksum = \"[a-f0-9]+\""),
+                "let remoteKotlinChecksum = \"$checksum\"",
+            )
         packageSwiftFile.writeText(updatedContent)
 
         println("Updated Package.swift with new checksum: $checksum")
     }
 }
-

PowerSync/src/iosMain/kotlin/com/powersync/SDK.kt

@@ -1,2 +1,5 @@
+@file:Suppress("ktlint:standard:no-empty-file")
+
 // This is required to build the iOS framework
-package com.powersync
+
+package com.powersync

build.gradle.kts

@@ -12,6 +12,7 @@ plugins {
     alias(libs.plugins.grammarKitComposer) apply false
     alias(libs.plugins.mavenPublishPlugin) apply false
     alias(libs.plugins.downloadPlugin) apply false
+    alias(libs.plugins.kotlinter) apply false
 }
 
 // Having different versions of this lead to the issue mentioned here
@@ -38,7 +39,6 @@ allprojects {
         }
     }
 
-
     configurations.configureEach {
         exclude(group = "com.jetbrains.rd")
         exclude(group = "com.github.jetbrains", module = "jetCheck")

compose/build.gradle.kts

@@ -5,6 +5,7 @@ plugins {
     alias(libs.plugins.androidLibrary)
     alias(libs.plugins.jetbrainsCompose)
     alias(libs.plugins.compose.compiler)
+    alias(libs.plugins.kotlinter)
     id("com.powersync.plugins.sonatype")
 }
 
@@ -33,13 +34,19 @@ kotlin {
 
 android {
     namespace = "com.powersync.compose"
-    compileSdk = libs.versions.android.compileSdk.get().toInt()
+    compileSdk =
+        libs.versions.android.compileSdk
+            .get()
+            .toInt()
     defaultConfig {
-        minSdk = libs.versions.android.minSdk.get().toInt()
+        minSdk =
+            libs.versions.android.minSdk
+                .get()
+                .toInt()
     }
     kotlin {
         jvmToolchain(17)
     }
 }
 
-setupGithubRepository()
+setupGithubRepository()

compose/src/androidMain/kotlin/com/powersync/compose/DatabaseDriverFactory.compose.android.kt

@@ -5,12 +5,10 @@ import androidx.compose.runtime.remember
 import androidx.compose.ui.platform.LocalContext
 import com.powersync.DatabaseDriverFactory
 
-
 @Composable
 public actual fun rememberDatabaseDriverFactory(): DatabaseDriverFactory {
     val context = LocalContext.current
     return remember {
         DatabaseDriverFactory(context)
     }
-
 }

compose/src/iosMain/kotlin/com/powersync/compose/DatabaseDriverFactory.compose.ios.kt

@@ -4,10 +4,8 @@ import androidx.compose.runtime.Composable
 import androidx.compose.runtime.remember
 import com.powersync.DatabaseDriverFactory
 
-
 @Composable
-public actual fun rememberDatabaseDriverFactory(): DatabaseDriverFactory {
-    return remember {
+public actual fun rememberDatabaseDriverFactory(): DatabaseDriverFactory =
+    remember {
         DatabaseDriverFactory()
     }
-}

connectors/supabase/build.gradle.kts

@@ -5,6 +5,7 @@ plugins {
     alias(libs.plugins.kotlinMultiplatform)
     alias(libs.plugins.kotlinSerialization)
     alias(libs.plugins.androidLibrary)
+    alias(libs.plugins.kotlinter)
     id("com.powersync.plugins.sonatype")
 }
 
@@ -37,13 +38,19 @@ kotlin {
 
 android {
     namespace = "com.powersync.connector.supabase"
-    compileSdk = libs.versions.android.compileSdk.get().toInt()
+    compileSdk =
+        libs.versions.android.compileSdk
+            .get()
+            .toInt()
     defaultConfig {
-        minSdk = libs.versions.android.minSdk.get().toInt()
+        minSdk =
+            libs.versions.android.minSdk
+                .get()
+                .toInt()
     }
     kotlin {
         jvmToolchain(17)
     }
 }
 
-setupGithubRepository()
+setupGithubRepository()

connectors/supabase/src/commonMain/kotlin/com/powersync/connector/supabase/SupabaseConnector.kt

@@ -21,34 +21,42 @@ import kotlinx.coroutines.flow.StateFlow
  */
 public class SupabaseConnector(
     public val supabaseClient: SupabaseClient,
-    public val powerSyncEndpoint: String
+    public val powerSyncEndpoint: String,
 ) : PowerSyncBackendConnector() {
-
     public constructor(
         supabaseUrl: String,
         supabaseKey: String,
-        powerSyncEndpoint: String
+        powerSyncEndpoint: String,
     ) : this(
-        supabaseClient = createSupabaseClient(supabaseUrl, supabaseKey) {
-            install(Auth)
-            install(Postgrest)
-        },
-        powerSyncEndpoint = powerSyncEndpoint
+        supabaseClient =
+            createSupabaseClient(supabaseUrl, supabaseKey) {
+                install(Auth)
+                install(Postgrest)
+            },
+        powerSyncEndpoint = powerSyncEndpoint,
     )
 
     init {
         require(supabaseClient.pluginManager.getPluginOrNull(Auth) != null) { "The Auth plugin must be installed on the Supabase client" }
-        require(supabaseClient.pluginManager.getPluginOrNull(Postgrest) != null) { "The Postgrest plugin must be installed on the Supabase client" }
+        require(
+            supabaseClient.pluginManager.getPluginOrNull(Postgrest) != null,
+        ) { "The Postgrest plugin must be installed on the Supabase client" }
     }
 
-    public suspend fun login(email: String, password: String) {
+    public suspend fun login(
+        email: String,
+        password: String,
+    ) {
         supabaseClient.auth.signInWith(Email) {
             this.email = email
             this.password = password
         }
     }
 
-    public suspend fun signUp(email: String, password: String) {
+    public suspend fun signUp(
+        email: String,
+        password: String,
+    ) {
         supabaseClient.auth.signUpWith(Email) {
             this.email = email
             this.password = password
@@ -59,9 +67,7 @@ public class SupabaseConnector(
         supabaseClient.auth.signOut()
     }
 
-    public fun session(): UserSession? {
-        return supabaseClient.auth.currentSessionOrNull()
-    }
+    public fun session(): UserSession? = supabaseClient.auth.currentSessionOrNull()
 
     public val sessionStatus: StateFlow<SessionStatus> = supabaseClient.auth.sessionStatus
 
@@ -84,7 +90,7 @@ public class SupabaseConnector(
         return PowerSyncCredentials(
             endpoint = powerSyncEndpoint,
             token = session.accessToken, // Use the access token to authenticate against PowerSync
-            userId = session.user!!.id
+            userId = session.user!!.id,
         )
     }
 
@@ -95,12 +101,10 @@ public class SupabaseConnector(
      * If this call throws an error, it is retried periodically.
      */
     override suspend fun uploadData(database: PowerSyncDatabase) {
-
         val transaction = database.getNextCrudTransaction() ?: return
 
         var lastEntry: CrudEntry? = null
         try {
-
             for (entry in transaction.crud) {
                 lastEntry = entry
 
@@ -131,7 +135,6 @@ public class SupabaseConnector(
             }
 
             transaction.complete(null)
-
         } catch (e: Exception) {
             println("Data upload error - retrying last entry: ${lastEntry!!}, $e")
             throw e