Allow read your writes configuration

Fixes #110

Signed-off-by: Piotr Jastrzebski <[email protected]>

Cargo.toml

@@ -12,7 +12,7 @@ crate-type = ["cdylib"]
 
 [dependencies]
 tracing-subscriber = { version = "0.3", features = ["env-filter"] }
-libsql = { git = "https://github.com/tursodatabase/libsql/", rev = "8a8a897833ec98a6201d22d5c5cf803cd57f98c6", features = ["encryption"] }
+libsql = { git = "https://github.com/tursodatabase/libsql", branch = "libsql_js", features = ["encryption"] }
 tracing = "0.1"
 once_cell = "1.18.0"
 tokio = { version = "1.29.1", features = [ "rt-multi-thread" ] }

index.js

@@ -73,7 +73,8 @@ class Database {
       }
       const encryptionKey = opts?.encryptionKey ?? "";
       const syncPeriod = opts?.syncPeriod ?? 0.0;
-      this.db = databaseOpenWithRpcSync(path, opts.syncUrl, authToken, encryptionCipher, encryptionKey, syncPeriod);
+      const readYourWrites = opts?.readYourWrites ?? true;
+      this.db = databaseOpenWithRpcSync(path, opts.syncUrl, authToken, encryptionCipher, encryptionKey, syncPeriod, readYourWrites);
     } else {
       const authToken = opts?.authToken ?? "";
       const encryptionKey = opts?.encryptionKey ?? "";

package.json

@@ -68,6 +68,6 @@
   "dependencies": {
     "@neon-rs/load": "^0.0.4",
     "detect-libc": "2.0.2",
-    "libsql": "^0.3.15"
+    "libsql": "^0.3.19"
   }
 }

src/database.rs

@@ -67,6 +67,7 @@ impl Database {
         let encryption_cipher = cx.argument::<JsString>(3)?.value(&mut cx);
         let encryption_key = cx.argument::<JsString>(4)?.value(&mut cx);
         let sync_period = cx.argument::<JsNumber>(5)?.value(&mut cx);
+        let read_your_writes = cx.argument::<JsBoolean>(6)?.value(&mut cx);
 
         let cipher = libsql::Cipher::from_str(&encryption_cipher).or_else(|err| {
             throw_libsql_error(
@@ -98,7 +99,7 @@ impl Database {
             sync_url,
             sync_auth,
             Some(version),
-            true,
+            read_your_writes,
             encryption_config,
             sync_period,
         );