jerry/buzz
1
0
Fork 0
mirror of https://github.com/block/buzz.git synced 2026-11-02 07:22:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(buzz-db): catalog workflow webhook authority

Browse Source 
Co-authored-by: Larry <8cf5a83f590ec0955b11647d1c88f796a98e088c30a492c58e0e46c3026ae7a4@buzz.block.builderlab.xyz>
Signed-off-by: Logan Johnson <loganj@squareup.com>
Signed-off-by: Larry <8cf5a83f590ec0955b11647d1c88f796a98e088c30a492c58e0e46c3026ae7a4@buzz.block.builderlab.xyz>
This commit is contained in:
Logan Johnson
2026-08-26 16:30:15 -04:00
committed by Larry
parent 0c7d354ffb
commit 55321b5800
2 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
crates/buzz-db/src/deletion.rs
View File

@@ -82,12 +82,14 @@ pub const EXPECTED_SCOPED_TABLES: &[&str] = &[
"workflow_agent_deliveries",
"workflow_approvals",
"workflow_runs",
"workflow_webhook_invocations",
"workflows",
];
/// Foreign-key-safe child-before-parent order for the PostgreSQL purge.
pub const PURGE_SCOPED_TABLES: &[&str] = &[
"workflow_agent_deliveries",
"workflow_webhook_invocations",
"workflow_approvals",
"scheduled_workflow_fires",
"workflow_runs",

8
crates/buzz-db/src/migration.rs
View File

@@ -649,7 +649,7 @@ mod tests {
let mut migrations: Vec<_> = MIGRATOR.iter().collect();
migrations.sort_by_key(|migration| migration.version);
assert_eq!(migrations.len(), 37);
assert_eq!(migrations.len(), 38);
assert_eq!(migrations[0].version, 1);
assert_eq!(&*migrations[0].description, "initial schema");
assert!(migrations[0]
@@ -1676,9 +1676,11 @@ mod tests {
let mut expected_fences = migration.fence_attachments.clone();
expected_fences.remove("product_feedback");
expected_fences.remove("rate_limit_violations");
// Migration 0035 attaches the fence to the durable managed-agent
// delivery inbox after 0029; the desired-state schema carries it inline.
// Migrations 0037 and 0038 attach fences to the durable managed-agent
// delivery inbox and webhook invocation authority after 0029; the
// desired-state schema carries both inline.
expected_fences.insert("workflow_agent_deliveries".to_owned());
expected_fences.insert("workflow_webhook_invocations".to_owned());
assert_eq!(
expected_fences, schema.fence_attachments,
"write-fence attachment targets differ after recovery policy"