Option to clear has_synced

Author: simolus3

crates/core/src/view_admin.rs

@@ -86,10 +86,10 @@ DELETE FROM ps_crud;
 DELETE FROM ps_untyped;
 DELETE FROM ps_updated_rows;
 DELETE FROM ps_kv WHERE key != 'client_id';
-DELETE FROM ps_sync_state;
 DELETE FROM ps_stream_subscriptions;
 ",
     )?;
+    clear_has_synced(local_db)?;
 
     let table_glob = if flags.clear_local() {
         "ps_data_*"
@@ -155,14 +155,25 @@ fn trigger_resync(db: *mut sqlite::sqlite3, state: &DatabaseState) -> Result<(),
     Ok(Default::default())
 }
 
+fn clear_has_synced(db: *mut sqlite::sqlite3) -> Result<(), PowerSyncError> {
+    db.exec_safe("DELETE FROM ps_sync_state;")?;
+    db.exec_safe("UPDATE ps_stream_subscriptions SET last_synced_at = NULL")?;
+    Ok(())
+}
+
 fn powersync_trigger_resync_impl(
     ctx: *mut sqlite::context,
-    _args: &[*mut sqlite::value],
+    args: &[*mut sqlite::value],
 ) -> Result<String, PowerSyncError> {
     let local_db = ctx.db_handle();
     let state = unsafe { DatabaseState::from_context(&ctx) };
     trigger_resync(local_db, state)?;
 
+    let clear_progress = args[0].int() != 0;
+    if clear_progress {
+        clear_has_synced(local_db)?;
+    }
+
     Ok(Default::default())
 }
 
@@ -243,7 +254,7 @@ pub fn register(db: *mut sqlite::sqlite3, state: Rc<DatabaseState>) -> Result<()
 
     db.create_function_v2(
         "powersync_trigger_resync",
-        0,
+        1,
         sqlite::UTF8,
         Some(Rc::into_raw(state) as *mut c_void),
         Some(powersync_trigger_resync),

dart/test/sync_test.dart

@@ -433,7 +433,7 @@ void _syncTests<T>({
       invokeControl('start', null);
 
       expect(
-        () => db.select('SELECT powersync_trigger_resync()'),
+        () => db.select('SELECT powersync_trigger_resync(1)'),
         throwsA(
           isSqliteException(
             3091,
@@ -452,7 +452,7 @@ void _syncTests<T>({
       invokeControl('stop', null);
 
       db.execute('delete from ps_data__items');
-      db.execute('select powersync_trigger_resync()');
+      db.execute('select powersync_trigger_resync(0)');
 
       final instructions = invokeControl('start', null);
       expect(
@@ -477,6 +477,19 @@ void _syncTests<T>({
         {'id': 'row-0', 'col': 'hi'}
       ]);
     });
+
+    test('can clear has synced', () {
+      invokeControl('start', null);
+      pushCheckpoint(buckets: [bucketDescription('a', count: 1)]);
+      pushSyncData('a', '1', 'row-0', 'PUT', {'col': 'hi'});
+      pushCheckpointComplete();
+      invokeControl('stop', null);
+
+      db.execute('select powersync_trigger_resync(1)');
+      final [row] = db.select('select powersync_offline_sync_status()');
+      expect(json.decode(row.columnAt(0)),
+          containsPair('priority_status', isEmpty));
+    });
   });
 
   test('persists download progress', () {