chore: Update opsqlite 11.2.13

.changeset/hip-pianos-relax.md

@@ -0,0 +1,5 @@
+---
+'@powersync/op-sqlite': patch
+---
+
+Update op-sqlite to v11.2.13.

.changeset/rotten-rats-raise.md

@@ -0,0 +1,5 @@
+---
+'@powersync/react-native': patch
+---
+
+Fixed an issue where the read and write locks were executing mutually exclusively. A read conccurent with a write or another read should correctly proceed instead of being blocked until the other lock has released.

packages/powersync-op-sqlite/package.json

@@ -65,7 +65,7 @@
     "access": "public"
   },
   "peerDependencies": {
-    "@op-engineering/op-sqlite": "^10.1.0",
+    "@op-engineering/op-sqlite": "^11.2.13",
     "@powersync/common": "workspace:^1.22.1",
     "react": "*",
     "react-native": "*"
@@ -75,7 +75,7 @@
     "async-lock": "^1.4.0"
   },
   "devDependencies": {
-    "@op-engineering/op-sqlite": "^10.1.0",
+    "@op-engineering/op-sqlite": "^11.2.13",
     "@react-native/eslint-config": "^0.73.1",
     "@types/async-lock": "^1.4.0",
     "@types/react": "^18.2.44",

packages/powersync-op-sqlite/src/db/OPSqliteAdapter.ts

@@ -78,9 +78,7 @@ export class OPSQLiteDBAdapter extends BaseObserver<DBAdapterListener> implement
 
     this.readConnections = [];
     for (let i = 0; i < READ_CONNECTIONS; i++) {
-      // Workaround to create read-only connections
-      let dbName = './'.repeat(i + 1) + dbFilename;
-      const conn = await this.openConnection(dbName);
+      const conn = await this.openConnection(dbFilename);
       await conn.execute('PRAGMA query_only = true');
       this.readConnections.push({ busy: false, connection: conn });
     }

packages/react-native/src/db/PowerSyncDatabase.ts

@@ -58,4 +58,14 @@ export class PowerSyncDatabase extends AbstractPowerSyncDatabase {
       identifier: this.database.name
     });
   }
+
+  async readLock<T>(callback: (db: DBAdapter) => Promise<T>): Promise<T> {
+    await this.waitForReady();
+    return this.database.readLock(callback);
+  }
+
+  async writeLock<T>(callback: (db: DBAdapter) => Promise<T>): Promise<T> {
+    await this.waitForReady();
+    return this.database.writeLock(callback);
+  }
 }