From 7286b494574e2414d42da3840eb5c752717db3f9 Mon Sep 17 00:00:00 2001 From: Breadway Date: Mon, 31 Aug 2026 19:55:31 +0800 Subject: [PATCH] test: stop emitting reserved bread.reload.* from the reload-storm test MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit `daemon_survives_repeated_reloads_and_pipeline_resumes` manually emitted `bread.reload.before` / `.after`. Since "Allow well-formed bread.command events on the emit bus" tightened the normalizer, a manual emit of an adapter-owned domain (`reload`) is rejected, so this test — and every push to main since — failed at the test step, blocking the dev-track publish. The event names are incidental here; the test only checks that events flow through the pipeline before and after a reload storm. Renamed to `bread.reloadtest.*` (a non-reserved domain). --- breadd/tests/ipc_integration.rs | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/breadd/tests/ipc_integration.rs b/breadd/tests/ipc_integration.rs index 894bc49..a862d31 100644 --- a/breadd/tests/ipc_integration.rs +++ b/breadd/tests/ipc_integration.rs @@ -822,9 +822,13 @@ async fn daemon_survives_repeated_reloads_and_pipeline_resumes() -> Result<()> { let harness = TestHarness::spawn()?; harness.wait_until_ready().await?; - // Event emitted before any reload. + // Event emitted before any reload. A non-reserved event name: `reload` is + // an adapter-owned domain, so a manual `emit` of `bread.reload.*` is now + // rejected by the normalizer (see "Allow well-formed bread.command events + // on the emit bus"). The name here is incidental — this test only cares + // that events flow through the pipeline before and after a reload storm. harness - .send_request("emit", json!({"event": "bread.reload.before", "data": {}})) + .send_request("emit", json!({"event": "bread.reloadtest.before", "data": {}})) .await?; // Hammer reload: each cycle drops and rebuilds the Lua VM, cancels timers, @@ -845,7 +849,7 @@ async fn daemon_survives_repeated_reloads_and_pipeline_resumes() -> Result<()> { // The pipeline must have resumed: an event emitted *after* the reloads // still flows through normalization into the replay buffer. harness - .send_request("emit", json!({"event": "bread.reload.after", "data": {}})) + .send_request("emit", json!({"event": "bread.reloadtest.after", "data": {}})) .await?; sleep(Duration::from_millis(100)).await; @@ -859,7 +863,7 @@ async fn daemon_survives_repeated_reloads_and_pipeline_resumes() -> Result<()> { .filter_map(|e| e.get("event").and_then(Value::as_str)) .collect(); assert!( - names.contains(&"bread.reload.after"), + names.contains(&"bread.reloadtest.after"), "event pipeline did not resume after reload; got {names:?}" );