Skip to content

Commit 07ed484

Browse files
committed
Soft clear: Delete $local bucket
1 parent 04bee21 commit 07ed484

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

crates/core/src/view_admin.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -159,6 +159,7 @@ fn powersync_clear_impl(
159159
local_db.exec_safe("DELETE FROM ps_oplog; DELETE FROM ps_buckets")?;
160160
} else {
161161
local_db.exec_safe("UPDATE ps_buckets SET last_applied_op = 0")?;
162+
local_db.exec_safe("DELETE FROM ps_buckets WHERE name = '$local'")?;
162163
}
163164

164165
// language=SQLite

dart/test/sync_test.dart

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -376,12 +376,16 @@ void _syncTests<T>({
376376
pushSyncData('a', '1', 'row-0', 'PUT', {'col': 'hi'});
377377
pushCheckpointComplete();
378378

379-
expect(db.select('SELECT * FROM items'), hasLength(1));
379+
db.execute(
380+
'insert into items (id, col) values (uuid(), ?)', ['local item']);
381+
expect(db.select('SELECT * FROM items'), hasLength(2));
380382

381383
// Soft clear
382384
db.execute('SELECT powersync_clear(2)');
383385
db.select('select powersync_replace_schema(?)', [json.encode(testSchema)]);
384386
expect(db.select('SELECT * FROM items'), hasLength(0));
387+
expect(
388+
db.select(r"SELECT * FROM ps_buckets WHERE name = '$local'"), isEmpty);
385389

386390
final request = invokeControl('start', null);
387391
expect(

0 commit comments

Comments
 (0)