sync

Author: penberg

examples/sync/package.json

@@ -11,7 +11,7 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "libsql": "^0.1.0",
+    "libsql": "../..",
     "readline-sync": "^1.4.10"
   }
 }

index.d.ts

@@ -17,6 +17,10 @@ export interface RunResult {
 }
 /** Retrieve next row from an iterator synchronously. Needed for better-sqlite3 API compatibility. */
 export declare function iteratorNextSync(iter: RowsIterator): Record
+export interface SyncResult {
+  framesSynced: number
+  replicationIndex: number
+}
 export declare class SqliteError {
   message: string
   code: string
@@ -40,6 +44,8 @@ export declare class Database {
   close(): void
   defaultSafeIntegers(toggle?: boolean | undefined | null): void
   unsafeMode(): void
+  sync(): SyncResult
+  syncUntil(replicationIndex: number): SyncResult
 }
 export declare class Statement {
   columns(): unknown[]

src/lib.rs

@@ -430,6 +430,30 @@ impl Database {
     pub fn unsafeMode(&self) -> Result<()> {
         todo!();
     }
+
+    #[napi]
+    pub fn sync(&self) -> Result<SyncResult> {
+        let rt = runtime()?;
+        let result = rt.block_on(async move {
+            self.db.sync().await.map_err(Error::from)
+        })?;
+        Ok(SyncResult {
+            frames_synced: result.frames_synced() as f64,
+            replication_index: result.frame_no().unwrap_or(0) as f64,
+        })
+    }
+
+    #[napi]
+    pub fn syncUntil(&self, replication_index: f64) -> Result<SyncResult> {
+        let rt = runtime()?;
+        let result = rt.block_on(async move {
+            self.db.sync_until(replication_index as u64).await.map_err(Error::from)
+        })?;
+        Ok(SyncResult {
+            frames_synced: result.frames_synced() as f64,
+            replication_index: result.frame_no().unwrap_or(0) as f64,
+        })
+    }
 }
 
 fn is_remote_path(path: &str) -> bool {
@@ -1093,3 +1117,9 @@ fn ensure_logger() {
             .try_init();
     });
 }
+
+#[napi(object)]
+pub struct SyncResult {
+    pub frames_synced: f64,
+    pub replication_index: f64,
+}

wrapper.js

@@ -52,11 +52,27 @@ class Database {
   }
 
   sync() {
-    throw new Error("not implemented");
+    try {
+      const result = this.db.sync();
+      return {
+        frames_synced: result.frames_synced,
+        replication_index: result.replication_index
+      };
+    } catch (err) {
+      throw convertError(err);
+    }
   }
 
   syncUntil(replicationIndex) {
-    throw new Error("not implemented");
+    try {
+      const result = this.db.syncUntil(replicationIndex);
+      return {
+        frames_synced: result.frames_synced,
+        replication_index: result.replication_index
+      };
+    } catch (err) {
+      throw convertError(err);
+    }
   }
 
   /**