c: add replicated data for sync

This adds a new replicated struct that is output during sync for the C
bindings.

Author: LucioFranco

bindings/c/include/libsql.h

@@ -27,6 +27,11 @@ typedef struct libsql_stmt libsql_stmt;
 
 typedef const libsql_database *libsql_database_t;
 
+typedef struct {
+  uintptr_t frame_no;
+  uintptr_t frames_synced;
+} replicated;
+
 typedef struct {
   const char *db_path;
   const char *primary_url;
@@ -56,7 +61,7 @@ typedef struct {
 extern "C" {
 #endif // __cplusplus
 
-int libsql_sync(libsql_database_t db, const char **out_err_msg);
+int libsql_sync(libsql_database_t db, replicated *out_replicated, const char **out_err_msg);
 
 int libsql_open_sync(const char *db_path,
                      const char *primary_url,

bindings/c/src/lib.rs

@@ -11,7 +11,7 @@ use tokio::runtime::Runtime;
 use types::{
     blob, libsql_connection, libsql_connection_t, libsql_database, libsql_database_t, libsql_row,
     libsql_row_t, libsql_rows, libsql_rows_future_t, libsql_rows_t, libsql_stmt, libsql_stmt_t,
-    stmt,
+    replicated, stmt,
 };
 
 lazy_static! {
@@ -34,11 +34,16 @@ unsafe fn set_err_msg(msg: String, output: *mut *const std::ffi::c_char) {
 #[no_mangle]
 pub unsafe extern "C" fn libsql_sync(
     db: libsql_database_t,
+    out_replicated: *mut replicated,
     out_err_msg: *mut *const std::ffi::c_char,
 ) -> std::ffi::c_int {
     let db = db.get_ref();
     match RT.block_on(db.sync()) {
-        Ok(_) => 0,
+        Ok(replicated) => {
+            (*out_replicated).frame_no = replicated.frame_no().unwrap_or(0) as usize;
+            (*out_replicated).frames_synced = replicated.frames_synced() as usize;
+            0
+        }
         Err(e) => {
             set_err_msg(format!("Error syncing database: {e}"), out_err_msg);
             1

bindings/c/src/types.rs

@@ -115,6 +115,12 @@ impl From<&mut libsql_connection> for libsql_connection_t {
     }
 }
 
+#[repr(C)]
+pub struct replicated {
+    pub frame_no: usize,
+    pub frames_synced: usize,
+}
+
 pub struct stmt {
     pub stmt: libsql::Statement,
     pub params: Vec<libsql::Value>,