External/buzz
1
0
Fork 0
mirror of https://github.com/block/buzz.git synced 2026-08-18 06:50:31 +02:00
Code Issues Packages Projects Releases Wiki Activity

test: cover deletion lifecycle safety boundaries

Browse Source 
Co-authored-by: npub1dccv64krpcpse5cmkzfeh998cftungyatw3djt8jwdw6g43f7fyqzzmrf7 <6e30cd56c30e030cd31bb0939b94a7c257c9a09d5ba2d92cf2735da45629f248@buzz.block.builderlab.xyz>
Signed-off-by: npub1dccv64krpcpse5cmkzfeh998cftungyatw3djt8jwdw6g43f7fyqzzmrf7 <6e30cd56c30e030cd31bb0939b94a7c257c9a09d5ba2d92cf2735da45629f248@buzz.block.builderlab.xyz>
This commit is contained in:
npub1dccv64krpcpse5cmkzfeh998cftungyatw3djt8jwdw6g43f7fyqzzmrf7
2026-08-02 13:55:25 -07:00
parent 4db5395dbe
commit b7faba840f
1 changed files with 34 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/buzz-db/src/deletion.rs
+34
View File
@@ -1920,6 +1920,18 @@ mod postgres_tests {
.expect("claim before approval")
.is_none());
// Approval binds structural/storage taxonomy, not live row counts. A
// serving write between inventory and approval must not make an active
// community undeletable.
db.add_to_allowlist(request.community_id, &[7_u8; 32], &[8_u8; 32], None)
.await
.expect("post-inventory serving write");
let current_schema = store
.inventory_schema(request.community_id)
.await
.expect("live schema after row churn");
assert_eq!(current_schema, inventory.schema);
let approved = store
.approve(request.id, "approver-a", Some("reviewed"))
.await
@@ -2088,6 +2100,20 @@ mod postgres_tests {
.freeze_destructive_storage_manifest(&token, &inventory.storage)
.await
.expect("freeze destructive storage");
store
.freeze_destructive_storage_manifest(&token, &inventory.storage)
.await
.expect("identical destructive manifest retry");
let mut drifted_storage = inventory.storage.clone();
drifted_storage
.media_upload_keys
.push("media/drifted-after-fence".to_string());
assert!(matches!(
store
.freeze_destructive_storage_manifest(&token, &drifted_storage)
.await,
Err(DbError::DeletionSafety(_))
));
store.mark_drained(&token).await.expect("drain");
store
.mark_bindings_removed(&token, serde_json::json!({"keys": 0}))
@@ -2136,5 +2162,13 @@ mod postgres_tests {
.await
.expect("serving lookup")
.is_none());
let direct_delete = sqlx::query("DELETE FROM communities WHERE id = $1")
.bind(request.community_id.as_uuid())
.execute(&db.pool)
.await
.expect_err("tombstone row must be permanent");
assert!(direct_delete
.to_string()
.contains("tombstones are permanent"));
}
}