Test encryption

Author: simolus3

Package.resolved

@@ -7,12 +7,14 @@ let packageName = "PowerSync"
 
 // Set this to the absolute path of your Kotlin SDK checkout if you want to use a local Kotlin
 // build. Also see docs/LocalBuild.md for details
-let localKotlinSdkOverride: String? = nil
+let localKotlinSdkOverride: String? = "/Users/simon/src/powersync-kotlin"
 
 // Set this to the absolute path of your powersync-sqlite-core checkout if you want to use a
 // local build of the core extension.
 let localCoreExtension: String? = nil
 
+let encryption = true
+
 // Our target and dependency setup is different when a local Kotlin SDK is used. Without the local
 // SDK, we have no package dependency on Kotlin and download the XCFramework from Kotlin releases as
 // a binary target.
@@ -22,10 +24,16 @@ var conditionalDependencies: [Package.Dependency] = []
 var conditionalTargets: [Target] = []
 var kotlinTargetDependency = Target.Dependency.target(name: "PowerSyncKotlin")
 
+if encryption {
+    conditionalDependencies.append(.package(url: "https://github.com/sqlcipher/SQLCipher.swift.git", from: "4.10.0"))
+} else {
+    conditionalDependencies.append(.package(url: "https://github.com/sbooth/CSQLite.git", from: "3.50.4"))
+}
+
 if let kotlinSdkPath = localKotlinSdkOverride {
     // We can't depend on local XCFrameworks outside of this project's root, so there's a Package.swift
     // in the PowerSyncKotlin project pointing towards a local build.
-    conditionalDependencies.append(.package(path: "\(kotlinSdkPath)/PowerSyncKotlin"))
+    conditionalDependencies.append(.package(path: "\(kotlinSdkPath)/internal/PowerSyncKotlin"))
 
     kotlinTargetDependency = .product(name: "PowerSyncKotlin", package: "PowerSyncKotlin")
 } else {
@@ -81,7 +89,10 @@ let package = Package(
             name: packageName,
             dependencies: [
                 kotlinTargetDependency,
-                .product(name: "PowerSyncSQLiteCore", package: corePackageName)
+                .product(name: "PowerSyncSQLiteCore", package: corePackageName),
+                encryption ?
+                    .product(name: "SQLCipher", package: "SQLCipher.swift") :
+                    .product(name: "CSQLite", package: "CSQLite"),
             ]
         ),
         .testTarget(

Package.swift

@@ -13,9 +13,10 @@ final class KotlinPowerSyncDatabaseImpl: PowerSyncDatabaseProtocol,
     init(
         schema: Schema,
         dbFilename: String,
-        logger: DatabaseLogger
+        logger: DatabaseLogger,
+        initialStatements: [String] = [],
     ) {
-        let factory = PowerSyncKotlin.DatabaseDriverFactory()
+        let factory = sqlite3DatabaseFactory(initialStatements: initialStatements)
         kotlinDatabase = PowerSyncDatabase(
             factory: factory,
             schema: KotlinAdapter.Schema.toKotlin(schema),

Sources/PowerSync/Kotlin/KotlinPowerSyncDatabaseImpl.swift

@@ -0,0 +1,67 @@
+@testable import PowerSync
+import XCTest
+
+
+final class EncryptionTests: XCTestCase {
+
+    func testLinksSqlcipher() async throws {
+        let database = KotlinPowerSyncDatabaseImpl(
+            schema: Schema(),
+            dbFilename: ":memory:",
+            logger: DatabaseLogger(DefaultLogger())
+        )
+        
+        let version = try await database.get("pragma cipher_version", mapper:  {cursor in
+            try cursor.getString(index: 0)
+        });
+        
+        XCTAssertEqual(version, "4.11.0 community")
+        try await database.close()
+    }
+
+    func testEncryption() async throws {
+        let database = KotlinPowerSyncDatabaseImpl(
+            schema: Schema(tables: [
+                Table(
+                    name: "users",
+                    columns: [
+                        .text("name")
+                    ]
+                ),
+            ]),
+            dbFilename: "encrypted.db",
+            logger: DatabaseLogger(DefaultLogger()),
+            initialStatements: [
+                "pragma key = 'foobar'"
+            ],
+        )
+
+        try await database.execute("INSERT INTO users (id, name) VALUES (uuid(), 'test')")
+        try await database.close()
+
+        let another = KotlinPowerSyncDatabaseImpl(
+            schema: Schema(tables: [
+                Table(
+                    name: "users",
+                    columns: [
+                        .text("name")
+                    ]
+                ),
+            ]),
+            dbFilename: "encrypted.db",
+            logger: DatabaseLogger(DefaultLogger()),
+            initialStatements: [
+                "pragma key = 'wrong password'"
+            ],
+        )
+        
+        var hadError = false
+        do {
+            try await database.execute("DELETE FROM users")
+        } catch let error {
+            hadError = true
+        }
+        
+        XCTAssertTrue(hadError)
+    }
+}