fix: sync instead of pull when not remote_writes

Author: levydsa

libsql/src/database.rs

@@ -679,10 +679,8 @@ impl Database {
                 ..
             } => {
                 use crate::{
-                    hrana::connection::HttpConnection,
-                    local::impls::LibsqlConnection,
-                    replication::connection::State,
-                    sync::connection::SyncedConnection,
+                    hrana::connection::HttpConnection, local::impls::LibsqlConnection,
+                    replication::connection::State, sync::connection::SyncedConnection,
                 };
                 use tokio::sync::Mutex;
 

libsql/src/database/builder.rs

@@ -6,7 +6,7 @@ use std::sync::Arc;
 
 use tracing::Instrument as _;
 
-use crate::{sync::DropAbort, Database, Result};
+use crate::{Database, Result};
 
 use super::DbType;
 
@@ -645,7 +645,7 @@ cfg_sync! {
                 db.sync_ctx.as_ref().unwrap().lock().await.set_push_batch_size(push_batch_size);
             }
 
-            let mut bg_abort: Option<Arc<DropAbort>> = None;
+            let mut bg_abort: Option<Arc<crate::sync::DropAbort>> = None;
             let conn = db.connect()?;
 
             let sync_ctx = db.sync_ctx.as_ref().unwrap().clone();
@@ -656,17 +656,22 @@ cfg_sync! {
                         loop {
                             tracing::trace!("trying to sync");
                             let mut ctx = sync_ctx.lock().await;
-                            if let Err(e) = crate::sync::try_pull(&mut ctx, &conn).await {
-                                tracing::error!("sync error: {}", e);
+                            if remote_writes {
+                                if let Err(e) = crate::sync::try_pull(&mut ctx, &conn).await {
+                                    tracing::error!("sync error: {}", e);
+                                }
+                            } else {
+                                if let Err(e) = crate::sync::sync_offline(&mut ctx, &conn).await {
+                                    tracing::error!("sync error: {}", e);
+                                }
                             }
-
                             tokio::time::sleep(sync_interval).await;
                         }
                     }
                     .instrument(tracing::info_span!("sync_interval")),
                 );
 
-                bg_abort.replace(Arc::new(DropAbort(jh.abort_handle())));
+                bg_abort.replace(Arc::new(crate::sync::DropAbort(jh.abort_handle())));
             }
 
             Ok(Database {